需要验证方法：Spring集成AMQP异步

Question

我最近一直在研究Spring集成和AMQP（RabbitMQ），因为我需要用异步方法通信两个应用程序（中间件和后端），这样中间件在接收客户端调用时就不会阻塞。

我首先采用了一种更简单的方法，以同步方式实现这一点，这意味着我在中间件上有一个网关接口和一个出站网关（requiresReply=true），然后在后端有一个入站网关和一个服务激活器。这种初始方法工作得很好（我使用了Spring集成XML配置）。

现在，我需要澄清如何以异步方式实现这一点。

通过查看RabbitMQ教程6，最好使用回调队列和相关标识，根据我的理解，这将类似于调用Spring RabbitTemboard的转换和发送（），然后接收（），而不是转换SendAnd接收（）（这将阻止直到收到响应）。

我已经检查了Spring集成文档，其中我需要替换中间件上的网关接口，以便它返回Future或ListenableFuture。

异步网关

完成后，我还查看了outbound gateway的文档，其中说明它可以与RabbitTemplate一起管理correlationID和replyTo消息属性。

我的问题是：

1. 为了使用异步方法使其工作，我应该继续使用出站/入站网关而不是出站/入站消息转换器吗？
2. 在遵循出站/入站消息转换器方法的情况下（听起来类似于RabbitMQ教程所展示的内容），我如何将网关接口上的Future与从入站通道适配器返回的结果相关联？

Answer 1

老实说，你没有提供原始的业务需求。这可能是一个事实，真的没有理由处理这个asynchandsoff，因为你有一个@Gateway作为一个切入点，它是无线程的，即使它被阻止等待回复它不影响其他线程，这些线程可能执行类似的sendAndRecture操作。在大多数情况下，在同一个请求者线程中执行所有操作就足够了，并且不会因为转移到共享的ThreadPoolExecator而降低性能。

好的，Future允许您释放调用方一点，以便准备好接受同一线程中的新请求。

由于它是一个MessagingGateway并且您无论如何都希望得到一个应答，因此有一个与请求相关联的钩子-TemporaryReplyChannel头。这就是为什么

我想说的是，我们可以实现与异步回复要求相同的临时回复通道增益。

1. 您应该使用入站/出站通道适配器对。
2. 在发送消息到之前

嗯，像这样的事情...

HTH

请随时提出更多问题。如果我误解了你的问题，请纠正我。