java - 使用核心 API 连接到 ActiveMQ Artemis Docker 容器

Question

我正在尝试使用 ActiveMQ Artemis Core API 连接到在 Docker 容器中运行的 ActiveMQ Artemis。

我正在使用以下代码来尝试连接。

Map<String,Object> connectionParams = new HashMap<String, Object>();
connectionParams.put(TransportConstants.PORT_PROP_NAME, "61616");
connectionParams.put(TransportConstants.HOST_PROP_NAME, "localhost");


TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(),connectionParams);

ServerLocator locator = ActiveMQClient.createServerLocatorWithoutHA(tc);

ClientSessionFactory queueFactory = locator.createSessionFactory();

运行后，当我尝试创建 session 工厂时，出现以下错误。

ActiveMQNotConnectedException[errorType=NOT_CONNECTED message=AMQ119007:无法连接到服务器。尝试了所有可用的服务器。]

在尝试连接到 ActiveMQ Artemis 代理时，我似乎缺少一个关键的配置步骤。我是否需要将 XML 文件放置在 Java 客户端应用程序中的某个位置，或者我可以在代码中设置正确的设置吗？

我正在使用的 AtiveMQ Artemis 的 Docker 镜像:

https://github.com/vromero/activemq-artemis-docker

Answer 1

也许您忘记通过 -p 61616:61616 公开公开端口