WildFly中Message Driven Bean无法接收Topic消息求助

咱们一步步拆解你的MDB收不到消息的核心问题，然后逐个解决：

问题根源 #

你的猜测完全正确：当前MDB默认绑定到了WildFly内嵌的ActiveMQ Artemis，而非你独立部署的ActiveMQ Classic。从配置来看，你同时存在两套冲突的JMS配置：WildFly自带的messaging-activemq子系统（内嵌Artemis），以及你尝试添加的外部ActiveMQ资源适配器，但两者的资源适配器名称重复、配置不完整，导致MDB没有正确关联到外部ActiveMQ。

分步解决方案 #

1. 禁用/移除内嵌的ActiveMQ Artemis #

既然要使用独立ActiveMQ，内嵌的Artemis会干扰配置，先处理它：
打开standalone-full.xml，找到整个<subsystem xmlns="urn:jboss:domain:messaging-activemq:2.0">节点，直接注释或删除即可。

2. 完整配置外部ActiveMQ资源适配器 #

你之前添加的resource-adapters配置不完整，补充完整后才能正确连接外部ActiveMQ：

<subsystem xmlns="urn:jboss:domain:resource-adapters:2.0">
    <resource-adapters>
        <resource-adapter id="activemq-ra">
            <!-- 确保这个rar包已放到WildFly的deployments目录 -->
            <archive>activemq-rar-5.10.0.rar</archive>
            <transaction-support>XATransaction</transaction-support>
            <!-- 独立ActiveMQ的连接地址 -->
            <config-property name="ServerUrl">tcp://localhost:61616</config-property>
            <!-- 替换为你的ActiveMQ真实账号密码 -->
            <config-property name="UserName">admin</config-property>
            <config-property name="Password">admin</config-property>
            <config-property name="UseInboundSession">false</config-property>

            <!-- 定义连接工厂 -->
            <connection-definitions>
                <connection-definition class-name="org.apache.activemq.ra.ActiveMQManagedConnectionFactory"
                    jndi-name="java:/ExternalActiveMQConnectionFactory"
                    enabled="true"
                    pool-name="ExternalActiveMQConnectionFactory">
                    <xa-pool>
                        <min-pool-size>1</min-pool-size>
                        <max-pool-size>20</max-pool-size>
                        <prefill>false</prefill>
                        <is-same-rm-override>false</is-same-rm-override>
                    </xa-pool>
                </connection-definition>
            </connection-definitions>

            <!-- 注册你要监听的Ecare Topic -->
            <admin-objects>
                <admin-object class-name="org.apache.activemq.command.ActiveMQTopic"
                    jndi-name="java:/jms/topic/Ecare"
                    use-java-context="true"
                    pool-name="EcareTopic">
                    <config-property name="PhysicalName">Ecare</config-property>
                </admin-object>
            </admin-objects>
        </resource-adapter>
    </resource-adapters>
</subsystem>

⚠️ 注意：要把activemq-rar-5.10.0.rar复制到WildFly的deployments目录，确保它部署成功（可以通过WildFly管理控制台确认）。

3. 调整EJB子系统的MDB全局配置 #

修改ejb3子系统的MDB配置，明确指向外部ActiveMQ的资源适配器：

<subsystem xmlns="urn:jboss:domain:ejb3:5.0">
    <!-- 保留其他ejb3配置不变 -->
    <mdb>
        <resource-adapter-ref resource-adapter-name="activemq-ra"/>
        <bean-instance-pool-ref pool-name="mdb-strict-max-pool"/>
    </mdb>
</subsystem>

这里的resource-adapter-name要和上面resource-adapter的id完全一致，不能用原来的activemq-ra.rar。

4. 修正MDB的注解配置 #

调整你的MDB代码，确保它指向正确的JNDI和资源适配器：

@MessageDriven(
    name = "receiver",
    activationConfig = {
        @ActivationConfigProperty(
            propertyName = "destinationType",
            propertyValue = "javax.jms.Topic"
        ),
        @ActivationConfigProperty(
            propertyName = "destination",
            propertyValue = "java:/jms/topic/Ecare" // 对应我们配置的JNDI名称
        ),
        @ActivationConfigProperty(
            propertyName = "acknowledgeMode",
            propertyValue = "Auto-acknowledge"
        ),
        // 可选：全局配置后可省略，但加上更明确
        @ActivationConfigProperty(
            propertyName = "resourceAdapter",
            propertyValue = "activemq-ra"
        )
    }
)
// 移除原来的@ResourceAdapter注解，全局配置已生效
public class JMSListener implements MessageListener {
    private Logger logger = Logger.getLogger("JMSListener logger");
    private JMSNotifier jmsNotifier = new JMSNotifier();

    @Override
    public void onMessage(Message message) {
        logger.info("Message received");
        jmsNotifier.notifyAllSubscribers();
    }
}

验证与额外排查 #

1. 启动WildFly，查看server.log，确认activemq-ra资源适配器部署成功，且MDB绑定到了外部ActiveMQ的Ecare Topic。
2. 登录独立ActiveMQ控制台，检查Ecare Topic是否有消费者连接（MDB启动后会显示1个消费者）。
3. 发送测试消息到Ecare Topic，查看WildFly日志是否打印Message received。
4. 如果仍有问题，检查WildFly是否能访问tcp://localhost:61616端口，无防火墙限制；同时查看日志中的错误信息定位问题。

内容的提问来源于stack exchange，提问作者Nikita Mikhailov