具有异步调用方的Netty同步客户端

Question

我正在创建一个服务器，该服务器使用来自许多来源的命令，例如JMS，SNMP，HTTP等。这些都是异步的，并且工作正常。服务器维护与单个传统硬件项目的单个连接，该项目具有具有自定义TCP协议的请求/应答体系结构。理想情况下，我想要一个像这样的阻塞类型方法的命令

public Response issueCommandToLegacyHardware(Command command)

或者这个异步类型的方法

public Future<Response> issueCommandToLegacyHardware(Command command)

我对Netty和异步编程比较陌生，基本上是边学边学。我目前的想法是，我的LegacyHardwareClient类将具有公共同步问题CommandToLegacy硬件（命令命令）

这太复杂了吗？我可以看看关于同步Netty客户端实现的例子吗？Netty有什么最佳实践吗？显然，我可以只使用标准的Java套接字，但是Netty解析自定义协议的能力以及易维护性太强了，无法放弃。

更新：只是关于实现，我使用了数组块队列

offer（）和remove（）对我不起作用的原因是，如果对方没有主动阻塞take（）请求，offer（”命令将不会传递任何内容。相反，remove（）不会返回任何内容，除非存在插入数据的阻塞put（）调用。我无法使用put（）/remove（），因为无法访问remove。由于尚未执行take（）调用，所以offer（）语句将返回false，因此我无法使用offer（（）/take（）。使用ArrayBlockingQueue

Answer 1

而不是使用SynchronousQueue以阻塞方式设计您的应用程序

您的公共未来

这一点的快速实现可能是：

public class MyLastHandler extends SimpleInboundHandler<Response> {
    private final SynchronousQueue<Promise<Response>> queue;

    public MyLastHandler (SynchronousQueue<Promise<Response>> queue) {
        super();
        this.queue = queue;
    }

    // The following is called messageReceived(ChannelHandlerContext, Response) in 5.0.
    @Override
    public void channelRead0(ChannelHandlerContext ctx, Response msg) {
        this.queue.remove().setSuccss(msg); // Or setFailure(Throwable)
    }
}

上述处理程序应该放在链的最后。

公共未来的实施

Channel channel = ....;
SynchronousQueue<Promise<Response>> queue = ....;

public Future<Response> issueCommandToLegacyHardware(Command command) {
    return issueCommandToLegacyHardware(command, channel.eventLoop().newPromise());
}

public Future<Response> issueCommandToLegacyHardware(Command command, Promise<Response> promise) {
    queue.offer(promise);
    channel.write(command);
    return promise;
}

使用重载的方法也是用于Channel.write的设计模式，这使得它非常灵活。

此设计模式可在客户端代码中使用如下：

issueCommandToLegacyHardware(
    Command.TAKE_OVER_THE_WORLD_WITH_FIRE, 
    channel.eventLoop().newPromise()
).addListener(
    (Future<Response> f) -> {
        System.out.println("We have taken over the world: " + f.get());
    }
);

这种设计模式的优点是，任何地方都不会使用不必要的阻塞，只使用简单的异步逻辑。

附录一:Javadoc:

promise未来违约promise