使用超文本传输协议将Tomcat连接到嵌入在JBoss EAP 7.2中的ActiveMQ

Question

为了更好的重现性，我在我的docker-compose.yml中定义了以下系统。

version: '2.2'
services:
  jmstool:
    image: spx01/jmstool-activemq
    container_name: jmstool
    ports:
      - 8181:8080
    volumes:
      - ./context.xml:/usr/local/tomcat/conf/context.xml
  jboss:
    image: daggerok/jboss-eap-7.2
    container_name: jboss
    environment:
      - PREPEND_JAVA_OPTS=-Djboss.server.default.config=standalone-full.xml
    ports:
      - 8080:8080
    volumes:
      - ./configure.cli:/tmp/configure.cli

工具jmstool是部署在Tomcat 9上的Spring应用程序，用于通过JMS与不同队列通信。我可以让它与独立的activeMQ一起工作。

启动这些容器后，我向运行JBoss的消息传递子系统添加了一个应用程序用户和两个队列：

docker exec jboss jboss-eap-7.2/bin/add-user.sh -a -u myUser -p "myPa##word"
docker exec jboss jboss-eap-7.2/bin/jboss-cli.sh --file=/tmp/configure.cli

configure.cli的内容

connect
/subsystem=messaging-activemq/server=default/jms-queue=ImportantMessages:add(entries=[java:jboss/exported/ImportantMessages])
/subsystem=messaging-activemq/server=default/jms-queue=ImportantMessagesOut:add(entries=[java:jboss/exported/ImportantMessagesOut])

独立版已满。xml看起来不错，与[另一个例子][2]非常相似。

    <subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0">
        <server name="default">
            <journal pool-files="10"/>
            <security-setting name="#">
                <role name="guest" send="true" consume="true" create-non-durable-queue="true" delete-non-durable-queue="true"/>
            </security-setting>
            <address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10"/>
            <http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/>
            <http-connector name="http-connector-throughput" socket-binding="http" endpoint="http-acceptor-throughput">
                <param name="batch-delay" value="50"/>
            </http-connector>
            <in-vm-connector name="in-vm" server-id="0">
                <param name="buffer-pooling" value="false"/>
            </in-vm-connector>
            <http-acceptor name="http-acceptor" http-listener="default"/>
            <http-acceptor name="http-acceptor-throughput" http-listener="default">
                <param name="batch-delay" value="50"/>
                <param name="direct-deliver" value="false"/>
            </http-acceptor>
            <in-vm-acceptor name="in-vm" server-id="0">
                <param name="buffer-pooling" value="false"/>
            </in-vm-acceptor>
            <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
            <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
            <jms-queue name="ImportantMessages" entries="java:jboss/exported/ImportantMessages"/>
            <jms-queue name="ImportantMessagesOut" entries="java:jboss/exported/ImportantMessagesOut"/>
            <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
            <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
            <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa"/>
        </server>
    </subsystem>

现在我尝试在上下文中配置这个远程连接。Spring应用程序的xml。我（遗憾地）不得不使用http远程处理协议，而不是通过tcp连接。

<Context>
<JarScanner scanClassPath="false" scanAllFiles="false" scanAllDirectories="false"/>

<Resource
        name="jms/ImportantMessages"
        auth="Container"
        type="org.apache.activemq.command.ActiveMQQueue"
        factory="org.apache.activemq.jndi.JNDIReferenceFactory"
        physicalName="ImportantMessages"/>

<Resource
        name="jms/ImportantMessagesOut"
        auth="Container"
        type="org.apache.activemq.command.ActiveMQQueue"
        factory="org.apache.activemq.jndi.JNDIReferenceFactory"
        physicalName="ImportantMessagesOut"/>

<Environment name="spring.jms.jndi-name"
             value="jms/RemoteConnectionFactory"
             type="java.lang.String"
             override="false"/>

<Environment name="jmstool.outgoingQueues"
             value="java:comp/env/jms/ImportantMessages"
             type="java.lang.String"
             override="false"/>

<Environment name="jmstool.incomingQueues"
             value="java:comp/env/jms/ImportantMessagesOut"
             type="java.lang.String"
             override="false"/>

</Context>

jmstool日志中的异常并不让我感到惊讶：

ackOff{interval=5000, currentAttempts=14, maxAttempts=unlimited}. Cause: Could not create Transport. Reason: java.io.IOException: Transport scheme NOT recognized: [http-remoting]

当我将[jboss-remoting][3]、[jboss-remoting3][4]或[activemq optional][5]添加到Tomcat的lib文件夹时，仍然会发生此错误。

有人知道我做错了什么吗？

编辑：贾斯汀的回答帮助了我。在添加artemis jms客户端之后。jar到tomcats lib文件并重新配置上下文。xml可以建立连接。此外，由于以下异常，客户端无法查找队列。在哪里可以配置队列的address属性？

当我呼唤

new JndiLocatorDelegate().lookup("java:comp/env/jms/ImportantMessages", javax.jms.Queue.class)

将引发此异常

        Caused by: java.lang.IllegalArgumentException: address cannot be null
            at org.apache.activemq.artemis.jms.client.ActiveMQDestination.setSimpleAddress(ActiveMQDestination.java:414)
            at org.apache.activemq.artemis.jms.client.ActiveMQDestination.setAddress(ActiveMQDestination.java:399)
            at org.apache.activemq.artemis.jms.client.ActiveMQDestination.buildFromProperties(ActiveMQDestination.java:540)
            at org.apache.activemq.artemis.jndi.JNDIStorable.setProperties(JNDIStorable.java:58)
            at org.apache.activemq.artemis.jndi.JNDIReferenceFactory.getObjectInstance(JNDIReferenceFactory.java:65)
            at org.apache.naming.factory.FactoryBase.getObjectInstance(FactoryBase.java:94)
            at javax.naming.spi.NamingManager.getObjectInstance(NamingManager.java:321)
            at org.apache.naming.NamingContext.lookup(NamingContext.java:840)
            ... 68 more

当我将一个非空字符串设置为定义资源节点的队列的address=“asdf”时，我得到了异常

DefaultMessageListenerContainer  : Could not refresh JMS Connection for destination 'java:comp/env/jms/ImportantMessagesOut' - retrying using FixedB
ackOff{interval=5000, currentAttempts=9, maxAttempts=unlimited}. Cause: Failed to create session factory; nested exception is ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=AMQ219013:
Timed out waiting to receive cluster topology. Group:null]

Answer 1

首先要注意的是，通过与JBoss EAP集成，您并不是在使用ActiveMQ 5。x、 您正在使用ActiveMQ Artemis。因此，您需要使用ActiveMQ Artemis中的集成类，例如：

<Context>
<JarScanner scanClassPath="false" scanAllFiles="false" scanAllDirectories="false"/>

<Resource
        name="jms/ImportantMessages"
        auth="Container"
        type="org.apache.activemq.artemis.jms.client.ActiveMQQueue"
        factory="org.apache.activemq.artemis.jndi.JNDIReferenceFactory"
        address="ImportantMessages"/>

<Resource
        name="jms/ImportantMessagesOut"
        auth="Container"
        type="org.apache.activemq.artemis.jms.client.ActiveMQQueue"
        factory="org.apache.activemq.artemis.jndi.JNDIReferenceFactory"
        address="ImportantMessagesOut"/>

<Resource
        name="jms/connectionFactory"
        auth="Container"
        userName="myUser"
        password="myPa##word"
        type="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory"
        factory="org.apache.activemq.artemis.jndi.JNDIReferenceFactory"
        brokerURL="tcp://jboss:8080?httpEnabled=true"/>

<Environment name="jmstool.outgoingQueues"
             value="java:comp/env/jms/ImportantMessages"
             type="java.lang.String"
             override="false"/>

<Environment name="jmstool.incomingQueues"
             value="java:comp/env/jms/ImportantMessagesOut"
             type="java.lang.String"
             override="false"/>

</Context>

这将在Tomcat集成的ActiveMQ Artemis留档中讨论。

注意连接工厂的brokerURL上的httpEnabled=true。这是一个重要参数，它使客户端能够使用JBoss EAP上定义的http接受器。

此外，请务必将artemis-jms-client-all.jar包含在您的应用程序中。

使用JBoss EAP中的JNDI实现，您可能会得到一个等效的解决方案（即org.wildfly.naming.client.WildFlyInitialContextFactory）。一般来说，在将JMS与JBoss EAP集成时，这将是推荐的方法。然而，前面提到的org。阿帕奇。activemq。阿耳特弥斯。jndi。JNDIReferenceFactory提供了与Tomcat的简单、直接的集成。此外，我还没有确认在这个场景中使用JBoss EAP JNDI实际上是可能的，而且几乎可以肯定，它比我上面概述的直接集成更复杂。