如何从正常流之外访问Netty处理程序方法

Question

我正在尝试将Netty（版本3.6.1.final）集成到我们当前的系统中，这样我就可以替换当前的NIO代码。

在我的Netty business logic处理程序的messageReceed（）方法中，我将向总线添加一个输入请求。我将传递的一件事是Netty事件消息中的数据。

我认为应该在这个InputEvent中传递ChannelHandlerContext以及接收的数据/消息。以便最终在处理OutputEvent时，它可以使用最初传递的ChannelHandlerContext将处理后的数据通过正确的Netty通道发送回请求客户端。

那么，正在处理OutputEvent的输出任务如何绑定回Netty呢？

public void messageReceived(
        ChannelHandlerContext ctx, MessageEvent e) {

    byte[] message = (byte[])e.getMessage();

    try {
            data.add(message);
        }
    catch( IOException ioe )
        {
            logger.error(ioe);
        }

    InputEvent ie = new InputEvent( ctx, this, data.getBuffer() );

    try {
              bus.enqueue(ie);
    }
    catch( Exception ex )
   {
      logger.error(ex);
   }

public void run() {


    // note that the OutputEvent (event) is available here.  This is not a Netty event.
    ChannelHandlerContext ctx = event.getHandlerContext();
    ClientChannel handler = event.getHandler();

    // I need to send the data in event.getBuffer() back.

// Now what do I do here???


…
…
…

}

谢谢你。

Answer 1

你只要打电话：

InputEvent event = ...
ChannelHandlerContext ctx = ....
ctx.write(event.getBuffer());

或：

InputEvent event = ...
Channel channel = ....
channel.write(event.getBuffer());