Netty TCP客户端异步消息

Question

我正在构建一个tcp客户端来接收和发送消息。我按照Netty用户指南中的步骤编写了一个简单的tcp客户端，其中包含一个扩展ChannelInboundHandlerAdapter的自定义处理程序。

在hander中，我存储了< code > ChannelHandlerContext :

 @Override
 public void channelActive (ChannelHandlerContext ctx) throws Exception {
   super.channelActive (ctx);
   this.ctx = ctx;
 }

然后我有一个发送方法，它使用ChannelHandlerContext发送消息：

 public void sendMessage (String msg) {
  if (ctx == null) {
    return;
  }
  ChannelFuture cf = ctx.write (Unpooled.copiedBuffer (msg, CharsetUtil.UTF_8));
  ctx.flush ();
}

我发现的另一个选项是在客户机类中使用Channel对象

 channel.writeAndFlush (msg);

我需要从另一个线程调用send方法。最好的方法是什么？

先谢谢你。




Answer 1

匿名用户

< code > ChannelHandlerContext 和< code>Channel都是线程安全的，因此您可以从任何线程编写，而不必担心。

如果使用< code>Channel.write()，消息将必须通过整个管道。但是如果您使用< code > channelhandlercontext . write()，它将只需要通过管道中的上游处理程序。因此，写入< code > ChannelHandlerContext 会更有效。

还要注意，大多数时候最好使用writeAndFlush（）而不是write（）。

请查看此演示以了解更多详细信息。