如何将 WebLogic JMS 消息传递桥配置到 Artemis答案

【问题标题】：How to configure WebLogic JMS Messaging Bridge to Artemis如何将 WebLogic JMS 消息传递桥配置到 Artemis
【发布时间】：2020-09-05 02:46:23
【问题描述】：

我正在尝试建立一个连接到 Artemis 的 WLS (12.1.3) 网桥，但我无法让它正常工作。我认为我的问题可能在于我在 WebLogic 中配置桥接目标的方式，但无法弄清楚！

Error "Invalid broker URL" while bridging ActiveMQ Artemis 7.4 with Weblogic 12.x 的问题非常相似。他们似乎设法让它发挥作用，但我认为我遗漏了一些关键细节！

到目前为止我所做的是：

将“artemis-jms-client-all-2.13.0.jar”和“jndi.properties”添加到 WebLogic 域“lib”文件夹
修改了 WLS 启动脚本，使“jndi.properties”位于类路径中，并通过检查启动日志中“java.class.path”的输出确认该脚本正在被拾取
jndi.properties 有以下内容：

java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
connectionFactory.ConnectionFactory=tcp://myArtemisServer:61616?type=XA_CF

在 WebLogic config.xml 中，像这样配置 JMS 网桥目标（在网桥“local2artemis”中使用它，本地队列作为源，这个 artemis 目标作为目标）：

<jms-bridge-destination>
    <name>artemis_endpoint</name>
    <adapter-jndi-name>eis.jms.WLSConnectionFactoryJNDIXA</adapter-jndi-name>
    <user-name>myUser</user-name>
    <user-password-encrypted>XXXXXXXXXXXXXXXXXXXXXX</user-password-encrypted>
    <connection-factory-jndi-name>ConnectionFactory</connection-factory-jndi-name>
    <initial-context-factory>org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory</initial-context-factory>
    <connection-url>tcp://myArtemisServer:61616?type=XA_CF</connection-url>
    <destination-jndi-name>MY.ADDRESS::my/queue/jndi/name</destination-jndi-name>
</jms-bridge-destination>

地址和队列 jndi 在“myArtemisServer”中静态定义
在 WebLogic 启动时出现此错误，一遍又一遍地重复：

####<13-Aug-2020 12:56:46 o'clock IST> <Debug> <MessagingBridgeRuntime> <localhost> <AdminServer> <[ACTIVE] ExecuteThread: '0' for queue: 'weblogic.kernel.Default (self-tuning)'> <<WLS Kernel>> <> <> <1597319806108> <BEA-000000> <Bridge  Getting target connection> 
####<13-Aug-2020 12:56:46 o'clock IST> <Debug> <MessagingBridgeRuntimeVerbose> <localhost> <AdminServer> <[ACTIVE] ExecuteThread: '0' for queue: 'weblogic.kernel.Default (self-tuning)'> <<anonymous>> <> <> <1597319806115> <BEA-000000> <Exception:
javax.naming.NameNotFoundException: ConnectionFactory
    at org.apache.activemq.artemis.jndi.ReadOnlyContext.lookup(ReadOnlyContext.java:236)
    at javax.naming.InitialContext.lookup(InitialContext.java:417)
    at weblogic.jms.adapter.JMSBaseConnection$2.run(JMSBaseConnection.java:301)
    at weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:363)
    at weblogic.jms.adapter.JMSBaseConnection.startInternal(JMSBaseConnection.java:299)
    at weblogic.jms.adapter.JMSBaseConnection.start(JMSBaseConnection.java:256)
    at weblogic.jms.adapter.JMSManagedConnectionFactory.createManagedConnection(JMSManagedConnectionFactory.java:192)
    at weblogic.connector.security.layer.AdapterLayer.createManagedConnection(AdapterLayer.java:843)
    at weblogic.connector.outbound.ConnectionFactory.createResource(ConnectionFactory.java:91)
    at weblogic.common.resourcepool.ResourcePoolImpl.makeResources(ResourcePoolImpl.java:1331)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResourceInternal(ResourcePoolImpl.java:425)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:344)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:324)
    at weblogic.connector.outbound.ConnectionPool.reserveResource(ConnectionPool.java:705)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:318)
    at weblogic.connector.outbound.ConnectionManagerImpl.getConnectionInfo(ConnectionManagerImpl.java:409)
    at weblogic.connector.outbound.ConnectionManagerImpl.getConnection(ConnectionManagerImpl.java:343)
    at weblogic.connector.outbound.ConnectionManagerImpl.allocateConnection(ConnectionManagerImpl.java:134)
    at weblogic.jms.adapter.JMSBaseConnectionFactory.getTargetConnection(JMSBaseConnectionFactory.java:123)
    at weblogic.jms.bridge.internal.MessagingBridge.getConnections(MessagingBridge.java:880)
    at weblogic.jms.bridge.internal.MessagingBridge.run(MessagingBridge.java:1079)
    at weblogic.work.SelfTuningWorkManagerImpl$WorkAdapterImpl.run(SelfTuningWorkManagerImpl.java:553)
    at weblogic.work.ExecuteThread.execute(ExecuteThread.java:311)

****************** 更新 *************

摆脱 jndi.properties 并将网桥配置更改为

<connection-factory-jndi-name>XAConnectionFactory</connection-factory-jndi-name>

新的错误，完整的堆栈跟踪是

javax.naming.NamingException: scheme MY.ADDRESS not recognized
    at org.apache.activemq.artemis.jndi.ReadOnlyContext.lookup(ReadOnlyContext.java:222)
    at javax.naming.InitialContext.lookup(InitialContext.java:417)
    at weblogic.jms.adapter.JMSBaseConnection$3.run(JMSBaseConnection.java:326)
    at weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:363)
    at weblogic.jms.adapter.JMSBaseConnection.startInternal(JMSBaseConnection.java:324)
    at weblogic.jms.adapter.JMSBaseConnection.start(JMSBaseConnection.java:256)
    at weblogic.jms.adapter.JMSManagedConnectionFactory.createManagedConnection(JMSManagedConnectionFactory.java:192)
    at weblogic.connector.security.layer.AdapterLayer.createManagedConnection(AdapterLayer.java:843)
    at weblogic.connector.outbound.ConnectionFactory.createResource(ConnectionFactory.java:91)
    at weblogic.common.resourcepool.ResourcePoolImpl.makeResources(ResourcePoolImpl.java:1331)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResourceInternal(ResourcePoolImpl.java:425)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:344)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:324)
    at weblogic.connector.outbound.ConnectionPool.reserveResource(ConnectionPool.java:705)
    at weblogic.common.resourcepool.ResourcePoolImpl.reserveResource(ResourcePoolImpl.java:318)
    at weblogic.connector.outbound.ConnectionManagerImpl.getConnectionInfo(ConnectionManagerImpl.java:409)
    at weblogic.connector.outbound.ConnectionManagerImpl.getConnection(ConnectionManagerImpl.java:343)
    at weblogic.connector.outbound.ConnectionManagerImpl.allocateConnection(ConnectionManagerImpl.java:134)
    at weblogic.jms.adapter.JMSBaseConnectionFactory.getTargetConnection(JMSBaseConnectionFactory.java:123)
    at weblogic.jms.bridge.internal.MessagingBridge.getConnections(MessagingBridge.java:880)
    at weblogic.jms.bridge.internal.MessagingBridge.run(MessagingBridge.java:1079)
    at weblogic.work.SelfTuningWorkManagerImpl$WorkAdapterImpl.run(SelfTuningWorkManagerImpl.java:553)
    at weblogic.work.ExecuteThread.execute(ExecuteThread.java:311)
    at weblogic.work.ExecuteThread.run(ExecuteThread.java:263)
>

在 Artemis 中这样定义队列：

<address name="MY.ADDRESS">
   <anycast>
       <queue name="my/queue/jndi/name" />
   </anycast>
</address>

【问题讨论】：

标签： jms weblogic jndi activemq-artemis

【解决方案1】：

由于您在connection-url 中使用type=XA_CF，因此您应该使用XAConnectionFactory 作为connection-factory-jndi-name。

关于destination-jndi-name 的NamingException，您使用完全限定队列名称（即<address>::<queue>）是否有特定原因？正如the documentation 中所讨论的，通常您会将队列名称和地址名称配置为与 JMS 客户端相同，以便生产者消费者可以使用相同的值，这通常不会让应用程序开发人员感到困惑。 FQQN 通常保留用于特殊用例。此外，在 2.15.0 之前，JNDI 查找不支持 FQQN 语法（请参阅ARTEMIS-2880）。因此，我建议您在 Artemis 的 broker.xml 中使用类似这样的内容：

<address name="myJmsDestination">
   <anycast>
       <queue name="myJmsDestination" />
   </anycast>
</address>

此外，由于您没有在 JNDI 环境属性中配置 JMS 目标的选项，您应该使用 dynamicQueues/ 前缀，如 the documentation 中所述。

最终你的配置应该是这样的：

<jms-bridge-destination>
    <name>artemis_endpoint</name>
    <adapter-jndi-name>eis.jms.WLSConnectionFactoryJNDIXA</adapter-jndi-name>
    <user-name>myUser</user-name>
    <user-password-encrypted>XXXXXXXXXXXXXXXXXXXXXX</user-password-encrypted>
    <connection-factory-jndi-name>XAConnectionFactory</connection-factory-jndi-name>
    <initial-context-factory>org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory</initial-context-factory>
    <connection-url>tcp://myArtemisServer:61616?type=XA_CF</connection-url>
    <destination-jndi-name>dynamicQueues/myJmsDestination</destination-jndi-name>
</jms-bridge-destination>

最后，我认为您实际上并不需要 jndi.properties 文件。所有必要的属性都可以直接在jms-bridge-destination中定义。

【讨论】：

非常感谢贾斯汀，这帮助我继续前进！但是我认为我定义“destination-jndi-name”来引用队列的方式现在是不正确的——我得到了一个“无法识别方案 MY.ADDRESS”的命名异常。任何关于从这里去哪里的指针都非常感谢！
这是在 Artemis 中定义的队列，顺便说一句：<address name="MY.ADDRESS"> <anycast> <queue name="my/queue/jndi/name" /> </anycast> </address>
谢谢。我实际上并不完全确定我们为什么要使用这样的地址，必须与团队核实。无论如何，我已经用详细信息和堆栈跟踪更新了问题。非常感谢您的支持！
我更新了我的答案以解决您的队列查找问题。
非常感谢，我正要回来说我自己也想通了。我认为这可能被认为是客户端中的一个错误-我对其进行了调试，发现它无法使用“::”处理完全限定的队列名称，因为在 ReadOnlyContext 中它假定冒号的存在意味着方案名称（int pos = name.indexOf(':');)。无论如何，我们将远离我们设置队列的方式——我们试图通过使用单个地址来对相关队列进行分组来模拟 WebLogic“JMS 模块”概念，但我认为它实际上并没有感觉。再次感谢！