netty实现websocket带参数

### 使用Netty实现带参数的WebSocket 为了使用Netty实现在Java中带有参数的WebSocket连接，可以遵循以下方法： #### 创建自定义握手处理器 创建一个继承`HandshakeHandler`类并重写其方法来处理握手过程中的查询参数。这允许服务器端读取客户端发起请求时附带的URL参数。 ```java public class CustomQueryParameterHandshaker extends WebSocketServerProtocolHandler { @Override protected void encodeInitialLine(ChannelHandlerContext ctx, HttpRequest req) throws Exception { // 解析 URL 参数 QueryStringDecoder decoder = new QueryStringDecoder(req.uri()); Map<String, List<String>> params = decoder.parameters(); super.encodeInitialLine(ctx, req); } } ``` 此部分代码展示了如何解析传入HTTP GET 请求里的查询字符串，并将其转换成易于访问的形式[^1]。 #### 配置通道初始化器 配置ChannelInitializer以添加必要的处理器到管道中，包括前面提到的手动编写的握手处理器以及用于消息编码解码的标准处理器。 ```java public class WebSocketChatServerInitializer extends ChannelInitializer<SocketChannel> { private final SslContext sslCtx; public WebSocketChatServerInitializer(SslContext sslCtx) { this.sslCtx = sslCtx; } @Override public void initChannel(SocketChannel ch) throws Exception { ChannelPipeline pipeline = ch.pipeline(); if (sslCtx != null) { pipeline.addLast(sslCtx.newHandler(ch.alloc())); } pipeline.addLast(new HttpServerCodec()); pipeline.addLast(new ChunkedWriteHandler()); // 添加自定义握手处理器 pipeline.addLast(new CustomQueryParameterHandshaker("/ws")); // ...其他处理器... } } ``` 这段代码片段说明了如何设置Netty服务端程序，在其中加入了之前定义好的自定义握手逻辑[^2]。 #### 启动WebSocket服务器 最后一步是启动实际的服务实例监听指定端口上的新连接尝试。 ```java EventLoopGroup bossGroup = new NioEventLoopGroup(); // Boss线程组负责接收新的TCP连接. EventLoopGroup workerGroup = new NioEventLoopGroup(); // Worker线程组负责处理已建立连接的数据传输. try { ServerBootstrap b = new ServerBootstrap() .group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new WebSocketChatServerInitializer(null)); ChannelFuture f = b.bind(8080).sync(); // 绑定到本地地址和给定端口号上等待就绪状态完成同步阻塞操作直到绑定成功为止。 System.out.println("WebSocket server started at port 8080."); f.channel().closeFuture().sync(); // 关闭通知事件发生前一直保持主线程存活。 } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); } ``` 通过这种方式，可以在基于Netty框架构建的应用程序里轻松支持携带额外参数的WebSocket协议通信[^3]。