WebSocket

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

如何使用WebSocket

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

服务端代码

一般代码：

     	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进行处理器的添加，分别添加握手处理器WebSocketServerProtocolHandshakeHandler，UTF8文本帧验证器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()));
            }
        }

WebSocketServerProtocolHandshakeHandler的channelRead

将WebSocketServerProtocolHandshakeHandler替换forbiddenHttpRequestResponder

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

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

握手响应发送成功后

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

WebSocket通信

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

看下握手请求：

响应：

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

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

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

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】即可免费领取。

阅读全文

吃透 Netty 源码

吃透Netty源码系列四十六之WebSocket预备知识