1 概述

(1) Http协议是无状态的,浏览器和服务器间的请求响应一次,下ー次会重新创建连接。
(2) 要求:实现基于 websockete的长连接的全双工的交互。
(3) 改变Http协议多次请求的约束,实现长连接了,服务器可以发送消息给浏览器。
(4) 客户端浏览器和服务器端会相互感知,比如服务器关闭了,浏览器会感知,同样浏览器关闭了,服务器会感知。

2 实现

2.1 WebSocketServerConsts

public final class WebSocketServerConsts {private WebSocketServerConsts() {}public static final Integer port = 8888;}

2.2 WebSocketHandler

public class WebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {@Overrideprotected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception {System.out.println("服务器接收到消息：" + msg.text());//回复消息ctx.channel().writeAndFlush(new TextWebSocketFrame("服务器时间" + LocalDateTime.now() + " " + msg.text()));}/*** 客户端连接后*/@Overridepublic void handlerAdded(ChannelHandlerContext ctx) throws Exception {System.out.println("handlerAdded 被调用" + ctx.channel().id().asLongText());System.out.println("handlerAdded 被调用" + ctx.channel().id().asShortText());}/***客户端断开连接时触发*/@Overridepublic void handlerRemoved(ChannelHandlerContext ctx) throws Exception {System.out.println("handlerRemoved 被调用" + ctx.channel().id().asLongText());}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {System.out.println("发生异常" + cause.getMessage());ctx.channel();}
}

2.3 WebSocketServerChannelInitializer

public class WebSocketServerChannelInitializer extends ChannelInitializer<SocketChannel> {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();//http 编码、解码器pipeline.addLast(new HttpServerCodec());//以块的方式写pipeline.addLast(new ChunkedWriteHandler());//http数据在传输过程中是分段的，HttpObjectAggregator可以将多个段聚合pipeline.addLast(new HttpObjectAggregator(8192));//websocketServerProtocolHandler，将http协议升级为ws协议，浏览器请求时uri为 ws://localhost:8888/hellopipeline.addLast(new WebSocketServerProtocolHandler("/hello"));//自定义handlerpipeline.addLast(new WebSocketHandler());}
}

2.4 WebSocketServer

public class WebSocketServer {public static void main(String[] args) {EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new WebSocketServerChannelInitializer());ChannelFuture channelFuture = serverBootstrap.bind(WebSocketServerConsts.port).sync();System.out.println("服务器已经开启......");channelFuture.channel().closeFuture().sync();} catch (InterruptedException e) {e.printStackTrace();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}}

2.5 hello.html

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>WebSocket</title>
</head>
<body><form onsubmit="return false"><textarea name="message" style="height: 300px;width: 300px;"></textarea><input type="button" value="发送消息" onclick="send(this.form.message.value)"><textarea id="responseText" name="responseText" style="height: 300px;width: 300px;"></textarea><input type="button" value="清空内容" onclick="document.getElementById('responseText').value=''"></form><script>var socket;if (window.WebSocket) {socket = new WebSocket("ws://localhost:8888/hello");//接收服务器消息socket.onmessage = function (ev) {var rt = document.getElementById("responseText");rt.value = rt.value + "\n" + ev.data;}//连接开启socket.onopen = function (ev) {var rt = document.getElementById("responseText");rt.value = "连接开启......";}//连接关闭socket.onclose = function (ev) {var rt = document.getElementById("responseText");rt.value = rt.value + "\n" + "连接关闭了......";}} else {alert("当前浏览器不支持websocket");}//发送消息function send(message) {if (!window.WebSocket) {return;}if (socket.readyState == WebSocket.OPEN) {socket.send(message);} else {alert("连接没有开启");}}</script></body>
</html>

3 测试

关闭浏览器后：

Netty集成WebSocket实现客户端、服务端长连接相关推荐

客户端与服务端长连接的几种方式
客户端与服务端长连接的几种方式前言一.ajax 轮询二.long poll 长轮询三.iframe 长连接四.WebSocket 前言在日常 Web 项目中,通常使用的是短连接.即一个 R ...
SpringBoot集成WebSocket案例：服务端与客户端消息互通
pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="htt ...
京东的Netty实践，京麦TCP网关长连接容器架构
背景早期京麦搭建 HTTP 和 TCP 长连接功能主要用于消息通知的推送,并未应用于 API 网关.随着逐步对 NIO 的深入学习和对 Netty 框架的了解,以及对系统通信稳定能力越来越高的要求, ...
Java Websocket实例【服务端与客户端实现全双工通讯】
Java Websocket实例[服务端与客户端实现全双工通讯] 现很多网站为了实现即时通讯,所用的技术都是轮询(polling).轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP ...
netty 游戏服务器框图_基于Netty和WebSocket协议实现Web端自动打印订单服务方法与流程...
本发明涉及电子商务技术领域,尤其涉及一种基于netty和websocket协议实现web端自动打印订单服务方法. 背景技术: 电子商务是以信息网络技术为手段,以商品交换为中心的商务活动:也可理解为在互 ...
Node.js联机游戏——gobang五子棋（客户端+服务端+websocket的双人游戏）
Node.js联机游戏--gobang五子棋(客户端+服务端+websocket的双人游戏) 五子棋的基本结构 ~·基本画图 ~·判断机制 ~···横向/竖向判断 ~···斜向判断搭建服务器阶段 ~ ...
ZooKeeper客户端源码（一）——向服务端建立连接+会话建立+心跳保持长连接
首发CSDN:徐同学呀,原创不易,转载请注明源链接.我是徐同学,用心输出高质量文章,希望对你有所帮助. 一.从ZooKeeper实例初始化开始 ZooKeeper 提供了原生的客户端库,虽然不好用,但 ...
netty源码学习之服务端客户端初始化
文章目录 1. AbstractBootstrap类简介 1.1. 核心方法 2. netty服务端创建 2.1. 服务端启动入口 2.2. doBind()方法 2.3. netty服务初始化 2. ...
http协议与https协议+UDP协议和TCP协议+WebSocket协议下服务端主动去发送信息+对称加密与非对称加密+get和post请求方式区别详解+浏览器内核以及jsj解析引擎
TCP和UDP协议是TCP/IP协议的核心. 在TCP/IP网络体系结构中,TCP(传输控制协议,Transport Control Protocol).UDP(用户数据报协议,User Data P ...
【Netty系列_3】Netty源码分析之服务端channel
highlight: androidstudio 前言学习源码要有十足的耐性!越是封装完美的框架,内部就越复杂,源码很深很长!不过要抓住要点分析,实在不行多看几遍,配合debug,去一窥优秀框架的精 ...

Netty集成WebSocket实现客户端、服务端长连接

1 概述

2 实现

2.1 WebSocketServerConsts

2.2 WebSocketHandler

2.3 WebSocketServerChannelInitializer

2.4 WebSocketServer

2.5 hello.html

3 测试

Netty集成WebSocket实现客户端、服务端长连接相关推荐

最新文章

热门文章