在java中实现同步网络调用等待ack消息？

Question

您将如何在 Java 中实现相当于等待完成的方法调用？

基本上我想做的是使用一种方法，通过网络向服务器应用程序发送消息，并等待它从服务器获取适当的 Ack 消息，其中包含操作成功完成或操作失败和错误消息。

我的方法已经有一个非阻塞版本，它传递一个回调类，其中有一个在回调时调用的方法。

构造一个回调类将其传递给我之前的方法然后执行等待操作并在回调上让该类执行通知是否有意义？

Answer 1

将 .wait() 添加到回调类将是最简单的路径。 它可以在某个标志上旋转，直到您的回调切换它为止，只需确保在循环中包含 Thread.yield() 或 .sleep() 即可。

无需重写替代的阻塞通信通道。

Answer 2

简短回答：是的。 我已经热衷于使用类库中的内容，您所描述的听起来很像观察者模式，假设您正在使用 J2SE，您已经拥有观察者/可观察接口。

编辑：我的咖啡出了点问题:)显然，我的意思是检查 java.util.concurrent 包中的内容，特别是 Future<> 。 和 ExecutorService 类。

Answer 3

是的，按照您的建议使用现有的方法。 在同步方法调用中创建回调，该回调将通过 wait()/notify() 与同步方法调用协调。 同步方法将调用异步方法，然后调用 wait()。 当回调被调用时，它会调用notify()来唤醒sync方法，以便它可以返回结果。

Answer 4

如果您不使用 JMS，请忽略。

如果您使用 JMS，那么您可以使用 QueueRequestor，它是请求回复集成模式的实现。

也就是说，即使使用异步消息，以下调用对于客户端来说也是同步的：

QueueRequestor requestor = null;
try {
    requestor = new QueueRequestor(session, queue); 
    Message response = requestor.send(request);
} finally {
    if (requestor == null) {
        try {
            requestor.close();
        } catch (JMSException e) {
            // log error message
        }
     }
}