JMS MDB消息处理概述与“丢失”现象
在企业应用集成中，jms（java message service）与mdb（message-driven bean）是实现异步消息处理的常用模式。通常，一个web应用通过servlet向jms队列发送消息，随后由一个mdb监听并消费这些消息。然而，在实际运行中，开发者可能会遇到一种困扰：消息生产者已成功发送消息，但预期的mdb的onmessage()方法却未被调用，日志中也无任何错误，这常常被误认为是“消息丢失”。
以下是一个典型的JBoss EAP 7.2环境下的JMS配置和代码示例：
JBoss JMS 队列配置:
Servlet 消息生产者:
@WebServlet(name = "/")
public class MyServlet extends HttpServlet {
@Inject
private JMSContext context;
@Resource(lookup = "java:jboss/exported/jms/queue/HifWebHookQueue")
private Queue queue;
protected void doGet(HttpServletRequest request, HttpServletResponse response) {
JMSProducer producer = context.createProducer();
producer.setDeliveryMode(DeliveryMode.PERSISTENT); // 持久化消息
ObjectMessage msg = context.createObjectMessage(evt); // evt 是一个可序列化的POJO
producer.send(queue,evt);
}
}MDB 消息消费者:
@MessageDriven(name = "WebhookListenerEJB", activationConfig = {
@ActivationConfigProperty(propertyName="messagingType", propertyValue="javax.jms.MessageListener"),
@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.MessageListener"),
@ActivationConfigProperty(propertyName="destination", propertyValue="java:/jms/queue/HIFWebHookQueue"),
@ActivationConfigProperty(propertyName="ConnectionFactoryName", propertyValue="ConnectionFactory"),
})
@TransactionManagement(value = TransactionManagementType.CONTAINER)
@TransactionAttribute(value = TransactionAttributeType.REQUIRED)
public class WebhookListenerEJB implements MessageListener {
public void onMessage(Message message) {
ObjectMessage msg = (ObjectMessage) message;
// ... 业务逻辑 ...
message.acknowledge(); // 在容器管理事务下，通常由容器处理
}
}在这种设置下，当Servlet发送消息后，如果MDB未被触发，首要的排查方向不应是消息真的“丢失”，而是理解消息在队列中的实际状态以及有多少消费者正在监听该队列。
诊断队列状态：JBoss CLI与运行时指标
要准确诊断消息处理情况，我们需要利用JBoss Command Line Interface (CLI) 来查看JMS队列的运行时指标。这些指标能清晰地反映消息的生命周期和消费情况。
执行以下CLI命令来获取特定JMS队列的运行时资源信息：
/subsystem=messaging-activemq/server=default/jms-queue=HIFWebHookQueue:read-resource(include-runtime=true)
该命令将返回队列的详细状态，其中几个关键字段对于排查问题至关重要：
- messages-added: 表示自队列创建或重置以来，添加到此队列的消息总数。
- message-count: 表示当前队列中等待被消费的消息数量。
- consumer-count: 表示当前连接到此队列的消费者数量。
示例CLI输出解读:
{
"outcome" => "success",
"result" => {
"consumer-count" => 30,
"dead-letter-address" => "jms.queue.DLQ",
"delivering-count" => 0,
"durable" => true,
"entries" => [
"HifWebHookQueue",
"java:jboss/exported/jms/queue/HifWebHookQueue"
],
"expiry-address" => "jms.queue.ExpiryQueue",
"legacy-entries" => undefined,
"message-count" => 0L,
"messages-added" => 1L,
"paused" => false,
"queue-address" => "jms.queue.HIFWebHookQueue",
"scheduled-count" => 0L,
"selector" => undefined,
"temporary" => false
}
}从上述输出中，我们可以观察到：
- messages-added 为 1L：表明确实有一条消息被成功发送并添加到了队列。
- message-count 为 0L：这至关重要！它表示当前队列中没有消息等待被消费。结合 messages-added 为1，这意味着那条被发送的消息已经被某个消费者成功接收并处理了。如果消息未被消费，message-count 应该与 messages-added 相等（或接近）。
- consumer-count 为 30：这表示有30个消费者实例正在监听这个队列。而MDB的默认并发会话数通常为15。这意味着极有可能存在多个MDB部署或其他的应用也在消费同一个队列。
揭示真相：多消费者竞争
当 messages-added 大于0而 message-count 为0时，结合高 consumer-count，最可能的原因是消息已被其他消费者处理。即使你的特定MDB没有被调用，也不能断定消息丢失，因为队列上的其他消费者可能已经接收并处理了它。
在JMS中，对于队列（Queue）模型，消息是点对点（point-to-point）的。一条消息一旦被一个消费者接收并成功处理，就会从队列中移除，其他消费者便无法再接收到它。因此，如果存在多个MDB实例或不同的应用程序都监听同一个JMS队列，它们之间会形成竞争关系，任何一个消费者都可能率先获取并处理消息。
识别所有活跃消费者
为了验证是否存在未预期的消费者，JBoss CLI提供了查看所有活跃消费者的命令：
/subsystem=messaging-activemq/server=default/jms-queue=HIFWebHookQueue:list-consumers-as-json?
执行此命令，你将获得一个JSON数组，其中列出了所有连接到 HIFWebHookQueue 的消费者详情，包括它们的客户端ID、连接ID、订阅名称等。通过分析这些信息，你可以识别出所有正在消费此队列的MDB实例或应用程序，从而定位到是哪个（或哪些）“额外”的消费者处理了消息。
最佳实践与注意事项
-
MDB配置审查：
- 仔细检查MDB的 @ActivationConfigProperty 中的 destination 属性，确保它指向正确的JMS队列。细微的拼写错误或JNDI名称差异都可能导致MDB监听错误的队列，或者创建了一个新的、独立的队列。
- 确认 destinationType 为 javax.jms.Queue。
-
部署管理：
- 避免重复部署： 确保同一个MDB或消费相同队列的其他应用程序没有被意外地多次部署到JBoss EAP服务器上。这可能是导致 consumer-count 异常高的常见原因。
- 集群环境： 在集群环境中，每个节点上的MDB实例都会作为独立的消费者。如果每个节点部署了MDB，并且MDB的并发会话数设置为默认值（如15），那么集群的总消费者数量将是 节点数 * 15。这是正常现象，但需要理解消息会在所有节点之间进行负载均衡。
-
事务与消息确认：
- 在 @TransactionManagement(value = TransactionManagementType.CONTAINER) 和 @TransactionAttribute(value = TransactionAttributeType.REQUIRED) 的配置下，消息的接收和确认（acknowledgement）由容器自动管理。当 onMessage() 方法成功执行并返回时，消息才会被视为成功处理并从队列中移除。如果发生异常，事务会回滚，消息通常会被重新投递。
- 手动调用 message.acknowledge() 在容器管理事务下通常是不必要的，甚至可能引起冲突。
-
日志与监控：
- 在MDB的 onMessage() 方法中添加详细的日志输出，记录消息ID和处理结果，这有助于追踪消息的实际处理路径。
- 持续监控JMS队列的运行时指标，尤其是 message-count 和 consumer-count，以便及时发现异常情况。
总结
当JBoss EAP环境下JMS MDB出现“消息丢失”的假象时，通常并非消息真的消失，而是被预期之外的消费者处理了。通过熟练运用JBoss CLI工具，检查JMS队列的 messages-added、message-count 和 consumer-count 等运行时指标，并进一步列出所有活跃消费者，可以迅速定位问题根源。理解JMS队列的点对点特性和多消费者竞争机制，结合严格的部署管理和MDB配置审查，是确保消息正确流转和处理的关键。
