java - 如何将 ActiveMQ 生产者连接到 OpenMQ JMS 代理

Question

我正在尝试从一个 swing 重型客户端(使用 Apache ActiveMQ 库)发送文本消息到一个似乎使用 OpenMQ 作为默认 JMS 提供程序的 glassfish 服务器实例。

在我为我的客户使用的基本源代码下面:

try {
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("jms/SaisieQueueFactory");
    connectionFactory.setBrokerURL("tcp://localhost:27676");
    Connection connection = connectionFactory.createConnection();
    connection.start();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Destination destination = session.createQueue("jms/SaisieQueue");
    MessageProducer producer = session.createProducer(destination);
    producer.setDeliveryMode(DeliveryMode.PERSISTENT);
    TextMessage message = session.createTextMessage("Score + 1");
    producer.send(message);
    session.close();
    connection.close();
} catch(Exception ex) {
    ex.printStackTrace();
}

• 我在 Glassfish 服务器管理控制台的系统属性中找到代理端口 (JMS_PROVIDER_PORT)
• 队列连接工厂和队列已在我部署 MessageDrivenBean 时创建
• 目前客户端和 glassfish 实例在同一台计算机上运行，​​但我想让它们在两台不同的计算机上运行(这就是我不使用 vm://作为传输协议(protocol)的原因)

我得到了这些异常(exception):

javax.jms.JMSException: Cannot send, channel has already failed: tcp://127.0.0.1:7676
    at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1395)
    at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1481)
    at org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:516)
    at testdate.TestDate.main(TestDate.java:44)
Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: tcp://127.0.0.1:7676
    at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:282)
    at org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:271)
    at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
    at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
    at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
    at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
    at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1366)
    ... 3 more

• 我考虑过将我的 Glassfish 实例的 JMS 提供程序更改为 ActiveMQ 的解决方案，但如果可能的话，我想保留 OpenMQ

PS:我是 JMS 和 Java EE 框架的初学者

Answer 1

JMS API 定义了一个 java 接口(interface)和一个消息传递架构，它没有定义任何特定的有线协议(protocol)，它可以是信鸽、内存或任何常见格式(STOMP、OpenWire、AMQP、MQTT)。

为什么不能在客户端中使用 Open MQ 库？这就是 JMS 的设计方式。您只需从 .jar 文件切换并更改 ConnectionFactory。

我看不出有任何理由仅仅为了使用 ActiveMQ JMS 客户端而切换到 ActiveMQ，因为它应该与 Open MQ 客户端几乎相同。虽然还有其他切换的原因，例如不同的服务器端功能等等，但您没有提到这一点。

也就是说，有一个桥接组件能够通过 STOMP 协议(protocol)(​​ActiveMQ 支持)公开任何 JMS 服务器。

它叫做 Stomp Connect还有一些rather old instructions在 OpenMQ 页面如何使用它。

从那里，您应该能够连接到指定 STOMP 的 ActiveMQConnection 工厂。但我自己并没有真正尝试过这种组合。