如何解决使用 http-remoting 协议将 Tomcat 连接到嵌入在 JBoss EAP 7.2 中的 ActiveMQ
我在我的 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])
standalone-full.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 应用程序的 context.xml 中配置这个远程连接。我（遗憾地）必须使用 http-remoting 协议，而不是通过 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-client-all.jar 添加到 tomcats lib 文件并重新配置 context.xml 后，可以建立连接。此外，由于以下异常，客户端无法查找队列。在哪里可以配置队列的地址属性？
当我打电话
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]
解决方法
首先要注意的是，通过与 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>
这在 ActiveMQ Artemis documentation on Tomcat integration.
中讨论注意连接工厂的 httpEnabled=true 上的 brokerURL。这是一个重要的参数，它使客户端能够使用 JBoss EAP 上定义的 http-acceptor。
另外，请务必在您的应用程序中包含 artemis-jms-client-all.jar。
您可以使用 JBoss EAP 的 JNDI 实现（即 org.wildfly.naming.client.WildFlyInitialContextFactory）获得等效的解决方案。一般来说，当将 JMS 与 JBoss EAP 集成时，这将是推荐的方法。但是，前面提到的 org.apache.activemq.artemis.jndi.JNDIReferenceFactory 提供了与 Tomcat 的简单、直接的集成。此外，我还没有确认在这种情况下使用 JBoss EAP JNDI 实际上是可行的，而且它几乎肯定比我上面概述的直接集成更复杂。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
