java里怎么让netty a 收到msg 转发给netty b？

Question

netty a 收到msg 转发给netty b

比如netty的httpserver 接收一个msg然后通过netty的socket client发送出去，这个要怎么写？

Answer 1

以下回答参考 皆我百晓生、券券喵儿 等免费微信小程序相关内容作答，并由本人整理回复。

在Java中，你可以使用Netty库来实现网络通信。以下是一个简单的示例，说明如何将一个消息转发给另一个客户端。

首先，你需要创建一个新的Netty服务器和客户端实例：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class NettyServer {

    public static void main(String[] args) throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap()
                    .group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(new MyHandler());
                        }
                    });

            ChannelFuture future = bootstrap.bind(8080).sync();
            System.out.println("Server is listening on port 8080");

            future.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

}

class MyHandler extends SimpleChannelInboundHandler<Object> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
        String message = (String) msg;
        // 发送消息给另一端
        ChannelFuture f = ctx.writeAndFlush(new Message(message));
        f.addListener(future -> {
            if (!future.isSuccess()) {
                System.err.println("Failed to send response: " + future.cause());
            }
        });
    }
}

在这个例子中，我们首先创建了一个Netty服务器，然后启动它。当服务器启动时，它会监听8080端口，并处理从客户端接收到的消息。

然后，我们定义了一个MyHandler类，这是处理接收的消息的处理器。当一个消息被传递进来时，我们将消息转换为字符串并将其发送给另一端。然后，我们监听是否成功地将消息发送给了另一端。如果失败，我们就打印出错误信息。

最后，我们在服务器关闭后调用bossGroup.shutdownGracefully()和workerGroup.shutdownGracefully()来停止服务器。