使用netty实现聊天室功能

文章目录

1. 引入依赖
2. 聊天室服务端代码
3. 聊天室客户端代码

1. 引入依赖

netty 5.x 以后的版本已流产，建议使用4.x的版本

        <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.35.Final</version></dependency>

2. 聊天室服务端代码

public class ChatServer {public static void main(String[] args) throws InterruptedException {//创建两个线程组bossGroup和workerGroup, 含有的子线程NioEventLoop的个数默认为cpu核数的两倍// bossGroup只是处理连接请求 ,真正的和客户端业务处理，会交给workerGroup完成NioEventLoopGroup boosGroup = new NioEventLoopGroup();NioEventLoopGroup workerGroup = new NioEventLoopGroup(8);try {//创建服务器对象ServerBootstrap serverBootstrap = new ServerBootstrap();/*** group：设置两个线程组bossGroup和workerGroup* channel：使用NioServerSocketChannel作为服务端的通道实现* option：初始化服务器连接队列大小为1024.*         服务端处理客户端连接请求是顺序处理的,所以同一时间只能处理一个客户端连接。*         多个客户端同时来的时候,服务端将不能处理的客户端连接请求放在队列中等待处理。* childHandler：创建通道初始化对象，设置处理器*/serverBootstrap.group(boosGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {//对workerGroup的SocketChannel设置处理器，设置客户端发来的数据的处理逻辑//获取ChannelPipelineChannelPipeline pipeline = socketChannel.pipeline();//向pipeline中加入解码器pipeline.addLast("decoder",new StringDecoder());//向pipeline中加入编码器pipeline.addLast("encoder",new StringEncoder());//向pipeline中加入业务Handlerpipeline.addLast(new ChatServerHandler());}});System.out.println("聊天室服务端已启动。。。");/*** 服务端对象绑定 9000 端口并启动*   sync():由于bind方法是异步操作，使用sync()方法是等待异步操作执行完毕。*/ChannelFuture cf = serverBootstrap.bind(9000).sync();/*** 对通道关闭进行监听* 由于closeFuture是异步操作，通过sync方法同步等待通道关闭处理完毕，这里会阻塞等待通道关闭完成*/cf.channel().closeFuture().sync();}finally {boosGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

服务端业务处理ChatServerHandler代码

public class ChatServerHandler extends SimpleChannelInboundHandler<String> {//GlobalEventExecutor.INSTANCE 是全局的事件执行器，是一个单例，记录所有已在线的连接private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);//日期格式化器SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");/*** 如果连上服务端，触发channelActive方法* @param ctx  上下文对象, 含有通道channel，管道pipeline*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {//获取channelChannel channel = ctx.channel();//把当前客户端上线信息 推送到其他已在线的客户端// 1. writeAndFlush()遍历channelGroup所有已在线的客户端channelGroup.writeAndFlush("[ 客户端 ]"+channel.remoteAddress()+" 上线了! "+sdf.format(new Date())+"\n");// 2. 把当前channel连接加入到channelGroup中去channelGroup.add(channel);//服务器端打印客户端上线信息System.out.println(channel.remoteAddress()+" 上线了! "+"\n");}@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {//获取channelChannel channel = ctx.channel();//客户端下线信息发送给其他客户端channelGroup.writeAndFlush("[ 客户端 ]"+channel.remoteAddress()+" 下线了! "+"\n");//服务器端打印客户端下线信息System.out.println(channel.remoteAddress()+" 下线了! 还剩余："+channelGroup.size()+" 个客户端！"+"\n");}@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, String msg) throws Exception {//获取当前channelChannel channel = channelHandlerContext.channel();channelGroup.forEach(x -> {if (channel != x) {x.writeAndFlush("[ 客户端 ]" + channel.remoteAddress() + " 发送了消息：" + msg + "\n");}else {x.writeAndFlush("[ 自己 ]发送了消息：" + msg + "\n");}});}
}

3. 聊天室客户端代码

public class ChatClient {public static void main(String[] args) throws InterruptedException {//客户端只需要一个事件循环组NioEventLoopGroup group = new NioEventLoopGroup();try {//创建客户端启动对象//注意客户端使用的不是 ServerBootstrap 而是 BootstrapBootstrap bootstrap = new Bootstrap();/**设置客户端相关参数* group：设置线程组* channel：使用NioSocketChannel作为客户端通道实现，注意服务端为NioServerSocketChannel* handler：创建通道初始化对象，加入客户端处理器*/bootstrap.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel channel) throws Exception {//加入处理器ChannelPipeline pipeline = channel.pipeline();//向pipeline中加入编码器pipeline.addLast(new StringEncoder());//向pipeline中加入解码器pipeline.addLast(new StringDecoder());//向pipeline中加入业务Handlerpipeline.addLast(new ChatClientHandler());}});//启动客户端去连接服务端ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 9000).sync();//得到channelChannel channel = channelFuture.channel();System.out.println("=============== " + channel.remoteAddress()+" ==================");//客户端发送消息Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String msg = scanner.nextLine();//通过客户端把输入内容发送到服务端channel.writeAndFlush(msg);}//对关闭通道进行监听
//            channelFuture.channel().closeFuture().sync();} finally {group.shutdownGracefully();}}
}

客户端业务处理ChatClientHandler代码

public class ChatClientHandler extends SimpleChannelInboundHandler<String> {@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, String msg) throws Exception {//打印服务端发送的消息System.out.println(msg.trim());}
}

使用netty实现聊天室功能相关推荐

Netty网络编程实战2，使用Netty开发聊天室功能
目录一.服务端 1.主程序类 2.自定义初始化器 3.自定义处理器二.客户端 1.主程序类 2.自定义初始化器 3.自定义处理器三.启动服务端.客户端 1.服务端:你好,我是服务端,哪吒编程 2 ...
Netty实现聊天室
文章目录注:更多netty相关文章请访问博主专栏: netty专栏本文内容基于上一篇博客 netty实现WebSocket协议,一些基本使用请参考该博客. 本例实现的功能: 有新成员加入时,群广播 ...
SpringBoot +WebSocket实现简单聊天室功能实例
SpringBoot +WebSocket实现简单聊天室功能实例) 一.代码来源二.依赖下载三.数据库准备(sql) 数据库建表并插入sql 四.resources文件配置 application ...
netty加载html文件的原理,Netty+html聊天室入门
1)服务端 ChatServer.java package chat; import chat.handler.WSServerInitializer; import io.netty.bootstr ...
python udp 直播_[Python] socket发送UDP广播实现聊天室功能
原博文 2018-11-24 12:33 − 一.说明本文主要使用socket.socket发送UDP广播来实现聊天室功能. 重点难点:理解UDP通讯流程.多线程.UDP广播收发等. 测试环境:Wi ...
php 利用redis写一个聊天室,Redis实现多人多聊天室功能
本文为大家分享了Redis支持多人多聊天室功能的设计代码,供大家参考,具体内容如下设计原理左边的一个数据域,代表两个聊天室,聊天室id分别是827,729 在聊天室827里,有2个人,分别是jas ...
java socket编程聊天室_Java Socket通信之聊天室功能
Java Socket通信之聊天室功能发布时间:2020-10-17 14:36:00 来源:脚本之家阅读:73 作者:LY_624 本文实例为大家分享了Java Socket聊天室功能的具体代码 ...
php 开发一个聊天系统,ajax+php 实现一个简单的在线聊天室功能（附带源码）
通过ajax和setInterval()函数,配合php+mysql实现一个简单的在线聊天室的功能.附带详细源码案例.这个聊天室是一个简单的聊天室,通过javascript setInterval() ...
APP开发者如何来实现视频聊天室功能
这是一个新型的互联网业态,直播社交业务所带来的"钱景"正吸引越来越多的玩家进入这一行业.无论是专注秀场直播的YY,网易BoBo,还是提供手机直播的爆款应用Meerkat.在2015 ...

使用netty实现聊天室功能

文章目录

1. 引入依赖

2. 聊天室服务端代码

3. 聊天室客户端代码

使用netty实现聊天室功能相关推荐

最新文章

热门文章