Springboot+netty网络聊天

  • 一、新建SringWeb项目
  • 二、环境配置
  • 三、代码实现
    • （一）项目结构
    • （二）代码
    • （三）测试文件
  • 四、运行结果
  • 五、总结
  • 六、参考资料

一、新建SringWeb项目

1.选择File->New-> Project

2.Spring Initializr->Next
3.Java Version 对于JDK选择8，点击next
4.选择新建Sring Web项目
5.创建成功如下

二、环境配置

1.在pom.xml里面添加依赖

 <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId></dependency><dependency><groupId>com.google.code.gson</groupId><artifactId>gson</artifactId></dependency>

2.会出现提示，点击Impot

三、代码实现

（一）项目结构

（二）代码

1.User

package com.example.demo;import java.util.Objects;public class User {public String id;public String nickname;public User(String id, String nickname) {super();this.id = id;this.nickname = nickname;}public String getId() {return id;}public void setId(String id) {this.id = id;}public String getNickname() {return nickname;}public void setNickname(String nickname) {this.nickname = nickname;}@Overridepublic boolean equals(Object o) {if (this == o)return true;if (o == null || getClass() != o.getClass())return false;User user = (User) o;return id.equals(user.getId());}@Overridepublic int hashCode() {return Objects.hash(id);}public String getUid() {return id;}
}

2.SessionGroup

package com.example.demo;import com.google.gson.Gson;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.ChannelGroupFuture;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.util.concurrent.ImmediateEventExecutor;
import org.springframework.util.StringUtils;import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;public final class SessionGroup {private static SessionGroup singleInstance = new SessionGroup();// 组的映射private ConcurrentHashMap<String, ChannelGroup> groupMap = new ConcurrentHashMap<>();public static SessionGroup inst() {return singleInstance;}public void shutdownGracefully() {Iterator<ChannelGroup> groupIterator = groupMap.values().iterator();while (groupIterator.hasNext()) {ChannelGroup group = groupIterator.next();group.close();}}public void sendToOthers(Map<String, String> result, SocketSession s) {// 获取组ChannelGroup group = groupMap.get(s.getGroup());if (null == group) {return;}Gson gson=new Gson();String json = gson.toJson(result);// 自己发送的消息不返回给自己
//      Channel channel = s.getChannel();// 从组中移除通道
//      group.remove(channel);ChannelGroupFuture future = group.writeAndFlush(new TextWebSocketFrame(json));future.addListener(f -> {System.out.println("完成发送："+json);
//          group.add(channel);//发送消息完毕重新添加。});}public void addSession(SocketSession session) {String groupName = session.getGroup();if (StringUtils.isEmpty(groupName)) {// 组为空，直接返回return;}ChannelGroup group = groupMap.get(groupName);if (null == group) {group = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE);groupMap.put(groupName, group);}group.add(session.getChannel());}/*** 关闭连接， 关闭前发送一条通知消息*/public void closeSession(SocketSession session, String echo) {ChannelFuture sendFuture = session.getChannel().writeAndFlush(new TextWebSocketFrame(echo));sendFuture.addListener(new ChannelFutureListener() {public void operationComplete(ChannelFuture future) {System.out.println("关闭连接："+echo);future.channel().close();}});}/*** 关闭连接*/public void closeSession(SocketSession session) {ChannelFuture sendFuture = session.getChannel().close();sendFuture.addListener(new ChannelFutureListener() {public void operationComplete(ChannelFuture future) {System.out.println("发送所有完成："+session.getUser().getNickname());}});}/*** 发送消息* @param ctx 上下文* @param msg 待发送的消息*/public void sendMsg(ChannelHandlerContext ctx, String msg) {ChannelFuture sendFuture = ctx.writeAndFlush(new TextWebSocketFrame(msg));sendFuture.addListener(f -> {//发送监听System.out.println("对所有发送完成："+msg);});}
}

3.SocketSession

ackage com.example.demo;import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.AttributeKey;import java.util.HashMap;
import java.util.Map;
import java.util.UUID;public class SocketSession {public static final AttributeKey<SocketSession> SESSION_KEY = AttributeKey.valueOf("SESSION_KEY");/*** 用户实现服务端会话管理的核心*/
// 通道private Channel channel;// 用户private User user;// session唯一标示private final String sessionId;private String group;/*** session中存储的session 变量属性值*/private Map<String, Object> map = new HashMap<String, Object>();public SocketSession(Channel channel) {//注意传入参数channel。不同客户端会有不同channelthis.channel = channel;this.sessionId = buildNewSessionId();channel.attr(SocketSession.SESSION_KEY).set(this);}// 反向导航public static SocketSession getSession(ChannelHandlerContext ctx) {//注意ctx，不同的客户端会有不同ctxChannel channel = ctx.channel();return channel.attr(SocketSession.SESSION_KEY).get();}// 反向导航public static SocketSession getSession(Channel channel) {return channel.attr(SocketSession.SESSION_KEY).get();}public String getId() {return sessionId;}private static String buildNewSessionId() {String uuid = UUID.randomUUID().toString();return uuid.replaceAll("-", "");}public synchronized void set(String key, Object value) {map.put(key, value);}public synchronized <T> T get(String key) {return (T) map.get(key);}public boolean isValid() {return getUser() != null ? true : false;}public User getUser() {return user;}public void setUser(User user) {this.user = user;}public String getGroup() {return group;}public void setGroup(String group) {this.group = group;}public Channel getChannel() {return channel;}
}

4.WebSocketServer

package com.example.demo;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler;
import io.netty.handler.stream.ChunkedWriteHandler;
import io.netty.handler.timeout.IdleStateHandler;import java.util.concurrent.TimeUnit;
public class WebSocketServer {private static WebSocketServer wbss;private static final int READ_IDLE_TIME_OUT = 60; // 读超时private static final int WRITE_IDLE_TIME_OUT = 0;// 写超时private static final int ALL_IDLE_TIME_OUT = 0; // 所有超时public static WebSocketServer inst() {return wbss = new WebSocketServer();}public void run(int port) {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer <SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();// Netty自己的http解码器和编码器，报文级别 HTTP请求的解码和编码pipeline.addLast(new HttpServerCodec());// ChunkedWriteHandler 是用于大数据的分区传输// 主要用于处理大数据流，比如一个1G大小的文件如果你直接传输肯定会撑暴jvm内存的;// 增加之后就不用考虑这个问题了pipeline.addLast(new ChunkedWriteHandler());// HttpObjectAggregator 是完全的解析Http消息体请求用的// 把多个消息转换为一个单一的完全FullHttpRequest或是FullHttpResponse，// 原因是HTTP解码器会在每个HTTP消息中生成多个消息对象HttpRequest/HttpResponse,HttpContent,LastHttpContentpipeline.addLast(new HttpObjectAggregator(64 * 1024));// WebSocket数据压缩pipeline.addLast(new WebSocketServerCompressionHandler());// WebSocketServerProtocolHandler是配置websocket的监听地址/协议包长度限制pipeline.addLast(new WebSocketServerProtocolHandler("/ws", null, true, 10 * 1024));// 当连接在60秒内没有接收到消息时，就会触发一个 IdleStateEvent 事件，// 此事件被 HeartbeatHandler 的 userEventTriggered 方法处理到pipeline.addLast(new IdleStateHandler(READ_IDLE_TIME_OUT, WRITE_IDLE_TIME_OUT, ALL_IDLE_TIME_OUT, TimeUnit.SECONDS));// WebSocketServerHandler、TextWebSocketFrameHandler 是自定义逻辑处理器，pipeline.addLast(new WebSocketTextHandler());}});Channel ch = b.bind(port).syncUninterruptibly().channel();ch.closeFuture().syncUninterruptibly();// 返回与当前Java应用程序关联的运行时对象Runtime.getRuntime().addShutdownHook(new Thread() {@Overridepublic void run() {SessionGroup.inst().shutdownGracefully();bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}});}
}

5.WebSocketTextHandler

package com.example.demo;import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.timeout.IdleState;
import io.netty.handler.timeout.IdleStateEvent;import java.util.HashMap;
import java.util.Map;import static com.fasterxml.jackson.databind.type.LogicalType.Map;public class WebSocketTextHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {@Overrideprotected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception {SocketSession session = SocketSession.getSession(ctx);TypeToken<HashMap<String, String>> typeToken = new TypeToken<HashMap<String, String>>() {};Gson gson=new Gson();java.util.Map<String,String> map = gson.fromJson(msg.text(), typeToken.getType());User user = null;switch (map.get("type")) {case "msg":Map<String, String> result = new HashMap<>();user = session.getUser();result.put("type", "msg");result.put("msg", map.get("msg"));result.put("sendUser", user.getNickname());SessionGroup.inst().sendToOthers(result, session);break;case "init":String room = map.get("room");session.setGroup(room);String nick = map.get("nick");user = new User(session.getId(), nick);session.setUser(user);SessionGroup.inst().addSession(session);break;}}@Overridepublic void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {// 是否握手成功，升级为 Websocket 协议if (evt == WebSocketServerProtocolHandler.ServerHandshakeStateEvent.HANDSHAKE_COMPLETE) {// 握手成功，移除 HttpRequestHandler，因此将不会接收到任何消息// 并把握手成功的 Channel 加入到 ChannelGroup 中new SocketSession(ctx.channel());} else if (evt instanceof IdleStateEvent) {IdleStateEvent stateEvent = (IdleStateEvent) evt;if (stateEvent.state() == IdleState.READER_IDLE) {System.out.println("bb22");}} else {super.userEventTriggered(ctx, evt);}}
}

6.DemoApplication

package com.example.demo;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.env.Environment;import java.net.InetAddress;
import java.net.UnknownHostException;@SpringBootApplication
public class DemoApplication {public static void main(String[] args) throws UnknownHostException {ConfigurableApplicationContext application = SpringApplication.run(DemoApplication.class, args);Environment env = application.getEnvironment();String host = InetAddress.getLocalHost().getHostAddress();String port = env.getProperty("server.port");System.out.println("[----------------------------------------------------------]");System.out.println("聊天室启动成功！点击进入:\t http://" + host + ":" + port);System.out.println("[----------------------------------------------------------");WebSocketServer.inst().run(53134);}
}

（三）测试文件

在桌面新建一个用来测试的html网页文件
test.html

<!DOCTYPE html>
<html lang="en">
<!DOCTYPE HTML>
<head><meta http-equiv="Content-Type" content="text/html; charset=utf-8"/><title>群聊天室</title><style type="text/css">body {margin-right:50px;margin-left:50px;}.ddois {position: fixed;left: 120px;bottom: 30px;}</style>
</head>
<body>
群名：<input type="text" id="room" name="group" placeholder="请输入群">
<br /><br />
昵称：<input type="text" id="nick" name="name" placeholder="请输入昵称">
<br /><br />
<button type="button" οnclick="enter()">进入聊天群</button>
<br /><br />
<div id="message"></div>
<br /><br />
<div class="ddois"><textarea name="send" id="text" rows="10" cols="30" placeholder="输入发送消息"></textarea><br /><br /><button type="button" οnclick="send()">发送</button>
</div>
<script type="text/javascript">var webSocket;if (window.WebSocket) {webSocket = new WebSocket("ws://localhost:53134/ws");} else {alert("抱歉，您的浏览器不支持WebSocket协议!");}//连通之后的回调事件webSocket.onopen = function() {console.log("已经连通了websocket");
//                setMessageInnerHTML("已经连通了websocket");};//连接发生错误的回调方法webSocket.onerror = function(event){console.log("出错了");
//              setMessageInnerHTML("连接失败");};//连接关闭的回调方法webSocket.onclose = function(){console.log("连接已关闭...");}//接收到消息的回调方法webSocket.onmessage = function(event){console.log("bbdds");var data = JSON.parse(event.data)var msg = data.msg;var nick = data.sendUser;switch(data.type){case 'init':console.log("mmll");break;case 'msg':console.log("bblld");setMessageInnerHTML(nick+":  "+msg);break;default:break;}}function enter(){var map = new Map();var nick=document.getElementById('nick').value;var room=document.getElementById('room').value;map.set("type","init");map.set("nick",nick);console.log(room);map.set("room",room);var message = Map2Json(map);webSocket.send(message);}function send() {var msg = document.getElementById('text').value;var nick = document.getElementById('nick').value;console.log("1:"+msg);if (msg != null && msg != ""){var map = new Map();map.set("type","msg");map.set("msg",msg);var map2json=Map2Json(map);if (map2json.length < 8000){console.log("4:"+map2json);webSocket.send(map2json);}else {console.log("文本太长了，少写一点吧												


											

Springboot+netty网络聊天相关推荐
	

    
								
  1. Netty网络聊天室完整代码实现
		
    Netty服务端: package cn.zhangxueliang.netty.chat;import io.netty.bootstrap.ServerBootstrap; import io.n ...
    
		
    2. 
						
  2. Netty网络聊天(一) 聊天室实战
		
    之前做过一个IM的项目,里面涉及了基本的聊天功能,所以注意这系列的文章不是练习,不含基础和逐步学习的部分,直接开始实战和思想引导,基础部分需要额外的去补充,我有精力的话可以后续出一系列的文章. 为什么 ...
    
		
    3. 
						
  3. springboot+netty实现网络聊天
		
    一.springboot+netty实现网络聊天 1.创建项目 选择spring initialzr,点击next 改一下项目名字和所使用的Java版本,点击next 选择spring web,点击n ...
    
		
    4. 
						
  4. Netty网络编程聊天项目
		
                                     Netty网络编程聊天项目 后端编写 导入依赖    <dependencies><dependency>&l ...
    
		
    5. 
						
  5. java在线客服系统源码 springboot客服聊天源码 网页客服源码 netty通信技术，java源码
		
    ava在线客服系统源码 springboot客服聊天源码 网页客服源码 netty通信技术,java源码 Java在线客服系统源码 企业网站客服聊天源码 网页客服源码 开发环境:Java + Spri ...
    
		
    6. 
						
  6. springboot+netty 仿微信网页版聊天工具
		
    本程序仿照微信界面进行开发,使用springboot+netty完成整体的框架开发,数据库方面使用h2数据库,前端部分使用thymeleaf,后期将会继续开发Ant Design React版.打包时 ...
    
		
    7. 
						
  7. Netty网络编程实战2，使用Netty开发聊天室功能
		
    目录 一.服务端 1.主程序类 2.自定义初始化器 3.自定义处理器 二.客户端 1.主程序类 2.自定义初始化器 3.自定义处理器 三.启动服务端.客户端 1.服务端:你好,我是服务端,哪吒编程 2 ...
    
		
    8. 
						
  8. 基于 Netty 网络编程项目实战课程
		
    一 基于 Netty 网络编程项目实战课程 1项目介绍 2Netty 介绍与相关基础知识 2.1Netty 介绍 简介 Netty 是由 JBOSS 提供的一个 java 开源框架.Netty 提供异 ...
    
		
    9. 
						
  9. Netty 4.x Netty 实现聊天功能
		
    Netty 实现聊天功能 Netty 是一个 Java NIO 客户端服务器框架,使用它可以快速简单地开发网络应用程序,比如服务器和客户端的协议.Netty 大大简化了网络程序的开发过程比如 TCP  ...
    
		
    10. 
		


					

最新文章
	

    
						
  1. 配置Hyper-V Server 资源计量
		
    2. 
						
  2. java移动接口发短信_天天都会写接口(interface)，但它的用途和好处有多少人能说得清楚？
		
    3. 
						
  3. qr码是二维码码_如何使用QR码进行有效的营销和推广
		
    4. 
						
  4. linux目录变成只读,解决Linux文件系统变成只读的方法
		
    5. 
						
  5. 04-10 swagger 接口管理体系
		
    6. 
						
  6. RK3288_Android7.1调试RTC总结（一）
		
    7. 
						
  7. 扇贝有道180913每日一句
		
    8. 
						
  8. 十六进制转二进制（转）
		
    9. 
						
  9. MacBook Pro 安装软件navicat15  ,  mac10.15安装navcat15
		
    10. 
						
  10. 密码学---攻击类型
		
    11. 
						
  11. iOS 添加自定义字体
		
    12. 
						
  12. Android开发 调用系统相机相册图片功能，解决小米手机拍照或者图片横竖相反问题，及小米手机相册图片路径问题
		
    13. 
						
  13. 【Web技术】1391- 页面可视化搭建工具前生今世
		
    14. 
						
  14. 旋转编码器详解(主要讨论增量式编码器与绝对式编码器)
		
    15. 
						
  15. 关于MD5和SHA-1的简单的介绍
		
    16. 
						
  16. Python实战：利用Tkinter实现屏保程序
		
    17. 
						
  17. 用navicat对比两个数据库表结构
		
    18. 
						
  18. Java Validation Api 详解
		
    19. 
						
  19. windows10 wls 配置流程a
		
    20. 
						
  20. 基于websocket的网络聊天室
		
    21. 
		

	


热门文章
	

    
									
  1. 软件破解(1)-Java篇
			
    2. 
						
  2. 邓应海：黄金冲高逼近1790后上演大逆转！最新黄金走势分析！
			
    3. 
						
  3. 金庸逝世两周年纪念日：一个失意程序员的呓语
			
    4. 
						
  4. Andoird Overview
			
    5. 
						
  5. 感受DataGrid给数据操作带来的便利（3）
			
    6. 
						
  6. MATLAB牛拉法,MATLAB潮流程序(IEEE14直角坐标牛拉法).doc
			
    7. 
						
  7. maven依赖拉不下来Process terminated【解决方法之一】
			
    8. 
						
  8. 树莓派WIFI一键连接配置
			
    9. 
						
  9. 【工具】sourceinsight4.0-工具栏被隐藏如何恢复
			
    10. 
						
  10. HDU 1290 献给杭电五十周年校庆的礼物 平面分割球
			
    11.