-肆行无忌网

发布时间：2025-06-24 18:24:46 作者：北方职教升学中心阅读量：650

总结

1、检查本地仓库

Maven版本3.6.3，在Maven文件夹下创建了res文件夹，做为Java工程的Maven本地仓库地址，此文件通常都在500MB以上，随着本地项目数而递增。改造服务端代码

在这里插入图片描述
查看数据结果

4、客户端结果
3.6、项目结构配置

打开【Project Structure】
在这里插入图片描述

1.3.1、构造NettyWebsocketServer

2.1、配置JDK
1.4、

添加依赖

2、项目结构配置

1.3.1、Debug调试数据
3.5、项目创建
成功创建项目，Sringboot版本 2.7.6，Java版本8。
1.3、配置JDK
修改SDK、
1.1、Language level等配置。客户端发送数据
3.4、检查settings.xml

1.2.2、

我们在Debug数据时，可以看到msg的data类型
TextWebSocketFrame(data: PooledUnsafeDirectByteBuf(ridx: 0, widx: 61, cap: 61))

在这里插入图片描述

3.5、创建一个 Netty 服务器配置类

importio.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;importorg.springframework.context.annotation.Configuration;importio.netty.channel.socket.nio.NioServerSocketChannel;importio.netty.handler.codec.http.HttpObjectAggregator;importio.netty.handler.codec.http.HttpServerCodec;importio.netty.handler.stream.ChunkedWriteHandler;importio.netty.handler.timeout.IdleStateHandler;importio.netty.channel.nio.NioEventLoopGroup;importio.netty.channel.socket.SocketChannel;importio.netty.bootstrap.ServerBootstrap;importjavax.annotation.PostConstruct;importlombok.extern.slf4j.Slf4j;importio.netty.channel.*;@Slf4j@ConfigurationpublicclassNettyWebsocketServer{//bossGroup 连接线程组，主要负责接受客户端连接EventLoopGroupbossGroup =newNioEventLoopGroup(1);privateEventLoopGroupworkerGroup =newNioEventLoopGroup();privateChannelFuturechannelFuture;@PostConstructpublicvoidstart()throwsInterruptedException{try{ServerBootstrapb =newServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,128).childOption(ChannelOption.SO_KEEPALIVE,true).childHandler(newChannelInitializer<SocketChannel>(){@OverrideprotectedvoidinitChannel(SocketChannelsocketChannel)throwsException{ChannelPipelinepipeline =socketChannel.pipeline();// 因为使用 HTTP 协议，所以需要 HTTP编码器，解码器pipeline.addLast(newHttpServerCodec());// 以块方式，添加 chunkedWriter 处理器pipeline.addLast(newChunkedWriteHandler());/**                             * 1. http数据在传输中是分段的，HttpObjectAggregator 可以把多个段聚合起来                             * 2. 这就是为什么当浏览器发送大量数据时，就会发出多次 http请求的原因                             */pipeline.addLast(newHttpObjectAggregator(8192));// 保存用户ip// pipeline.addLast(new HttpHeadersHandler());pipeline.addLast(newWebSocketServerProtocolHandler("/chat"));pipeline.addLast(newIdleStateHandler(60,5,0));pipeline.addLast(newChatHandler());//添加自定义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、环境配置

- 1.2.1、
  目录
  1、改造服务端代码
- 4、
  在 pom.xml 文件中添加 Netty 和 Spring Boot 相关的依赖：
```
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.68.Final</version></dependency></dependencies>
```
  2、使用ApiFox调试
- - 3.1、
    1.2、添加Apifox WebSocket接口
    
    输入ws接口地址，成功连接上netty服务
    3.3、添加自定义handler
    创建一个自定义的 ChannelHandler 来处理客户端的请求：
```
importio.netty.channel.ChannelHandlerContext;importio.netty.channel.ChannelInboundHandlerAdapter;publicclassChatHandlerextendsChannelInboundHandlerAdapter{@OverridepublicvoidchannelRead(ChannelHandlerContextctx,Objectmsg)throwsException{// 处理收到的消息System.out.println("Received message: "+msg);ctx.writeAndFlush("Message received: "+msg);}@OverridepublicvoidexceptionCaught(ChannelHandlerContextctx,Throwablecause)throwsException{cause.printStackTrace();ctx.close();}}
```
    3、
    
    1.4、创建Springboot工程
    在Idea里创建Springboot工程，Language选择Java，Type选择Maven，Project SDK 选择Java8。客户端发送数据
  - 3.4、创建Springboot工程
  - - 1.1、
      下一章节，我们讲解解码器的使用，使得我们的数据可以可视化，以及正常的展示。环境配置
      检查Maven配置，主要检查settings.xml和本地Maven仓库
      1.2.1、使用ApiFox调试
      3.1、添加自定义handler
  - 3、检查本地仓库
- 1.3、添加依赖
  上述操作都是打基础，搭架子和配置环境，下一步我们需要加载netty 的相关依赖包。启动服务
  3.2、项目创建
- 1.2、客户端结果
  客户端收不到服务端回复的消息。启动服务
- 3.2、构造NettyWebsocketServer
- - 2.1、检查settings.xml
    在settings.xml里配置上阿里云镜像
```
<mirrors><mirror><id>alimaven</id><mirrorOf>central</mirrorOf><name>aliyun maven</name><url>http://maven.aliyun.com/nexus/content/repositories/central/</url></mirror></mirrors>
```
    1.2.2、创建一个 Netty 服务器配置类
  - 2.2、添加Apifox WebSocket接口
  - 3.3、总结
    在文章里，我们实现了Springboot 集成netty，并使用apiFox客户端发送了消息到netty服务，最终客户端收到服务端的应答。Debug调试数据
    这里可以看到已经接收到数据了。
    3.6、