java - 如何将 HornetQ 消息代理与 RESTful 服务 JAX-RS Jersey 连接

Question

我已经使用 JAX-RS Jersey 创建了一个 RESTful 服务并将其部署在 tomcat 7 服务器上。

现在我想使用 JMS。请求将被捕获并定向到消息代理上的消息队列，消息应该从那里被推送到 REST 服务，然后响应将被重定向到最终用户。

我正在使用 Activemq。如何将 Activemq 与 RESTful 服务集成？

Answer 1

您的网络服务接口(interface)需要提供两个功能:submit 和poll。

• 客户端调用 submit，后者将请求作为 JMS 消息发送到传入队列，并返回消息 ID。 提交之后返回。
• 请求处理异步运行。例如，消息驱动 bean (MDB) 监听传入队列、处理消息并将结果放入传出队列。它将结果消息的关联 ID 设置为传入请求的消息 ID。关联 ID 是连接请求及其结果所必需的。
• 客户端以消息 ID(由 submit 返回)作为参数调用 poll 函数:poll 使用检查结果队列关联 ID 上的 JMS 消息选择器。它返回“尚未完成”或结果。客户端可能需要多次调用poll来获取结果。

注意事项:

• JMS 消息选择器是一个过滤器(类似于数据库中的 where 子句):在这种情况下需要它来识别给定请求的结果。
• setJMSCorrelationID 的 Javadoc