JBoss EAP 7.2 JMS MDB消息丢失排查指南

本文旨在帮助开发者排查和解决 JBoss EAP 7.2 环境下 JMS MDB 消息丢失的问题。通过分析 JMS 队列的运行时状态，确定是否存在多个消费者，并提供相应的排查命令，最终解决消息无法被 MDB 消费的问题。

在 JBoss EAP 7.2 中，当使用 JMS 消息驱动 Bean (MDB) 处理消息时，有时会遇到消息丢失的情况，即消息被发送到 JMS 队列，但 MDB 的 onMessage() 方法未被调用。 这种问题通常很难调试，因为它可能不会在服务器日志中产生任何错误。以下是一些排查和解决此问题的方法。

确认消费者数量

首先，需要确认是否有多个 MDB 实例或应用程序正在消费同一个 JMS 队列。MDB 的默认并发会话数为 15。 如果 consumer-count 远大于 15，则很可能存在多个消费者。

可以使用 JBoss CLI 命令来查看 JMS 队列的运行时状态，包括消费者数量、已添加的消息数量和当前队列中的消息数量。

/subsystem=messaging-activemq/server=default/jms-queue=HIFWebHookQueue:read-resource(include-runtime=true)

此命令的输出结果包含以下关键信息：

• consumer-count: 消费者数量。
• messages-added: 已添加到队列的消息总数。
• message-count: 当前队列中未被消费的消息数量。

如果 messages-added 大于 0，而 message-count 为 0，这意味着消息已被消费。 此时，我们需要进一步调查是谁消费了这些消息。

列出消费者

可以使用以下 JBoss CLI 命令来列出所有连接到指定 JMS 队列的消费者：

/subsystem=messaging-activemq/server=default/jms-queue=HIFWebHookQueue:list-consumers-as-json?

此命令将返回一个 JSON 格式的列表，其中包含每个消费者的详细信息，例如客户端 ID 和会话 ID。 通过查看此列表，可以确定是否有多个 MDB 实例或应用程序正在消费同一个队列。

解决多个消费者的问题

如果发现有多个消费者正在消费同一个 JMS 队列，则需要采取措施来解决此问题。以下是一些可能的解决方案：

1. 确保只有一个 MDB 部署在消费该队列: 检查服务器上部署的应用程序，确保只有一个 MDB 被配置为监听该队列。
2. 使用消息选择器: 如果需要多个 MDB 实例处理消息，可以使用消息选择器来将消息路由到特定的 MDB 实例。
3. 调整 MDB 的并发会话数: 如果单个 MDB 实例无法处理所有消息，可以增加其并发会话数。但是，需要确保 MDB 实例能够处理更高的负载。

检查 MDB 配置

确保 MDB 的配置正确，特别是以下属性：

• destinationType: 必须设置为 javax.jms.Queue。
• destination: 必须设置为正确的 JMS 队列名称，例如 java:/jms/queue/HIFWebHookQueue。
• ConnectionFactoryName: 必须设置为正确的连接工厂名称，例如 ConnectionFactory。

@MessageDriven(name = "WebhookListenerEJB", activationConfig = {
    @ActivationConfigProperty(propertyName="messagingType", propertyValue="javax.jms.MessageListener"),
    @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
    @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;
        // ... 处理消息 ...
        try {
            message.acknowledge();
        } catch (JMSException e) {
            // 处理确认消息失败的情况
            e.printStackTrace();
        }
    }
}

注意事项:

• 确保 MDB 实现了 javax.jms.MessageListener 接口。
• 在 onMessage() 方法中，务必处理可能抛出的 JMSException 异常，尤其是在调用 message.acknowledge() 方法时。

总结

排查 JBoss EAP 7.2 中 JMS MDB 消息丢失问题需要仔细分析 JMS 队列的运行时状态，并检查 MDB 的配置。通过确认消费者数量、列出消费者以及检查 MDB 配置，可以找到问题的根源并采取相应的措施来解决问题。 重要的是，要确保只有一个 MDB 实例或应用程序正在消费同一个 JMS 队列，并正确配置 MDB 的属性。 此外，务必处理 onMessage() 方法中可能抛出的 JMSException 异常。 通过这些步骤，可以确保 JMS MDB 能够可靠地处理消息。