java - 如何发出 JMS 同步请求

标签 java architecture jms ibm-mq

我有一个 Web 应用程序,需要从只能通过消息传递 (JMS) 访问的外部应用程序获取和显示数据。

因此,如果用户在浏览器上提交请求,则同一个 HTTP 请求线程将必须与消息系统(MQ 系列)交互,以便同一个请求线程可以显示从消息系统接收的数据。

这里有我可以使用的模式吗?我在网上看到一些模糊的引用资料是这样使用“Correlation ID”的:

Msg m = new TextMsg("findDataXYZ");
String cr_id = m.setCorrelationID(id);

sendQueue.send(m).

// now start listening to the Queue for a msg that bears that specific cr_id

Response r = receiverQueue.receive(cr_id);

还有更好的吗?我发现的其他模式期望异步接收响应。这对我来说不是一个选项,因为我必须在同一个 HTTP 请求上发回响应。

最佳答案

请求/回复消息传递模式对您的要求很有用。您通常使用 CorrelationId 来关联请求和回复消息。

在发送请求消息时,您在消息上设置了 JMSReplyTo 目的地。通常临时队列用作 JMSReplyTo 目标。创建消费者以接收响应时,使用带有 JMSCorrelationId 的选择器,例如

cons = session.createConsumer(tempDestination,"JMSCorrelationId="+requestMsg.JMSMessageId);

在另一端,处理请求消息的应用程序必须使用 JMSReplyTo 目的地来发送响应。它还必须使用请求消息的 MessageId 并将其设置为响应消息的 CorrelationId。

关于java - 如何发出 JMS 同步请求,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10778485/

相关文章:

java - 为什么子列表不适用于 List<Object>?

jboss - 使用Jboss资源适配器连接ActiveMQ时配置sendTimeout

java - 获取 "Failed to capture snapshot of input files for task ' :compileJava' "

rest - 如何使用不同的端点集动态创建权限组 Django Rest Framework

java - 逻辑架构模型 : references for further understanding?

java - 从 ActiveMQ 并行消费消息

java - 是否有任何 JAX-RS 实现解析路径段特定参数和值?

java - 如何更改 GWT 中 DecoratorPanel 的颜色?

java - 如何用另一个 void 方法来阻止方法

mysql - 在数据库中存储数百万个 URL 以进行快速模式匹配