2023-09-13
原文作者:https://blog.csdn.net/wangwei19871103/category_9681495_2.html 原文地址: https://blog.csdn.net/wangwei19871103/article/details/104634282

WebSocket

一种应用层协议,主要解决HTTP强交互时候的问题,节省带宽,提高传输效率,用在实时性比较强的地方,比如竞技游戏,RPC通信,即时通信等。具体的通信协议,格式我后面会说。

如何使用WebSocket

html中的jssocket = new WebSocket("ws://localhost:8080/wc");,即希望请求从HTTP升级到WebSocket,其实就是握手的协议内容。

202309132208163741.png

服务端代码

一般代码:

     	ChannelPipeline pipeline = ch.pipeline();               
    	pipeline.addLast(new HttpRequestDecoder());//HTTP请求解码
    	pipeline.addLast(new HttpResponseEncoder());//HTTP响应编码
    	pipeline.addLast(new HttpObjectAggregator(8192));//HTTP报文聚合
    	
    	pipeline.addLast(new WebSocketServerProtocolHandler("/wc"));//WEBSOCKET协议处理器
    	//自定义的handler ,处理业务逻辑
    	pipeline.addLast(new MyTextWebSocketFrameHandler());

WebSocketServerProtocolHandler的handlerAdded

初始化添加的时候,会调用handlerAdded进行处理器的添加,分别添加握手处理器WebSocketServerProtocolHandshakeHandlerUTF8文本帧验证器Utf8FrameValidator,关闭帧处理器WebSocketCloseFrameHandler

     @Override
        public void handlerAdded(ChannelHandlerContext ctx) {
            ChannelPipeline cp = ctx.pipeline();
            if (cp.get(WebSocketServerProtocolHandshakeHandler.class) == null) {
                // Add the WebSocketHandshakeHandler before this one.在前面添加一个握手处理器
                cp.addBefore(ctx.name(), WebSocketServerProtocolHandshakeHandler.class.getName(),
                        new WebSocketServerProtocolHandshakeHandler(serverConfig));
            }
            if (serverConfig.decoderConfig().withUTF8Validator() && cp.get(Utf8FrameValidator.class) == null) {
                // Add the UFT8 checking before this one.在前面添加帧验证器
                cp.addBefore(ctx.name(), Utf8FrameValidator.class.getName(),
                        new Utf8FrameValidator());
            }
            if (serverConfig.sendCloseFrame() != null) {//添加关闭帧处理器
                cp.addBefore(ctx.name(), WebSocketCloseFrameHandler.class.getName(),
                    new WebSocketCloseFrameHandler(serverConfig.sendCloseFrame(), serverConfig.forceCloseTimeoutMillis()));
            }
        }

202309132208172392.png

WebSocketServerProtocolHandshakeHandler的channelRead

将WebSocketServerProtocolHandshakeHandler替换forbiddenHttpRequestResponder

202309132208179323.png

删除HttpObjectAggregator和HttpContentCompressor(如果存在的话)

202309132208189774.png

替换HTTP相关解码器并添加WebSocket编码器

202309132208197265.png

握手响应发送成功后

发送完后会删除HTTP响应编码器。

202309132208205516.png

WebSocket通信

之后就开始WebSocket协议通信了,跟TCP一样只要传协议内容就行,没有太多的附加数据,具体后面会说这个协议格式。可以看到发送文本数据的编码是UTF-8的,中文占3个字节。

202309132208212077.png
看下握手请求:

202309132208219208.png
响应:

202309132208226789.png
其实就是握手的时候用HTTP,然后就转到WebSocket了,所以为什么会看到会有替换和删除处理器了。下次我们再继续分析具体的源码,这次先有个大概了解吧。

具体协议的了解还是参考这些吧:
https://www.cnblogs.com/songwenjie/p/8575579.html
https://blog.csdn.net/p312011150/article/details/79758068

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。

阅读全文