java - Spring Boot 和 ActiveMQ : Ignores broker-url and uses default localhost:61616

Question

我正在使用 Spring Boot 和 ActiveMQ。在 application.properties 中，我设置了 activemq 的 url，如下所示:

spring.activemq.broker-url=vm://localhost?broker.persistent=false

如您所见，我正在使用嵌入式代理(在 pom 中添加依赖项)。这是我的应用程序类:

@SpringBootApplication
@EntityScan(
    basePackageClasses = {ServiceApplication.class, Jsr310JpaConverters.class}
)
@EnableAutoConfiguration
@ServletComponentScan
public class ServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceApplication.class, args);
    }

}

这些是pom中与activemq相关的依赖项:

<dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-camel</artifactId>
        <version>5.14.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-pool</artifactId>
        <version>5.14.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-broker</artifactId>
        <version>5.14.5</version>
    </dependency>

我有一个 application.properties，我没有不同的配置文件。

但是当我运行应用程序时，我收到以下日志:

[ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport       : Failed to connect to [tcp://localhost:61616] after: 10 attempt(s) continuing to retry.

它正在尝试连接到 tcp://localhost:61616，即使这不是我定义的 URL。

我尝试删除@EnableAutoConfiguration，但仍然存在同样的问题。

我该如何解决这个问题？

Answer 1

您的 ActiveMQ 客户端不知道 spring.activemq.broker-url 因为此属性用于配置 spring-boot-starter-activemq。如果您没有此启动器 - 您无需配置任何内容具有此属性。

我建议您阅读以下资源，以更好地了解如何在项目中设置 spring-boot-starter-activemq:

• https://spring.io/guides/gs/messaging-jms/
• https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-messaging.html

希望对你有帮助!