使用 ActiveMQ Artemis 发送 AMQ 消息

Question

我想向 WildFly 服务器上的 ActiveMQ Artemis 实例发送消息。我正在使用 this tutorial in trying to configure the standalone-full.xml. I am using the jboss/wildfly docker 图像并公开以下网络端口：5445.

独立配置：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:10.0">
    <server name="default">
        <security enabled="true"/>
        <security-setting name="#">
            <role name="SuperUser" 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" redistribution-delay="1000"/>
        <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"/>
        <remote-connector name="netty" socket-binding="messaging"/>
        <remote-acceptor name="netty" socket-binding="messaging"/>

        <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"/>
        <jms-queue name="JoeIsCool" entries="java:/jms/queue/JoeIsCool"/>

        <connection-factory name="InVmConnectionFactory" connectors="in-vm" entries="java:/ConnectionFactory"/>
        <connection-factory name="RemoteConnectionFactory" ha="true" block-on-acknowledge="true" reconnect-attempts="-1" connectors="netty" entries="java:jboss/exported/jms/RemoteConnectionFactory"/>
        <pooled-connection-factory name="activemq-ra" transaction="xa" connectors="in-vm" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory"/>
    </server>
</subsystem>


<socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:0}">

    ...
    <socket-binding name="messaging" port="5445"/>
    ...

</socket-binding-group>

我尝试创建一个简单的测试用例来向 ActiveMQ Artemis 实例发送消息：

public void sendAmqMessage() throws Exception {
    final ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "secretPassoword", "tcp://localhost:5445");
    final Connection connection = connectionFactory.createConnection();
    connection.start();
    final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    final Destination destination = session.createQueue("JoeIsCool");
    final MessageProducer producer = session.createProducer(destination);
    final TextMessage message =
    session.createTextMessage("Hello !!! Welcome to the world of ActiveMQ.");
    producer.send(message);
    connection.close();
}

执行后，我的客户端出现此错误：

javax.jms.JMSException: Cannot send, channel has already failed: tcp://127.0.0.1:5445

我在我的服务器上收到此错误：

(Thread-1 (activemq-netty-threads)) AMQ214013: Failed to decode packet: java.lang.IllegalArgumentException: AMQ219032: Invalid type: 1

我试图按照回答我自己的问题，但未能找到有用的解决方案。

我在配置 ActiveMQ 实例时遗漏了什么，我如何用 Java 代码测试它？

Answer 1

在您的 sendAmqMessage 方法中，您正在创建一个 javax.jms.ConnectionFactory 实例，如下所示：

final ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "secretPassoword", "tcp://localhost:5445");

此 ActiveMQConnectionFactory 来自 ActiveMQ 5.x 客户端并使用您的 standalone-full.xml 中的 remote-acceptor 不理解的 OpenWire 协议，因此出现有关失败的错误解码传入的备份。

正如您所遵循的 the documentation 所建议的那样，与其直接实例化 ConnectionFactory，不如像这样在 JNDI 中简单地查找它：

final Properties env = new Properties();
env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");
env.put(Context.PROVIDER_URL, "http-remoting://localhost:8080");
InitialContext remotingCtx = new InitialContext(env);
final ConnectionFactory connectionFactory = (ConnectionFactory) remotingCtx.lookup("jms/RemoteConnectionFactory");

此外，请确保您使用的是正确的依赖项，即：

<dependencies>
  <dependency>
    <groupId>org.wildfly</groupId>
    <artifactId>wildfly-jms-client-bom</artifactId>
    <type>pom</type>
  </dependency>
</dependencies>

以这种方式使用 JNDI 还可以让您从 standalone-full.xml:

中删除它

<remote-connector name="netty" socket-binding="messaging"/>
<remote-acceptor name="netty" socket-binding="messaging"/>

还有这个：

<socket-binding name="messaging" port="5445"/>

您真的只需要默认 standalone-full.xml 中定义的资源。

使用 ActiveMQ Artemis 发送 AMQ 消息

Send AMQ Message using ActiveMQ Artemis

java

jboss-arquillian

wildfly

activemq-artemis