目录1、创建Springboot工程1.1、项目创建1.2、环境配置1.2.1、检查settings.xml1.2.2、检查本地仓库1.3、项目结构配置1.3.1、配置JDK1.4、添加依赖2、构造NettyWebsocketServer2.1、创建一个 Netty 服务器配置类2.2、添加自定义handler3、使用ApiFox调试3.1、启动服务3.2、添加Apifox WebSocket接口3.3、客户端发送数据3.4、Debug调试数据3.5、客户端结果3.6、改造服务端代码4、总结1、创建Springboot工程在Idea里创建Springboot工程Language选择JavaType选择MavenProject SDK 选择Java8。1.1、项目创建成功创建项目Sringboot版本 2.7.6Java版本8。1.2、环境配置检查Maven配置主要检查settings.xml和本地Maven仓库1.2.1、检查settings.xml在settings.xml里配置上阿里云镜像mirrors mirror idalimaven/id mirrorOfcentral/mirrorOf namealiyun maven/name urlhttp://maven.aliyun.com/nexus/content/repositories/central//url /mirror /mirrors1.2.2、检查本地仓库Maven版本3.6.3在Maven文件夹下创建了res文件夹做为Java工程的Maven本地仓库地址此文件通常都在500MB以上随着本地项目数而递增。1.3、项目结构配置打开【Project Structure】1.3.1、配置JDK修改SDK、Language level等配置。1.4、添加依赖上述操作都是打基础搭架子和配置环境下一步我们需要加载netty 的相关依赖包。在 pom.xml 文件中添加 Netty 和 Spring Boot 相关的依赖dependencies dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter/artifactId /dependency dependency groupIdio.netty/groupId artifactIdnetty-all/artifactId version4.1.68.Final/version !-- 请根据需要选择合适的版本 -- /dependency /dependencies2、构造NettyWebsocketServer2.1、创建一个 Netty 服务器配置类import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler; import org.springframework.context.annotation.Configuration; import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.codec.http.HttpObjectAggregator; import io.netty.handler.codec.http.HttpServerCodec; import io.netty.handler.stream.ChunkedWriteHandler; import io.netty.handler.timeout.IdleStateHandler; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.bootstrap.ServerBootstrap; import javax.annotation.PostConstruct; import lombok.extern.slf4j.Slf4j; import io.netty.channel.*; Slf4j Configuration public class NettyWebsocketServer { //bossGroup 连接线程组主要负责接受客户端连接 EventLoopGroup bossGroup new NioEventLoopGroup(1); private EventLoopGroup workerGroup new NioEventLoopGroup(); private ChannelFuture channelFuture; PostConstruct public void start() throws InterruptedException { try { ServerBootstrap b new ServerBootstrap(); b.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 128) .childOption(ChannelOption.SO_KEEPALIVE, true) .childHandler(new ChannelInitializerSocketChannel() { Override protected void initChannel(SocketChannel socketChannel) throws Exception { ChannelPipeline pipeline socketChannel.pipeline(); // 因为使用 HTTP 协议所以需要 HTTP编码器解码器 pipeline.addLast(new HttpServerCodec()); // 以块方式添加 chunkedWriter 处理器 pipeline.addLast(new ChunkedWriteHandler()); /** * 1. http数据在传输中是分段的HttpObjectAggregator 可以把多个段聚合起来 * 2. 这就是为什么当浏览器发送大量数据时就会发出多次 http请求的原因 */ pipeline.addLast(new HttpObjectAggregator(8192)); // 保存用户ip // pipeline.addLast(new HttpHeadersHandler()); pipeline.addLast(new WebSocketServerProtocolHandler(/chat)); pipeline.addLast(new IdleStateHandler(60, 5, 0)); pipeline.addLast(new ChatHandler()); //添加自定义handler } }); // Bind and start to accept incoming connections. channelFuture b.bind(9091).sync(); if(channelFuture.isSuccess()) { log.info(netty启动成功); } // 对通道关闭进行监听 channelFuture.channel().closeFuture().sync(); } finally { if (channelFuture ! null channelFuture.isSuccess()) { System.out.println(Netty server started on port 9091); } else { System.err.println(Netty server failed to start); } } } }2.2、添加自定义handler创建一个自定义的 ChannelHandler 来处理客户端的请求import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; public class ChatHandler extends ChannelInboundHandlerAdapter { Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { // 处理收到的消息 System.out.println(Received message: msg); ctx.writeAndFlush(Message received: msg); } Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { cause.printStackTrace(); ctx.close(); } }3、使用ApiFox调试3.1、启动服务3.2、添加Apifox WebSocket接口输入ws接口地址成功连接上netty服务3.3、客户端发送数据3.4、Debug调试数据这里可以看到已经接收到数据了。我们在Debug数据时可以看到msg的data类型TextWebSocketFrame(data: PooledUnsafeDirectByteBuf(ridx: 0, widx: 61, cap: 61))3.5、客户端结果客户端收不到服务端回复的消息。3.6、改造服务端代码查看数据结果4、总结在文章里我们实现了Springboot 集成netty并使用apiFox客户端发送了消息到netty服务最终客户端收到服务端的应答。下一章节我们讲解解码器的使用使得我们的数据可以可视化以及正常的展示。