Spring boot Artemis嵌入式代理行为

Question

早上好，

null

感谢您对旅游的帮助

经过深入研究，我注意到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 starter，Spring创建一个配置bean，用于EmbeddedJMS配置。您可以在ArtemisEmbeddedConfigurationFactory类中看到这一点，其中将为配置设置InvmAcceptorFactor。您可以编辑这个bean并通过自定义ArtemisConfigurationCustomizerbean更改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()));
    }
}