使用netty搭建一个简单的聊天室

1.导入maven依赖

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

2.ChannelHandler

我们需要写一个处理消息的handler，继承SimpleChannelInboundHandler即可，然后实现我们需要实现的几个方法。

因为我们要搭建的是一个聊天室，所以需要有一个对象ChannelGroup来将所有客户端保存起来。每当一个用户连接到服务器，就将该用户所在的通道加入到该对象中。当任一用户发送消息，将消息遍历发送给所有用户。

/*** 处理消息的handler* TextWebSocketFrame: 在netty中，是用于为websocket专门处理文本的对象，frame是消息的载体*/
public class ChatHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {
/*** 用来保存所有的客户端连接*/private static ChannelGroup clients = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm");
/*** 当Channel中有新的事件消息会自动调用*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) {// 当接收到数据后会自动调用
// 获取客户端发送过来的文本消息String text = msg.text();System.out.println("接收到消息数据为：" + text);
for (Channel client : clients) {// 将消息发送到所有的客户端client.writeAndFlush(new TextWebSocketFrame(sdf.format(new Date()) + ":" + text));}}
/*** 当有新的客户端连接服务器之后，会自动调用这个方法*/@Overridepublic void handlerAdded(ChannelHandlerContext ctx) {// 将新的通道加入到clientsclients.add(ctx.channel());}
}

3.ChannelHandler

ChannelInitializer的主要目的是为程序员提供了一个简单的工具，用于在某个Channel注册到EventLoop后，对这个Channel执行一些初始化操作。ChannelInitializer虽然会在一开始被注册到Channel相关的pipeline里，但是在初始化完成之后，ChannelInitializer会将自己从pipeline中移除，不会影响后续的操作。

/*** 通道初始化器* 用来加载通道处理器（ChannelHandler)*/
public class WebSocketChannelInitializer extends ChannelInitializer<SocketChannel> {
// 初始化通道// 在这个方法中去加载对应的ChannelHandler@Overrideprotected void initChannel(SocketChannel ch) throws Exception {// 获取管道，将一个一个的ChannelHandler添加到管道中ChannelPipeline pipeline = ch.pipeline();
// 添加一个http的编解码器pipeline.addLast(new HttpServerCodec());// 添加一个用于支持大数据流的支持pipeline.addLast(new ChunkedWriteHandler());// 添加一个聚合器，这个聚合器主要是将HttpMessage聚合成FullHttpRequest/Responsepipeline.addLast(new HttpObjectAggregator(1024 * 64));
// 需要指定接收请求的路由// 必须使用以ws后缀结尾的url才能访问pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
// 添加自定义的Handlerpipeline.addLast(new ChatHandler());}
}

4.客户端server

public class WebSocketNettyServer {public static void main(String[] args) {// 创建两个线程池NioEventLoopGroup mainGrp = new NioEventLoopGroup(); // 主线程池NioEventLoopGroup subGrp = new NioEventLoopGroup(); // 从线程池
try {// 创建Netty服务器启动对象ServerBootstrap serverBootstrap = new ServerBootstrap();
// 初始化服务器启动对象serverBootstrap// 指定使用上面创建的两个线程池.group(mainGrp, subGrp)// 指定Netty通道类型.channel(NioServerSocketChannel.class)// 指定通道初始化器用来加载当Channel收到事件消息后，// 如何进行业务处理.childHandler(new WebSocketChannelInitializer());
// 绑定服务器端口，以同步的方式启动服务器ChannelFuture future = serverBootstrap.bind(9090).sync();// 等待服务器关闭future.channel().closeFuture().sync();} catch (InterruptedException e) {e.printStackTrace();} finally {// 优雅关闭服务器mainGrp.shutdownGracefully();subGrp.shutdownGracefully();}
}
}

5.html页面

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>在线聊天室</title>
</head>
<body><input type="text" id="message"><input type="button" value="发送消息" onclick="sendMsg()">
接收到的消息:<p id="server_message" style="background-color: #AAAAAA"></p>
<script>
var websocket = null;
// 判断当前浏览器是否支持websocketif(window.WebSocket) {websocket = new WebSocket("ws://127.0.0.1:9090/ws");
websocket.onopen = function() {console.log("建立连接.");}websocket.onclose = function() {console.log("断开连接");}websocket.onmessage = function(e) {console.log("接收到服务器消息:" + e.data);var server_message = document.getElementById("server_message");server_message.innerHTML += e.data + "<br/>";}}else {alert("当前浏览器不支持web socket");}
function sendMsg() {var message = document.getElementById("message");websocket.send(message.value);}</script>
</body>
</html>

6.测试

打开多个页面，然后发送消息，不同页面都能实时的显示不同页面发送的消息。

使用netty搭建一个简单的聊天室相关推荐

Netty - 一个简单的聊天室小项目
经过一段时间对Netty的学习,我们对Netty各版本以及像ProtocolBuffers等技术应用都有了不少相关的了解, 我们就用这段时间学到的只是做一个简单的聊天室的小项目来练习自己学到的技术. ...
用ServletContext做一个简单的聊天室
这里主要是ServletContext的一个特性:ServletContext是一个公共的空间,可以被所有的客户访问.由此可见ServletContext比cookie和session的作用范围要大[ ...
python开发一个简单的聊天室
使用python的twisted框架编写一个简单的聊天室下面是基本架构基本架构图 -- coding:utf-8 -- from twisted.internet.protocol import ...
前端+node实现一个简单的聊天室功能
简单的实现一个聊天室功能目录前言一.了解一下WebSocket 我们有了http协议,为什么会出现ws呢? ws出现之前,我们是怎么实现双向通信的呢? 二.使用到的websocket库三.聊天 ...
使用Unity制作一个简单的聊天室
使用控制台作为一个服务器,在Unity中开发客户端,制作一个简易的聊天室,无论哪个客户端发送消息,其他的客户端都会实时的显示出来. 服务器代码 using System; using System.C ...
Ubuntu下用apache+perl搭建最简单的聊天室
最近学习了下perl,尝试自己搭建一个聊天室,现已搭建成功,但设计方法很简陋,误见笑,收获在于对apache.html.perl都有了些许认识,后面打算学习LAMP(Linux+Apache+MySQ ...
Go 实现一个简单的聊天室
创建客户端先在main方法中创建一个sorcket服务端,这个服务端就像一个酒店 func main() {listen, err := net.Listen("tcp", &q ...
python 土拨鼠库_为了应对某人的需求，写了一个简单的聊天室内容
Python聊天室背景这是一篇水文,同时也是更换markdown后的第一篇,主要是为了测试markdown的情况. 服务器程序 #!/usr/bin/env python # -*- coding ...
10分钟教对象搭建了一个多人聊天室~
Demo演示体验demo链接: http://socket.vjscoder.com/websocket-chatroom/index.html#/ 去github查看完整源码: https://g ...