如何使用netty客户端编写消息？

Question

我试图使用Netty构建一个简单的TCP客户端-服务器应用程序。开始时，我通过SocketChannel从客户端发送消息，方式如下:

    SocketChannel client = SocketChannel.open(hostAddress);
    client.write(buffer);

所有的消息都被服务器收到了，但是当我想把响应写回客户端时，我发现为了得到客户端的响应，它需要通过引导程序发送消息，并定义将读取响应的Inoundhandler（也许有人知道另一种方法？）当我试图通过引导程序发送消息时，我使用以下代码：

    EventLoopGroup group = new NioEventLoopGroup();
    Bootstrap b = new Bootstrap();
    b.group(group).channel(NioSocketChannel.class);
    b.handler(new ChannelInitializer<SocketChannel>() {

        @Override
        protected void initChannel(SocketChannel ch) throws Exception {
            // TODO Auto-generated method stub
            ch.pipeline().addLast(new TestClientHandler());
        }

      });
    ChannelFuture future = bootstrap.connect(hostAddress);
    future.channel().writeAndFlush(buffer);

但是通过这种方式，服务器根本没有收到消息！这是我用于服务器的代码（当我不通过客户端的引导程序发送消息时，它工作正常）：

    bootstrap = new ServerBootstrap();
    bootstrap.group(boosGroup, workerGroup);
    bootstrap.channel(NioServerSocketChannel.class);
    bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel ch) throws Exception {
              ChannelPipeline pipeline = ch.pipeline();
              pipeline.addLast(dnsMessageDecodingHandler); 
              pipeline.addLast(group,"DnsTcpHandler",dnsTcpHandler); 
            }
          });
     future = bootstrap.bind(hostAddress).await();

在Netty中编写一个简单的客户端-服务器的正确方法是什么？我没有找到任何可以做到这一点的工作示例……

谢谢，奥斯纳特。

Answer 1

在我检查了从writeAndFlush返回的ChannelFuture的原因(就像Norman Maurer建议我做的那样)后，我看到原因是:不支持的消息类型:HeapByteBuffer(预期:ByteBuf，FileRegion)这是因为我没有向客户端管道添加ObjectEncoder！！这个添加解决了这个问题:b . handler(new ChannelInitializer(){

        @Override
        protected void initChannel(SocketChannel ch) throws Exception {
            // TODO Auto-generated method stub
            ch.pipeline().addLast(new ObjectEncoder());
            ch.pipeline().addLast(new TestClientHandler());
        }

      });

感谢所有帮助过我的人！奥斯纳特。

Answer 2

netty存储库中有多个示例，我不确定为什么你说没有。

https://github.com/netty/netty/tree/4.1/example

也就是说，我怀疑问题在于您没有“等待”到< code >连接(...)操作完成。如果您想检查由< code>writeAndFlush(...)它早就告诉你这些了。

S因此，快速修复方法是：

ChannelFuture future = bootstrap.connect(hostAddress).await();
future.channel().writeAndFlush(buffer);

Answer 3

你应该知道TCP连接是如何工作的

本文描述了典型的TCP流。https://www.ibm.com/support/knowledgecenter/en/SSB23S_1.1.0.14/gtps7/s5tcpcf.html

阅读本文后，您需要正确编写服务器代码

// create your server bootstrap
ServerBootstrap b = new ServerBootstrap();

// add your ChannelInitializer which handles when client has been connected to your server
// in ChannelInitializer you need to register your ChannelHandler, such as ChannelDuplexHandler to client channel pipeline
b.childHandler(YOUR_CHANNEL_INITIALIZER); 

b.bind(bindAddress); // your server will now listen() for client connect()

运行引导代码后，客户端可以连接到服务器