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

我在一台服务器上运行着两个Spring Boot" title="Spring Boot">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.

回答:

我有同样的问题,两个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。

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

以上是 如何在Spring Boot中设置ActiveMQ端口? 的全部内容, 来源链接: utcz.com/qa/408731.html

回到顶部