如何在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来做到这一点:
@Beanpublic 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