从Wildfly Docker容器公开RemoteConnectionFactory

问题描述

我想从客户端向远程ActiveMQ Artemis实例发送一条消息，该实例在docker中运行。我正在使用此docker映像：jboss / wildfly：20.0.1.Final。我通过指定以下属性来运行docker映像：

docker run -d -p 8080:8080 /opt/jboss/wildfly/bin/standalone.sh -c standalone-full.xml -b 0.0.0.0 -bmanagement 0.0.0.0

这是我配置standalone-full.xml的方式：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:10.0">
    <server name="default">
        <security enabled="true"/>
        <security-setting name="#">
            <role name="guest" 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"/>

        <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:jboss/exported/jms/queue/JoeIsCool"/>

        <connection-factory name="InVmConnectionFactory" connectors="in-vm" entries="java:/ConnectionFactory"/>
        <connection-factory name="RemoteConnectionFactory" scheduled-thread-pool-max-size="10" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
        <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="http" port="${jboss.http.port:8080}"/>
    ...
</socket-binding-group>

然后我使用此tutorial中提供的代码尝试将消息发送到JoeIsCool队列：

String MESSAGE = "Hello,World!";
String CONNECTION_FACTORY = "jms/RemoteConnectionFactory";
String DESTINATION = "jms/queue/JoeIsCool";

final String username = "my_username";
final String password = "my_password";

final Properties env = new Properties();
env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jboss.naming.remote.client.InitialContextFactory");
env.put(Context.PROVIDER_URL,"http-remoting://127.0.0.1:8080");
env.put(Context.SECURITY_PRINCIPAL,username);
env.put(Context.SECURITY_CREDENTIALS,password);
final Context namingContext = new InitialContext(env);


ConnectionFactory connectionFactory =
    (ConnectionFactory) namingContext.lookup(CONNECTION_FACTORY);
System.out.println("### Got ConnectionFactory " + CONNECTION_FACTORY);

Destination destination = (Destination) namingContext.lookup(DESTINATION);
System.out.println("### Got JMS Endpoint " + DESTINATION);

// Create the JMS context
final JMSContext context = connectionFactory.createContext(username,password);

context.createProducer().send(destination,MESSAGE);
System.out.println("Sent message " + MESSAGE);

执行此行时，最终的JMSContext context = connectionFactory.createContext（username，password）; ，出现此错误：

javax.jms.JMSException: Failed to create session factory
...
org.apache.activemq.artemis.api.core.ActiveMQNotConnectedException: AMQ219007: Cannot connect to server(s). Tried with all available servers.

在堆栈上，我看到这两个相关的帖子：Required ports for JMS using HornetQ (JBoss) to expose on docker container，javax.jms.JMSException: Failed to create session factory while sending message to embedded ActiveMQ Artemis within JBoss EAP 7.2。作者提到了为什么-b 0.0.0.0引起问题，并且为了解决此问题，必须定义一个公共端点来代替。在我的用例中，我将始终要使用localhost，而不管它在哪台计算机上运行，​​因为docker容器是主机本地的。因此，我进行了以下更改：

<socket-binding name="external" interface="external" port="${jboss.http.port:8080}"/>

<interface name="external">
    <inet-address value="${jboss.bind.address.external:127.0.0.1}"/>
</interface>

<http-connector name="http-connector-external" socket-binding="external" endpoint="http-acceptor"/>

<connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector-external"/>

但是，问题仍然存在。我收到相同的错误，无法使用远程连接工厂发送amq消息。我该如何解决才能解决此问题？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）