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

Question

在互联网上如此笨拙之后,令人惊讶的是,我找不到使用带有ActiveMQ(Artemis)的WildFly 10中的JMS推送到远程消息队列的示例配置.为了恶化这种情况standalone-full.xml并不局限于一个模式(为什么???),当我最终在GitHub上找到它的XSD时,它不包含任何文档,说明每个节点/属性的含义以及可以放入什么值.

以下是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 Socket。请参阅有关如何执行此操作的文档，即前三个步骤。

这种池化连接工厂的配置分 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],entries=[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 查找。这是解释here。 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

还可以查找尚未在 JNDI 上下文环境中显式配置的 JMS 目标。这可以在查找字符串中使用 dynamicQueues/ 或 dynamicTopics/ 。例如，如果客户端想要查找前面提到的“OrderQueue”，它可以通过使用字符串“dynamicQueues/OrderQueue”来实现。请注意，dynamicQueues/ 或 dynamicTopics/ 后面的文本必须与服务器上的目标名称完全对应。

请阅读有关此的 artemis 配置。

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

但是你必须让自己知道什么最适合你。

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

Answer 2

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

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

这种方法仍然让我有些头疼，但最终我得到了很好的效果。详情请见：

WildFly 10 Artemis 和 ActiveMQ 5.14 之间的 JMS 桥接（ONCE_AND_ONLY_ONCE 服务质量）