如何在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.

Answer 1

我有同样的问题，两个SpringBoot进程，我想通过ActiveMQ发送消息。首先，我开始使用ActiveMQ启动另一个进程，并使用以下命令将两个SpringBoot进程配置到它们的application.properties文件中：

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

通过这种配置，您告诉Springboot连接到外部ActiveMq服务。这行得通，但随后我需要先启动ActiveMQ并在Springboot过程之后。在某些页面中，我读到了这一定是在生产环境中使用的方式。

另一种解决方案是在一个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。

希望对您有帮助。最好的祝福。