使用JMS/ActiveMQ的并发同步请求-应答-模式/库？

Question

我有一个网络应用程序，当用户提交请求时，我们向远程服务发送JMS消息，然后等待回复。（也有异步请求，我们为消息重放等设置了各种细节，所以我们更愿意坚持使用JMS而不是HTTP）

在如何使用JMS实现请求-响应？，ActiveMQ似乎不鼓励每个请求使用临时队列，也不鼓励在JMSCorrelationID上使用选择器的临时消费者，因为这会增加开销。

但是，如果我使用池消费者进行回复，我如何从回复消费者发送回原始请求线程？

我当然可以编写自己的线程安全回调注册/调度，但我讨厌编写我怀疑已经由比我更了解的人编写的代码。

ActiveMQ页面推荐Lingo，自2006年以来一直没有更新过，以及Camel Spring远程处理，我的团队因为它的许多gotcha错误而禁止了它。

有更好的解决方案吗？是以实现此模式的库的形式，还是以不同的模式的形式来模拟JMS上的同步请求-应答？

相关SO问题：

• 使用JMS临时队列进行同步使用是一种好做法吗？，这表明在JMSCorrelationID上使用选择器启动消费者实际上开销很低，这与ActiveMQ文档所说的相矛盾。谁是对的

Answer 1

一位同事提出了一个潜在的解决方案——每个webapp线程一个响应队列/消费者，我们可以将返回地址设置为该特定线程拥有的响应队列。由于这些线程通常是长寿命的（并被重新用于后续的web请求），我们只需要在池生成线程时承受开销。

这就是说，整个练习让我重新思考JMS与HTTP之间的关系…：）

Answer 2

我仍然会考虑使用Camel，让它处理线程，也许不需要spring远程处理，只需要原始产品模板。

骆驼有一些很好的留档关于这个主题和工程与ActiveMQ非常好。http://camel.apache.org/jms#JMS-RequestreplyoverJMS

对于您关于启动基于选择器的消费者和开销的问题，ActiveMQ文档实际上说明的是，它需要往返到ActiveMQ代理，后者可能位于地球的另一端或高延迟网络上。这种情况下的开销是到AMQ代理的TCP/IP往返时间。我会将此视为一种选择。多次成功地使用了它。

Answer 3

在过去的一个项目中，我们遇到了类似的情况，其中同步WS请求是用一对Async req/res JMS消息处理的。当时我们使用Jboss JMS impl和临时目的地，其中开销很大。

我们最终编写了一个线程安全的调度程序，让WS等待JMS响应。我们使用CorrelationID将响应映射回请求。

这个解决方案完全是自己开发的，但是我遇到了一个很好的阻塞映射iml，它解决了将响应与请求匹配的问题。

方块图

如果您的解决方案是集群式的，则需要注意将响应消息发送到集群中的正确节点。我不知道ActiveMQ，但我记得JBoss消息传递在集群目的地的后台出现了一些小故障。