一个简单的聊天室案例（基于netty+websocket）

1.------------------------webSocketServer 主要是用于启动netty服务------------------

/*** 启动WebSocketServer*/
@Component
public final class WebSocketServer {static final boolean SSL = System.getProperty("ssl") != null;public void start(Integer port) throws Exception {// Configure SSL.final SslContext sslCtx;if (SSL) {SelfSignedCertificate ssc = new SelfSignedCertificate();sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();} else {sslCtx = null;}EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).handler(new LoggingHandler(LogLevel.INFO)).childHandler(new WebSocketServerInitializer(sslCtx));Channel ch = b.bind(port).sync().channel();System.out.println("Open your web browser and navigate to " +(SSL? "https" : "http") + "://127.0.0.1:" + port + '/');ch.closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

2.---------------------------处理http请求用于处理http请求升级为ws

public class WebSocketIndexPageHandler extends SimpleChannelInboundHandler<FullHttpRequest> {private final String websocketPath;public WebSocketIndexPageHandler(String websocketPath) {this.websocketPath = websocketPath;}@Overrideprotected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {// Handle a bad request.if (!req.decoderResult().isSuccess()) {sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), BAD_REQUEST,ctx.alloc().buffer(0)));return;}// Allow only GET methods.if (!HttpMethod.GET.equals(req.method())) {sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), FORBIDDEN,ctx.alloc().buffer(0)));return;}// Send the index pageif ("/".equals(req.uri()) || "/index.html".equals(req.uri())) {String webSocketLocation = getWebSocketLocation(ctx.pipeline(), req, websocketPath);ByteBuf content = WebSocketServerIndexPage.getContent(webSocketLocation);FullHttpResponse res = new DefaultFullHttpResponse(req.protocolVersion(), OK, content);res.headers().set(CONTENT_TYPE, "text/html; charset=UTF-8");HttpUtil.setContentLength(res, content.readableBytes());sendHttpResponse(ctx, req, res);} else {sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), NOT_FOUND,ctx.alloc().buffer(0)));}}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {cause.printStackTrace();ctx.close();}private static void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req, FullHttpResponse res) {// Generate an error page if response getStatus code is not OK (200).HttpResponseStatus responseStatus = res.status();if (responseStatus.code() != 200) {ByteBufUtil.writeUtf8(res.content(), responseStatus.toString());HttpUtil.setContentLength(res, res.content().readableBytes());}// Send the response and close the connection if necessary.boolean keepAlive = HttpUtil.isKeepAlive(req) && responseStatus.code() == 200;HttpUtil.setKeepAlive(res, keepAlive);ChannelFuture future = ctx.writeAndFlush(res);if (!keepAlive) {future.addListener(ChannelFutureListener.CLOSE);}}private static String getWebSocketLocation(ChannelPipeline cp, HttpRequest req, String path) {String protocol = "ws";if (cp.get(SslHandler.class) != null) {// SSL in use so use Secure WebSocketsprotocol = "wss";}return protocol + "://" + req.headers().get(HttpHeaderNames.HOST) + path;}
}

3.------------------------静态页面

package com.netty.server.websocketServer;import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.util.CharsetUtil;/*** 返回一个聊天页面*/
public final class WebSocketServerIndexPage {private static final String NEWLINE = "\r\n";public static ByteBuf getContent(String webSocketLocation) {return Unpooled.copiedBuffer("<html><head><title>Web Socket Test</title></head>" + NEWLINE +"<body>" + NEWLINE +"<script type=\"text/javascript\">" + NEWLINE +"var socket;" + NEWLINE +"if (!window.WebSocket) {" + NEWLINE +"  window.WebSocket = window.MozWebSocket;" + NEWLINE +'}' + NEWLINE +"if (window.WebSocket) {" + NEWLINE +"  socket = new WebSocket(\"" + webSocketLocation + "\");" + NEWLINE +"  socket.onmessage = function(event) {" + NEWLINE +"    var ta = document.getElementById('responseText');" + NEWLINE +"    ta.value = ta.value + '\\n' + event.data" + NEWLINE +"  };" + NEWLINE +"  socket.onopen = function(event) {" + NEWLINE +"    var ta = document.getElementById('responseText');" + NEWLINE +"    ta.value = \"Web Socket opened!\";" + NEWLINE +"  };" + NEWLINE +"  socket.onclose = function(event) {" + NEWLINE +"    var ta = document.getElementById('responseText');" + NEWLINE +"    ta.value = ta.value + \"Web Socket closed\"; " + NEWLINE +"  };" + NEWLINE +"} else {" + NEWLINE +"  alert(\"Your browser does not support Web Socket.\");" + NEWLINE +'}' + NEWLINE +NEWLINE +"function send(message) {" + NEWLINE +"  if (!window.WebSocket) { return; }" + NEWLINE +"  if (socket.readyState == WebSocket.OPEN) {" + NEWLINE +"    socket.send(message);" + NEWLINE +"  } else {" + NEWLINE +"    alert(\"The socket is not open.\");" + NEWLINE +"  }" + NEWLINE +'}' + NEWLINE +"</script>" + NEWLINE +"<form οnsubmit=\"return false;\">" + NEWLINE +"<input type=\"text\" name=\"message\" value=\"Hello, World!\" style=\"width:300px;height:100px;border-color:#6699FF\"/>" +"<input type=\"button\" value=\"Send\"" + NEWLINE +"       οnclick=\"send(this.form.message.value)\" style=\"width:100px;height:100px;background:#66FF66\" />" + NEWLINE +"<h1>Output</h1>" + NEWLINE +"<textarea id=\"responseText\" style=\"width:400px;height:500px;border:20px;solid:#378888;border-color:#6699FF;background:#66FF66\"></textarea>" + NEWLINE +"</form>" + NEWLINE +"</body>" + NEWLINE +"</html>" + NEWLINE, CharsetUtil.US_ASCII);}private WebSocketServerIndexPage() {// Unused}
}

4.----------------------------------具体的处理消息handler

/**** @Description: 处理消息的handler* TextWebSocketFrame： 在netty中，是用于为websocket专门处理文本的对象，frame是消息的载体*/
public class WebSocketFrameHandler extends SimpleChannelInboundHandler<WebSocketFrame> {// 用于记录和管理所有客户端的channleprivate static ChannelGroup clients =new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);private static ConcurrentHashMap<Object,Object>  channels=new ConcurrentHashMap<>();private static  Integer count =0;// 定义接收到消息的操作@Overrideprotected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {// ping and pong frames already handledif (frame instanceof TextWebSocketFrame) {// Send the uppercase string back.String request = ((TextWebSocketFrame) frame).text();StringBuilder stringBuilder=new StringBuilder();;int index=(int)channels.get(ctx.channel().id());stringBuilder.append(RandomUtil.map.get(index)+": ");stringBuilder.append(request);for(Channel channel:clients){channel.writeAndFlush(new TextWebSocketFrame(stringBuilder.toString().toUpperCase(Locale.US)));}} else {String message = "unsupported frame type: " + frame.getClass().getName();throw new UnsupportedOperationException(message);}}/*** 当客户端连接服务端之后（打开连接）* 获取客户端的channle，并且放到ChannelGroup中去进行管理*/@Overridepublic void handlerAdded(ChannelHandlerContext ctx){try {count++;System.out.println("用户加入事件 "+ctx.channel().id()+" 第"+count+"个用户");clients.add(ctx.channel());int index=RandomUtil.getIndex();channels.put(ctx.channel().id(),index);}catch (Exception e){e.printStackTrace();System.out.println(e.getMessage());}}//定义用户离线的操作@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {Channel incoming = ctx.channel();System.out.println("用户:"+incoming+"掉线");}//定义用户异常的操作@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)throws Exception {Channel incoming = ctx.channel();System.out.println("用户:"+incoming.id()+"异常");cause.printStackTrace();ctx.close();}}

5.--------------------------------初始化Initializer

public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {private static final String WEBSOCKET_PATH = "/websocket";private final SslContext sslCtx;public WebSocketServerInitializer(SslContext sslCtx) {this.sslCtx = sslCtx;}@Overridepublic void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();if (sslCtx != null) {pipeline.addLast(sslCtx.newHandler(ch.alloc()));}//// websocket 基于http协议，所以要有http编解码器pipeline.addLast(new HttpServerCodec());//java.lang.NoSuchMethodError:// io.netty.util.internal.AppendableCharSequence.setLength(I)V//该异常是因为版本冲突导致pipeline.addLast(new HttpObjectAggregator(1024*64));//   WebSocket数据压缩pipeline.addLast(new WebSocketServerCompressionHandler());//    协议包长度限制pipeline.addLast(new WebSocketServerProtocolHandler(WEBSOCKET_PATH, null, true));//这个仅限demo使用 是用来返回初始化html页面的pipeline.addLast(new WebSocketIndexPageHandler(WEBSOCKET_PATH));/*  pipeline.addLast(new HttpRequestHandler("/ws"));*///具体的消息处理逻辑pipeline.addLast(new WebSocketFrameHandler());}}

6.----------------------util

package com.netty.server.websocketServer;import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import java.util.TreeSet;
import java.util.concurrent.ConcurrentHashMap;public class RandomUtil {static Map<Integer,String> map= new ConcurrentHashMap();static Set<Integer> set=new TreeSet<>();public static void getOne(){Random random=new Random();for(int i=0;i<10;i++){set.add(random.nextInt(10));}if(set.size()<10){getOne();}}static {getOne();map.put(0,"尼古拉斯儿");map.put(1,"张三");map.put(2,"李四");map.put(3,"王二麻子");map.put(4,"马六");map.put(5,"申公豹");map.put(6,"大麻花");map.put(7,"小垃圾");map.put(8,"鸡腿");map.put(9,"鸭腿");}public static int getIndex(){int re=0;if(!set.isEmpty()){Iterator itr=set.iterator();re=(int)itr.next();set.remove(re);return re;}return re;}
}

7.-----------------启动类

@SpringBootApplication
@ComponentScan("com.netty")
public class NettyServerApplication {public static void main(String[] args) {ConfigurableApplicationContext context = SpringApplication.run(NettyServerApplication.class, args);WebSocketServer webSocketServer=context.getBean(WebSocketServer.class);try {webSocketServer.start(8888);} catch (Exception e) {e.printStackTrace();}}}

效果图：

查看全文
如若内容造成侵权/违法违规/事实不符，请联系编程学习网邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！

小程序微信支付（PHP）
条件：申请微信支付商户号，拥有商户号id及商户号密钥一、微信接口 https://developers.weixin.qq.com/miniprogram/dev/api/open-api/payment/wx.requestPayment.html#wxrequestpaymentobject这几个参数需要通过wx.request从后台得到前台代码：wx.request({ …...
2024/4/28 0:53:49
在echarts中应用阿里巴巴图标库（iconfont）的图标——以散点图为例
修改echarts标记类型 1.symbol修改为官方预设值根据官网文档，以散点图为例，可以通过修改symbol属性值，修改默认的几种散点图标样式，直接在官方示例上试验代码，以最简单的散点图为例： option = {xAxis: {},yAxis: {},series: [{symbolSize: 20,symbol:pin, //这是我们设…...
2024/4/28 9:09:19
fyzf
目录1、接口说明2、首页目录菜单接口3、综治概况接口4、首页目录菜单数字接接口5、首页新闻标题接口6、新闻列表数据1、接口说明{"data":object,"code":"0","msg":"操作成功!","count":10000}所有接口都是上面格式…...
2024/4/28 5:24:02
推荐一款神器，比EXCEL还强大好上手
数据分析中，我们常用excel来进行数据的统计、数据展示以及数据的过滤，但数据的清洗过程和数据的可视化展现情况没有那么的可观，数据和数据之间实现联动、数据的层层递进如何实现，都是excel所不能实现或者实现起来不那么便捷的，在此我们的豌豆BI，一个敏捷时代的数据分析工…...
2024/4/28 4:56:26
学平面设计一定需要绘画基础吗？——黎乙丙
随着现在新媒体事业的发达，人们的美感慢慢觉醒，设计在我们的生活中也是处处可见，但很多人也像题主一样没有绘画基础却又想学平面设计，难道没有绘画基础就没法学平面设计了吗？答案是：不！我们可以另辟蹊径，条条大道通罗马，并不是非要会画画才可以做设计师。 1.平面设计是…...
2024/4/27 12:53:36
2D，3D你选谁？简单好用的3D可视化工具在这里
现状：3D可视化目前来说还是属于一个比较小众的设计群体，而且因为主要面对的客户大多是ToG或者ToB的项目，项目保密工作做的很好，对外发声较少，因此也会显得特别神秘，行业门槛也相对较高。但是由于政府和企业对于这类项目的需求大，再加上城市智慧建设、军事电子沙盘、智慧…...
2024/4/15 16:46:59
牛客周周练17-B-七彩线段
题目：输入样例： 4 2 1 3 1 4 5 1 5 8 2 7 9 3 输出样例： 5 挺恶心的一道题，我们用dp来解决，dp[i][j]代表什么，i代表前i个线段，j代表的是颜色（由1-2^7-1组成，其中二进制表示为1的位置就是j所含有的颜色), 举个例子，j = 5，用二进制表示就是101第一个位置和第三个位置有…...
2024/4/28 4:42:14
django快速入门(一)--简单学生管理系统--主体流程
前言 django 官方文档 https://docs.djangoproject.com/en/3.0/ 肯定是官方文档最全最细，这里的流程一个是我自己的练习，适合初学者，当一个流程走下来，可以从整体上去把握官方文档，去查阅更细节的东西。 django快速入门(一)–简单学生管理系统–主体流程 django快速入门(二…...
2024/4/28 12:06:56
linux操作系统部署jdk和nginx
1.jdk安装首先需要下载一个linux版本的jdk压缩包链接：http://pan.baidu.com/s/1nvGBzdR 密码：ziqb 详情参考：https://www.cnblogs.com/kuoAT/p/7555298.html 在etc/profile中进行修改环境变量 //安装jdk路径 export JAVA_HOME=/usr/java/jdk1.8.0_161 export PATH=$JAVA_H…...
2024/4/28 16:17:59
django快速入门(二)--站点管理与模型
django快速入门(一)–简单学生管理系统–主体流程 django快速入门(二)–站点管理与模型 django快速入门(三)–视图 django快速入门(四)–模板，部署站点管理创建一个能登录管理页面的用户。请运行下面的命令： python manage.py createsuperuser按照提示输入用户名、邮箱、密…...
2024/4/15 16:46:55
django快速入门(三)--视图
django快速入门(一)–简单学生管理系统–主体流程 django快速入门(二)–站点管理与模型 django快速入门(三)–视图 django快速入门(四)–模板，部署 URLconf 在项目mysite和应用students下都建立url.py文件是为了便于管理，一个项目可以有多个应用，把不同的应用全都塞在项目的…...
2024/4/25 0:52:41
LeetCode 17. 电话号码的字母组合
给定一个仅包含数字 2-9 的字符串，返回所有它能表示的字母组合。给出数字到字母的映射如下（与电话按键相同）。注意 1 不对应任何字母。示例: 输入："23" 输出：["ad", "ae", "af", "bd", "be", "bf&quo…...
2024/4/24 23:49:50
HDFS写数据流程
大致步骤①服务端启动HDFS中的NN和DN进程②客户端创建一个分布式文件系统客户端，由客户端向NN发送请求，请求上传文件③NN处理请求，检查客户端是否有权限上传，路径是否合法等④检查通过，NN响应客户端可以上传⑤客户端根据自己设置的块大小，开始上传第一个块，默认0-128M，…...
2024/4/15 16:46:52
viscode 使用vue模板快速创建
转载...
2024/4/25 1:32:23
WEB渗透学习笔记6——XSS漏洞
XSS——跨站脚本漏洞跨站脚本（Cross-Site Scripting），简称为XSS或CSS或跨站脚本攻击，是一种针对网站应用程序的安全漏洞攻击技术，是代码注入的一种。它允许恶意用户将代码注入网页，其他用户在浏览网页时就会受到影响。恶意用户利用XSS代码攻击成功后，可能得到很高的权限…...
2024/4/23 12:45:28
msfvenom & shellter——程序捆绑木马_端口映射远程控制
文章目录一、工具&环境二、准备三、木马与程序捆绑Ⅰ、msfvenom捆绑Ⅱ、shellter捆绑四、msfconsole监听完免责声明：本文章仅供网络安全方面学习、交流使用，任何操作与作者无关请遵守我国法律法规一、工具&环境VMware V15.5 Kali-Linux-2020.2 msfconsole msfvenom …...
2024/4/28 12:02:26
如何读懂数据的含义？（通俗版）
很多新人读不懂数据含义。对着报表，只会和复读机一样，叨叨：“昨天销量100，今天销量120，增加20……”讲这些只要不是瞎子都能看的到的东西。也因此经常被笑话，咋办？！今天我们系统讲解一下。读懂第一阶段：明指标给一个数字：180，能看出含义不？不能！因为这就是孤零…...
2024/4/24 23:15:36
架构篇---2---LAMP架构的部署与安装
LAMP架构的部署与安装方法一：使用rpm包安装lamp,并发布discuz论坛。（1）还原初始快照，桥接网卡，测试ping通外网，关闭防火墙和selinux systemctl stop firewalld \\关闭防火墙 setenforce 0 \\暂时关闭selinux（重启后将失效）（2）使用yum安装httpd mariadb …...
2024/4/25 6:56:07
浅谈Ros中使用launch启动文件的方法（三）：更多launch文件示例（详细讲解）--Ros入门21讲-第19讲笔记（持续更新）
浅谈Ros中使用launch启动文件的方法（三）：更多launch文件示例首先附上古月居老师的教程地址：古月居古月居老师《Ros入门21讲》的全部代码在个人主页中免费分享给大家共同学习 1.turtlesim_parameter_config.launch（对应《Ros入门21讲》第16讲有关内容 <launch><…...
2024/4/15 16:46:47
vue使用swiper组件循环轮播，点击事件连续跳转（穿透）
...
2024/4/22 6:13:55

一个简单的聊天室案例（基于netty+websocket）

相关文章

最新文章