如何在块中发送多个 JMS 消息（每个都在一个新事务中）

Question

我的 Java EE 6 Web 应用程序已达到可在单个事务中发送的最大 JMS 消息数，我需要在多个事务中执行此操作。当事务由容器管理时，最好的方法是什么？跨不同事务使用同一个MessageProducer是否可以（使用带有@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)注解的EJB方法）

我正在使用 Glassfish v3 和 OpenMQ。

这个 SO 问题Maximum number of messages sent to a Queue in OpenMQ? 涵盖了 OpenMQ 中最大消息数的问题。

Answer 1

如果您无法找到在应用服务器中使用容器管理事务实现此目的的方法，并且您不想使用编程事务，则可以考虑使用聚合器和/或拆分器企业集成模式。

在您的生产者中，将您的单个消息或对象聚合为一条复合消息。在消费者端，拆分复合消息以进行适当的处​​理。

Answer 2

@theo：太好了。所以基本上你目前的业务流程是：-

前端（JSF UI）操作--> EJB 层（交易开始）--->发布 消息到 FINAL QUEUE。

现在这是解决您的问题的一种方法：- 您可以在两者之间定义一个拆分队列：- 所以流量可以是

要么：--前端（JSF UI）操作-->EJB层-->SPLIT QUEUE--->MDB-->FINAL 排队
要么， 前端（JSF UI） 操作-->SPLIT QUEUE-->EJB 层-->最终队列

所以基本的想法是因为每个事务限制有 n 个消息传递者，如果你有 m 个要发布的消息，其中 m>n 和 m>0；然后你可以通过在中间引入一个 SPLIT QUEUE 将 m 分成 m\n 次块。我已经在我的一个项目中做到了这一点。如果您有任何问题，请告诉我。

---

@Theo：我不太清楚 Asynkronos 提到了什么。但这就是我的意思：- 您的 JSF UI 操作导致（让我们说）1000 条 JMS 消息到您的 FINAL 队列。 现在让我们假设，每个事务限制有 200 条 JMS 消息。 你可以做的可能是：-

虽然我不完全了解您的数据模型/业务流程，但这里是概要。 让我假设您的 JMS 消息的有效负载数据来自一组可以由标识符 Un 唯一标识的表。因此，您有 1000 条要发布的 JMS 消息，由 U1、U2....U1000 标识。 所以基本上你可以定义一个内部 SPLIT 队列。在您的 Java 代码中，将 1000 个标识符拆分为每个 200 个块：{U1...U200},{U201...U400),{U401...U600),(U601,..U800) 和 (U801 ,...U1000)。您可以将这些标识符列表作为 Java.util.List 有效负载发布到您的拆分队列中。 您可以使用事务属性 REQUIRES-NEW 定义 MDB 侦听 SPLIT 队列。 在 MDB 代码中，您可以获取标识符列表并执行 for 循环：

onMessage(Message m){
ObjectMessage objectMsg=(ObjectMessage) m;
java.util.List list=(List) objectMsg.getObject();
//open  a JMS session
for (String identifer : list){

//fetch data from DB for particular identifier.

//prepare output JMS payload for that particular identifier.

//publish JMS data onto FINAL queue
}

希望这可以澄清。