14

我有一个与架构相关的问题。这是一个与语言无关的问题，但由于我来自 Java 背景，如果有人以 Java 方式指导我，对我来说会更容易。

基本上，我正在编写的中间件与基于 SOAP 的第三方服务进行通信。调用是异步的 - 以某种方式，当调用服务时，它会返回响应 01 - 处理；表示第三方已成功收到请求。在原始SOAP请求中，每次都必须提交一个回调URL，由第三方实际发送结果。因此，调用特定服务实际上并不会立即返回结果。结果在中间件中的一个单独的 HTTP 端点中接收。

现在在我们的前端，我们不想让用户体验复杂化。我们希望我们的用户调用一个中间件函数（通过菜单项/按钮），并立即得到结果；并将肮脏的工作留给中间件。

请注意，从前端调用的中间件函数（比如说 X()）和第三方推送结果的中间件端点 URL（我们称之为 Y）是完全分开的。X() 必须等待然后获取在 Y 中抓取的结果，然后将结果返回到前端。

在此处输入图像描述

如何构建一个强大的解决方案来实现上述行为？图片完美地描绘了我的情况。任何建议将不胜感激。

4

2 回答 2

12

这个问题可能更多是关于集成模式，而不是关于多线程。但是可以使用异步调用和观察者模式的组合来编排同一应用程序/JVM 中的请求：

最好使用示例（利用您的 Java 知识）来完成此操作。检查以下尝试复制您的场景的简单组件：

第三方服务：它暴露了一个返回关联ID并开始长时间运行的操作

class ExternalService {
    public String send() {
        return UUID.randomUUID().toString();
    }
}

您的面向客户端的服务：它接收请求，调用第三方服务，然后在向结果接收器注册后等待响应：

class RequestProcessor {
    public Object submitRequest() {
        String correlationId = new ExternalService().send();

        return new ResultReceiver().register(correlationId).join();
    }
}

结果接收者：它向第三方服务公开一个操作，并维护一个内部相关注册表：

class ResultReceiver {

    Map<String, CompletableFuture<Object>> subscribers;

    CompletableFuture<Object> register(String responseId) {
        CompletableFuture<Object> future = new CompletableFuture<Object>();
        this.subscribers.put(responseId, future);

        return future;
    }

    public void externalResponse(String responseId, Object result) {
        this.subscribers.get(responseId).complete(result);
    }
}

在这种情况下，期货、承诺、回调很方便。同步由初始请求处理器完成，以强制执行阻塞客户端。

现在，这可能会引发一些在这个简单的类集中没有解决的问题。其中一些问题可能是：

  • new ExternalService().send()和之间的竞争条件new ResultReceiver().register(correlationId)。ResultReceiver如果不知道某些响应可能非常快（可以说是2路等待），这是可以解决的

  • 永远不会出现的结果：结果可能需要很长时间或只是遇到错误。这些未来的 API 通常会提供超时来强制取消请求。例如：

    new ResultReceiver().register(correlationId)
    .get(10000, TimeUnit.SECONDS);
于 2018-05-08T08:11:03.117 回答
2

那么这样做到底有什么问题呢？您只需创建一个 API（中间件），它在第三方返回处理后的结果之前不会返回响应。前端向 X() 发送请求，X() 通过向 Y() 发送请求来处理该请求，然后继续轮询 Y() 以查看结果何时准备就绪，然后 X() 从 Y() 中获取结果并将其发送回前端。就像一个门面。

使用第三方服务存在一些您无法控制的问题，您应该考虑这些问题。首先，您需要实现某种断路器或超时。因为第三方服务可能会挂起并且永远不会处理结果（或处理它们的时间太长以至于等待毫无意义）。此外，即使第三方服务不可用或已更新其 API 或其他阻止您使用它的东西，您也应该考虑一些有意义的方式来保持站点运行。

最后只有一个想法。为什么要使已经实现异步同步的东西？这样做可能是因为它可能需要时间。长时间阻塞前端等待结果，让用户体验不愉快，UI 反应迟钝。通常最好坚持异步请求并显示他们正在处理的用户，但同时让他们做其他事情。

于 2018-05-08T06:53:40.183 回答