小编典典

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

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.

阅读 453

收藏
2020-05-30

共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。

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

2020-05-30