Spring boot Artemis 嵌入式代理行为

Question

早上好，

我最近一直在努力使用 spring-boot-artemis-starter。 我对其 spring-boot 支持的理解如下：

• 设置spring.artemis.mode=embedded 和tomcat 一样，spring-boot 将实例化一个可通过tcp（服务器模式）访问的代理。以下命令应该成功：nc -zv localhost 61616
• 设置spring.artmis.mode=native，spring-boot只会根据spring.artemis.*属性（客户端模式）配置jms模板。

客户端模式与我机器上的独立 artemis 服务器一起工作得很好。 不幸的是，我无法在服务器模式下访问 tcp 端口。

如果有人确认我对嵌入式模式的理解，我将不胜感激。

感谢您的游览帮助

经过一番挖掘，我注意到 spring-boot-starter-artemis 提供的开箱即用的实现使用org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory 接受器。我想知道这是否不是根本原因（同样我绝不是专家）。 但似乎有一种方法可以自定义 artemis 配置。 因此，我尝试了以下配置，但没有任何运气：

@SpringBootApplication
public class MyBroker {

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

    @Autowired
    private ArtemisProperties artemisProperties;

    @Bean
    public ArtemisConfigurationCustomizer artemisConfigurationCustomizer() {
        return configuration -> {
            try {
               configuration.addAcceptorConfiguration("netty", "tcp://localhost:" + artemisProperties.getPort());
            } catch (Exception e) {
                throw new RuntimeException("Failed to add netty transport acceptor to artemis instance");
            }
        };
    }

}

Answer 1

您只需在 Artemis 配置中添加一个连接器和一个接受器。使用 Spring Boot Artemis 启动器，Spring 创建了一个配置 bean，它将用于 EmbeddedJMS 配置。您可以在 ArtemisEmbeddedConfigurationFactory 类中看到这一点，其中将为配置设置 InVMAcceptorFactory。您可以编辑此 bean 并通过自定义 ArtemisConfigurationCustomizer bean 更改 Artemis 行为，该 bean 将被 Spring autoconfig 吸收并应用于配置。

Spring Boot 应用程序的示例配置类：

import org.apache.activemq.artemis.api.core.TransportConfiguration;
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory;
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnectorFactory;
import org.springframework.boot.autoconfigure.jms.artemis.ArtemisConfigurationCustomizer;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ArtemisConfig implements ArtemisConfigurationCustomizer {
    @Override
    public void customize(org.apache.activemq.artemis.core.config.Configuration configuration) {
        configuration.addConnectorConfiguration("nettyConnector", new TransportConfiguration(NettyConnectorFactory.class.getName()));
        configuration.addAcceptorConfiguration(new TransportConfiguration(NettyAcceptorFactory.class.getName()));
    }
}

Answer 2

我和我的同事遇到了与 this link (chapter Artemis Support) 上的文档完全相同的问题，没有提及添加单独的 ArtemisConfigurationCustomizer - 这很可悲，因为我们意识到如果没有这个定制器，我们的 Spring Boot 应用程序将启动并表现得好像一切正​​常但实际上它不会做任何事情。

我们还意识到，如果没有定制器，application.properties 文件将不会被加载，因此无论您在此处提到的主机或端口是什么，它都不会计算在内。

按照两个示例所述添加定制器后，它可以正常工作。

以下是我们得出的一些结果：

• 仅在配置 ArtemisConfigurationCustomizer 后才加载 application.properties

• 您不再需要使用嵌入式 Spring Boot Artemis 客户端的 broker.xml

• 许多使用 Artemis 的示例使用“in-vm”协议，而我们只想使用 netty tcp 协议，因此我们需要将其添加到配置中

• 对我来说最重要的参数是 pub-sub-domain，因为我使用的是主题而不是队列。如果您使用主题，则需要将此参数设置为 true，否则 JMSListener 将不会读取消息。

查看此页面：stackoverflow jmslistener-usage-for-publish-subscribe-topic

当使用 @JmsListener 时，它使用 DefaultMessageListenerContainer 它扩展了 JmsDestinationAccessor 默认情况下具有 pubSubDomain 设置为 false。当此属性为 false 时 在队列上操作。如果你想使用主题，你必须设置这个 属性值为 true。

In Application.properties:
spring.jms.pub-sub-domain=true

如果有人对完整示例感兴趣，我已将其上传到我的 github： https://github.com/CorDharel/SpringBootArtemisServerExample

Answer 3

嵌入模式将代理作为应用程序的一部分启动。这种设置没有可用的网络协议，只允许 InVM 调用。自动配置exposes the necessary pieces you can tune 虽然我不确定你是否真的可以在嵌入式模式下拥有一个 TCP/IP 通道。