SpringBoot优雅整合Netty实现WebSocket通信（初学者友好）

├── WebSocketNettyApplication.java
├── config/
│   └── NettyConfig.java
├── netty/
│   ├── WebSocketServer.java
│   ├── WebSocketChannelInitializer.java
│   └── WebSocketHandler.java

<dependencies>
    <!-- Spring Boot 核心依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>

    <!-- Netty 核心 -->
    <dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.1.86.Final</version>
    </dependency>
</dependencies>

@Configuration
public class NettyConfig {
    @Value("${netty.port}")
    private int port;

    @Bean
    public WebSocketServer webSocketServer() {
        return new WebSocketServer(port);
    }

    @EventListener(ApplicationReadyEvent.class)
    public void start() {
        webSocketServer().start();
    }
}

netty:
  port: 8081

public class WebSocketServer {
    private final int port;

    public WebSocketServer(int port) {
        this.port = port;
    }

    public void start() {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                     .channel(NioServerSocketChannel.class)
                     .childHandler(new WebSocketChannelInitializer());

            Channel ch = bootstrap.bind(port).sync().channel();
            System.out.println("WebSocket Server started at port " + port);
            ch.closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

public class WebSocketChannelInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new HttpServerCodec());
        pipeline.addLast(new HttpObjectAggregator(65536));
        pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
        pipeline.addLast(new WebSocketHandler());
    }
}

public class WebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) {
        System.out.println("接收到客户端消息：" + msg.text());
        ctx.channel().writeAndFlush(new TextWebSocketFrame("服务端响应：" + msg.text()));
    }

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) {
        System.out.println("客户端连接：" + ctx.channel().id().asLongText());
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) {
        System.out.println("客户端断开连接：" + ctx.channel().id().asLongText());
    }
}

<view>接收的消息</view>
<textarea style="border: 1px solid black;" value="{{msg}}"></textarea>
<view>发送的消息</view>
<textarea style="border: 1px solid black;" bindinput='inputTitle'></textarea>
<button style="border: 1px solid violet;" bindtap='send'>发送消息</button>
<button style="border: 1px solid red;" bindtap='openWebSocket'>打开WebSocket连接</button>
<button style="border: 1px solid red;" bindtap='closeWebSocket'>关闭WebSocket连接</button>

Page({
  /**
   * 页面的初始数据
   */
  data: {
  },
  /**
   * 生命周期函数--监听页面加载
   */
  onLoad: function (options) {
  },
  /**
   * 绑定参数
   */
  inputTitle: function(e){
    var _this = this;
    _this.setData({ title: e.detail.value })
  },
  /**
   * 发送信息
   */
  send: function(){
    var _this = this;
    wx.sendSocketMessage({ 
      data: _this.data.title ,
      success: (result) => {
        console.log(result)
      },
      fail: (result) => {
        console.log(result)
        wx.showToast({
          title: result.errMsg,
          icon:"none",
          duration:5000
        })
      },    
    })
  },
  /**
   * 打开连接
   */
  openWebSocket: function(){
    //创建一个 WebSocket 连接
    wx.connectSocket({
      url: 'ws://10.8.51.124:8000/ws',
      success: (result) => {
        console.log(result)
      },
    })
    //监听 WebSocket 连接打开事件
    wx.onSocketOpen(function (result) {
      console.log(result)
    })
    //监听 WebSocket 错误事件
    wx.onSocketError(function (result) {
      console.log(result)
      wx.showToast({
        title: result.errMsg,
      })
    })
    //监听 WebSocket 接受到服务器的消息事件
    wx.onSocketMessage((result) => {
      console.log(result)
      this.setData({
        msg: result.data
      })
    })
    //监听 WebSocket 关闭事件
    wx.onSocketClose((result) => {
      console.log(result)
    })
  },
  /**
   * 关闭连接
   */
  closeWebSocket: function(){
    wx.closeSocket({
      success: (result) => {
        console.log(result)
      },
    })
  }
})