springboot netty实现tcp客户端

Spring Boot结合Netty可以轻松地创建高性能的TCP客户端，这是一种基于事件驱动、异步I/O模型的网络通信框架。以下是使用Spring Boot和Netty构建TCP客户端的基本步骤：

1. 添加依赖：首先，在你的`pom.xml`文件中添加Netty的依赖：

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.x.y</version> <!-- 更新到最新的稳定版本 -->
</dependency>

2. 创建配置：在Spring Boot项目中，你可以创建一个配置类来设置Netty的一些参数，如连接超时、心跳检测等：

@Configuration
public class NettyClientConfig {
    private static final int DEFAULT_PORT = 8080;
    private String host = "localhost";

    @Value("${server.port}")
    public void setPort(int port) {
        this.host = "localhost:" + port;
    }

    public String getHost() {
        return host;
    }

    // 可以在这里添加更多的配置项
}

3. 实现客户端服务：创建一个自定义的TCP客户端组件，继承`ChannelInitializer`，负责初始化`ChannelPipeline`并处理连接：

@Component
public class NettyTcpClientHandler extends ChannelInitializer<SocketChannel> {
    private final Logger logger = LoggerFactory.getLogger(NettyTcpClientHandler.class);

    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        // 初始化管道，包括编码解码器和其他处理器
        ch.pipeline().addLast(new ObjectDecoder(StandardCharsets.UTF_8));
        ch.pipeline().addLast(new ObjectEncoder());
        ch.pipeline().addLast(new SimpleServerHandler());
    }
}

// 简单服务器处理器示例
class SimpleServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 接收数据并处理
        System.out.println("Received message: " + msg);
        // 发送响应...
    }
}

4. 调用客户端：在需要发送请求的地方，通过Spring的Bean注入创建客户端实例，并发起连接：

@Autowired
private NettyTcpClientHandler clientHandler;

public void sendMessage(String request) {
    try (ChannelFuture future = clientHandler.connectToHost(host)) {
        if (!future.channel().isActive()) {
            throw new RuntimeException("Failed to connect");
        }
        
        // 编码请求并发送
        ByteBuf byteBuf = Unpooled.copiedBuffer(request.getBytes(StandardCharsets.UTF_8));
        future.channel().writeAndFlush(byteBuf);
        // 关闭ByteBuf释放资源
        byteBuf.release();
    } catch (IOException e) {
        log.error("Error sending message", e);
    }
}