一、创建项目

java版本选8，选择web中的spring web

在pom.xml的dependencies加入以下代码

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

二、环境配置

1.下载gson2.8.9.jar
Maven Central Repository Search

2.File–>settings–>Runner 勾选如图下的选项后，点击OK

3.导入包

三、项目结构及代码 

1.项目结构

2.代码

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);}
}

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);});}
}

SocketSession

package 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;}
}

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;}
}

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();}});}
}

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);}}
}

创建一个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实现基于Web的聊天室相关推荐
	

    
						
  1. 使用Springboot+netty实现基于Web的聊天室
		
    一.项目创建 选择Spring Initializr 选择JDK版本 选择Spring Web 确定项目名称及保存路径 创建成功 二.编写代码 导入相关jar包及相关类的创建 下载地址: https: ...
    
		
    2. 
								
  2. SpringBoot + Vue 实现基于 WebSocket 的聊天室(单聊)
		
    前言 在前一篇文章SpringBoot 集成 STOMP 实现一对一聊天的两种方法中简单介绍了如何利用 STOMP 实现单聊,本文则将以一个比较完整的示例展示实际应用,不过本文并未使用 STOMP,而 ...
    
		
    3. 
						
  3. 基于Web的聊天室（Springboot+netty)
		
    1.新建空白项目 选中File -> New-> Project 修改项目信息: 选中web,选中spring web 添加文件依赖: <?xml version="1.0 ...
    
		
    4. 
						
  4. 基于Web的聊天室构建
		
    技术:Java.JSP等 摘要: 随着网络的发展与技术的不断成熟,越来越多出色的聊天软件冲击着聊天室的发展,聊天室要想在夹缝中生存,必须有自己的特点.现在各大网站都把聊天室嵌入到了网站中,但是目前还没 ...
    
		
    5. 
						
  5. 基于 SpringBoot+WebSocket 无DB实现在线聊天室（附源码）
		
    文章目录 基于 SpringBoot+WebSocket 无DB实现在线聊天室 0 项目说明 0.1 样例展示 0.2 源码地址 1 WebSocket 简介 1.1 HTTP 1.2 WebSock ...
    
		
    6. 
						
  6. Springboot毕设项目基于WEB的延边旅游网 5jjp2java+VUE+Mybatis+Maven+Mysql+sprnig）
		
    Springboot毕设项目基于WEB的延边旅游网 5jjp2java+VUE+Mybatis+Maven+Mysql+sprnig) 项目运行 环境配置: Jdk1.8 + Tomcat8.5 +  ...
    
		
    7. 
						
  7. 基于web视频聊天技术归纳
		
    本文转载于http://zhidao.baidu.com/link?url=brsWhD7CoFno5-Lojb-lpz7Vc8VeD6WPI_4Eh5cWnVdfYRUJoIGCyYCzO_J3tx ...
    
		
    8. 
						
  8. 基于SSM的Web网页聊天室系统设计与实现 毕业论文+项目源码及数据库文件、
		
    下载地址:https://download.csdn.net/download/ouyangxiaobai123/22679732 项目介绍: 基于SSM的Web网页聊天室系统设计与实现 毕业论文+项 ...
    
		
    9. 
						
  9. java语言基于springboot+vue+elementUI 基于web的智慧养老平台-#计算机毕业设计
		
    项目介绍 随着社会的发展我国的人口老龄化严重,为了让这些在年前是给社会做出过贡献的老人老有所依,老有所养,度过一个安详的晚年,很多地方都实现了智慧养老,为此我们通过springboot+vue+ele ...
    
		
    10. 
		


					

最新文章
	

    
						
  1. 【鸿蒙 HarmonyOS】Ability 中使用纯代码绘制布局及 UI 组件
		
    2. 
						
  2. NeurIPS 2018 | 腾讯AI Lab详解3大热点：模型压缩、机器学习及最优化算法
		
    3. 
						
  3. Linux系统常用目录操作函数
		
    4. 
						
  4. netlify支持php吗,hexo  netlify 搭建简易博客
		
    5. 
						
  5. （转）tomcat配置访问项目时不需要加项目名称
		
    6. 
						
  6. 玩转spring boot——国际化
		
    7. 
						
  7. shmget出现Invalid argument错误
		
    8. 
						
  8. 浓缩的就是精华——ES6迭代器精炼讲解
		
    9. 
						
  9. 用友U8.72　审核成品入库单时生成销售出库单　SQL触发器　　－－白波九道
		
    10. 
						
  10. 物业计算机管理系统论文,小区物业管理系统设计毕业论文
		
    11. 
						
  11. Win10 安装 Tomcat 解压版
		
    12. 
						
  12. Unity Wwise 自己使用
		
    13. 
						
  13. 华为鸿蒙11公测版,首升鸿蒙2.0系统！华为官宣这10款机型率先公测EMUI11-互联网/电商-文章-小虾米...
		
    14. 
						
  14. 000webhost – 1500M支持PHP可绑米免费虚拟主机
		
    15. 
						
  15. php微信上传头像,微信小程序怎么上传头像
		
    16. 
						
  16. RAS 和 NDIS 拨号模式
		
    17. 
						
  17. OFDM学习笔记（一）（OFDM技术简介）
		
    18. 
						
  18. Java编写猜单词游戏
		
    19. 
						
  19. Android studio app启动时默认启动页面为自定义界面
		
    20. 
						
  20. 内地炒美股需要什么条件？有哪些美股交易基础要点
		
    21. 
		

	


热门文章
	

    
									
  1. html逻辑像素和实际像素,物理像素、逻辑像素、设备像素比、PPI、二倍图、css3盒子模型、布局视口、视觉视口、理想视口...
			
    2. 
						
  2. IDEA插件-CheckStyle的安装与使用
			
    3. 
						
  3. 你真的理解持续集成(CI)吗？
			
    4. 
						
  4. （超详解）Linux系统find命令用法
			
    5. 
						
  5. 临摹图标都有哪些技巧，五个临摹图标案例告诉你
			
    6. 
						
  6. 阿里面试题：Pandas中合并数据的5个函数，各有千秋！
			
    7. 
						
  7. 缓存穿透，缓存击穿，缓存雪崩详解
			
    8. 
						
  8. 什么是html_什么是HTML？
			
    9. 
						
  9. SQL Server注释
			
    10. 
						
  10. 战争升级谷歌限制华为使用android,谷歌“神助攻”！Android12将不支持华为手机，鸿蒙迎来新挑战...
			
    11.