如何将 JMS 消息从 WildFly 10 发送到远程 ActiveMQ

Question

在互联网上摸索了这么多之后，令人惊讶的是，我找不到使用带有 ActiveMQ (Artemis) 的 WildFly 10 中的 JMS 推送到远程消息队列的示例配置。更糟糕的是standalone-full.xml 没有绑定到模式（为什么？？？），当我最终找到它的 XSD here on GitHub 时，它没有包含说明每个节点/属性的含义以及可以放入哪些值的文档什么。

下面是standalone-full.xml的原始配置。

    <subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
      <server name="default">
        <security-setting name="#">
          <role name="guest" delete-non-durable-queue="true" create-non-durable-queue="true" consume="true" send="true"/>
        </security-setting>
        <address-setting name="#" message-counter-history-day-limit="10" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
        <http-connector name="http-connector" endpoint="http-acceptor" socket-binding="http"/>
        <http-connector name="http-connector-throughput" endpoint="http-acceptor-throughput" socket-binding="http">
          <param name="batch-delay" value="50"/>
        </http-connector>
        <in-vm-connector name="in-vm" server-id="0"/>
        <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"/>
        <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
        <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
        <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" transaction="xa" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm"/>
      </server>
    </subsystem>

下面是我的 CDI 队列客户端，它能够将消息发布到 WildFly 中的本地 Artemis 实例。

@ApplicationScoped
public class QueueClient {

  private static final Gson GSON = new Gson();

  @Resource(mappedName = "java:jboss/DefaultJMSConnectionFactory")
  private ConnectionFactory connectionFactory;

  public void sendMessage(String destinationName, Object message) throws JMSException {
    try (Connection conn = connectionFactory.createConnection();
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)) {

      Queue queue = session.createQueue(destinationName);
      final Message consignment = session.createMessage();
      consignment.setStringProperty("MEDIA_TYPE", "application/json");
      consignment.setStringProperty("BODY", GSON.toJson(message));
      session.createProducer(queue).send(consignment);
    }
  }
}

我的目标：将消息发布到远程 ActiveMQ 实例。

我有什么：server url、topic name、username 和 password。

我的问题：如何修改配置来实现这个目标？

另类问题：如果以上都不能回答，我还有什么方法可以实现这个目标？

谢谢！

Answer 1

您是否检查过以下文档。

https://docs.jboss.org/author/display/WFLY10/Connect+a+pooled-connection-factory+to+a+Remote+Artemis+Server

它可能解决了您当前的问题。

谢谢。

编辑：对这篇文章的负面标记。

正如上面列出的文档清楚地描述的那样。 您需要创建一个使用远程连接器的池连接工厂，并且远程连接器引用远程 Active MQ 服务器的 IP x 套接字。 请参阅有关如何执行此操作的文档，前三个步骤。

这样一个pooled-connection-factory的配置分3步完成，我引用：

1. 创建一个指向远程消息服务器的出站套接字绑定： /socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=remote-artemis:add(host=, port=61616)

2. 创建一个远程连接器，引用在步骤 (1) 中创建的出站套接字绑定。 /subsystem=messaging-activemq/server=default/remote-connector=remote-artemis:add(socket-binding=remote-artemis)

3. 创建一个池连接工厂，引用在步骤 (2) 中创建的远程连接器。 /subsystem=messaging-activemq/server=default/pooled-connection-factory=remote-artemis:add(connectors=[remote-artemis], 条目=[java:/jms/remoteCF])

最后，一旦正确配置了池连接工厂，就可以将其用作 JEE 容器可用的任何 JNDI 资源。 只需将池连接工厂注入您的 bean 并使用它来创建会话。

这里有一个关于如何将 JMS 消息发送到服务器的示例。 在您的情况下，只需将连接工厂 JNDI 引用修复到与远程活动 MQ 关联的池连接工厂。

http://www.mastertheboss.com/jboss-server/jboss-jms/sending-jms-messages-over-xa-with-wildfly-jboss-as

我引用：

@Stateless
public class JMSService {


    @Resource(mappedName = "java:jboss/jms/queue/exampleQueue")
    private Queue queueExample;

    @Resource(mappedName = "java:/JmsXA")
    private ConnectionFactory cf;

    private Connection connection;
    private MessageProducer publisher;
    private Session session;

    @TransactionAttribute(TransactionAttributeType.REQUIRED)
    public void sendMessage(String txt) {

        try {         

            connection = cf.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            publisher = session.createProducer(queueExample);

            connection.start();

            TextMessage message = session.createTextMessage(txt);
            publisher.send(message);


        }
        catch (Exception exc) {
            exc.printStackTrace();
        }
        finally {         

          if (publisher != null) try { publisher.close(); } catch (Exception ignore) { }
          if (session != null) try { session.close(); } catch (Exception ignore) { }
          if (connection != null) try { connection.close(); } catch (Exception ignore) { }


         }
    } 
}

在这种情况下，您的连接工厂应该：

@Inject

    @JMSConnectionFactory("java:/jms/remoteCF")

    private JMSContext context;

您需要注意的另一件事是，您要注入 bean 的队列是远程队列。 访问远程队列的方法是在远程活动 MQ 服务器上执行 JNDI 查找。 这在这里解释。 http://activemq.apache.org/artemis/docs/1.1.0/using-jms.html#jndi-configuration

我引用文档中有趣的部分开始。如果您继续阅读，您会看到如何使用 JNDI 初始上下文来查找 artemis 队列。

如果客户端想将此队列绑定到“queues/OrderQueue” 那么 JNDI 属性将像这样配置：

java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory java.naming.provider.url=tcp://myhost:5445 queue.queues/OrderQueue=OrderQueue

还可以查找尚未访问过的 JMS 目的地 在 JNDI 上下文环境中显式配置。这是 可以在查找字符串中使用 dynamicQueues/ 或 dynamicTopics/。 例如，如果客户想要查找上述 “OrderQueue” 它可以简单地通过使用字符串来做到这一点 “动态队列/订单队列”。请注意，dynamicQueues/ 后面的文本 或 dynamicTopics/ 必须与 服务器上的目的地。

请仔细阅读有关此的 artemis 配置。

最后，您可以尝试探索另一种方法。 这些是 JMS 队列桥。 你太谷歌了。 但本质上，JMS 网桥可以允许队列的内容通过隧道传输到远程队列。 因此，这种桥接机制应该使您可以像针对本地 artemis JMS 服务器一样对代码进行编程，但是所有队列都被桥接，正在读取或发布的数据实际上来自或去往远程服务器。

但你必须了解自己，看看什么最适合你。

我真诚地希望这会有所帮助。

Answer 2

本周我一直在努力解决一个非常相似的问题。由于我的架构，我选择了一种您可能会觉得有用的替代方法：

继续向本地 Artemis 代理发送消息，但在 Artemis 代理和远程 ActiveMQ 代理之间配置 JMS 桥。

这种方法仍然让我有些头疼，但最后我让它运行良好。详情在：

JMS Bridge Between WildFly 10 Artemis and ActiveMQ 5.14 (ONCE_AND_ONLY_ONCE Quality of Service)