如何在Spring Boot中设置ActiveMQ端口？

Question

我在一台服务器上运行两个Spring Boot应用程序。这两个应用程序都使用嵌入式ActiveMQ JMS。我想为每个应用程序设置单独的JMS实例。如何为它们中的每一个设置端口？是否有类似于spring.activemq.port的属性？ 当我运行第二个应用程序时，我收到以下预期的错误：

Failed to start JMX connector Cannot bind to URL [rmi://localhost:1099/jmxrmi]: javax.naming.NameAlreadyBoundException: jmxrmi [Root exception is java.rmi.AlreadyBoundException: jmxrmi]. Will restart management to re-create JMX connector, trying to remedy this issue.

- Igorock

Answer 1

我有同样的问题，有两个SpringBoot进程，我想通过ActiveMQ发送消息。 首先，我启动了另一个带有ActiveMQ的进程，并在它们各自的application.properties文件中进行配置，使得两个SpringBoot进程都可以正常工作。

spring.activemq.broker-url = tcp://localhost:61616

通过这个配置，你告诉Springboot连接到一个外部的ActiveMq服务。这个方法可以使用，但是需要在Springboot进程之前启动ActiveMQ。在某些页面上我读到，这必须是在生产环境中使用的方式。

另一种解决方案是在SpringBoot进程中使用嵌入式JMS支持，为此你需要配置ActiveMQ代理服务以便在一个Springboot进程中监听连接。你可以添加一个Broker bean来实现这一点：

@Bean
public BrokerService broker() throws Exception {
    final BrokerService broker = new BrokerService();
    broker.addConnector("tcp://localhost:61616");
    broker.addConnector("vm://localhost");
    broker.setPersistent(false);
    return broker;
}

现在，使用这个bean的SpringBoot进程不需要之前在application.properties中进行的配置，这将是第一个启动的进程，以便让ActiveMQ监听其他进程的连接。

其他Springboot进程仍然需要在application.properties中进行配置，以便连接到由第一个进程创建的ActiveMq。

希望对您有所帮助。 最好的问候。

- Eidansoft

Answer 2

您可以使用spring.activemq.broker-url属性配置代理URL，例如将其设置为spring.activemq.broker-url=tcp://localhost:61616。

有关可用属性的全面参考，请查看此参考文献。

- gtonic

---

当我执行此操作时，出现以下错误：无法连接到代理URL：tcp://localhost:61616。原因：java.net.ConnectException：连接被拒绝：连接 - Igorock

我认为这个属性用于设置远程JMS，而不是更改嵌入式的URL。 - Igorock

你能提供每个应用程序所使用的设置吗？有几个端口可能会发生冲突。 - gtonic

在 application.properties 文件中，我只为第一个服务器设置了 server.port=8091，而第二个服务器设置了 server.port=8093。 - Igorock

Answer 3

spring.activemq.broker-url

包括端口，根据spring boot properties的属性

- rob