spring boot配置多个ActiveMQ实例

我需要将消息从一个ActiveMQ实例上的队列移动到另一个ActiveMQ实例.有没有办法使用spring boot配置连接到两个不同的ActiveMQ实例？

我需要创建多个connectionFactories吗？如果是这样,那么jmstemplate如何知道连接哪个ActiveMQ实例？

  @Bean
    public ConnectionFactory connectionFactory() {
        return new ActiveMQConnectionFactory(JMS_broKER_URL);
    }

任何帮助和代码示例都很有用.

提前致谢.
GM

最佳答案

除了@Chris的回应
您必须使用不同的端口创建不同的brokerService实例,并创建不同的ConnectionFactory以连接到每个代理,并使用这些不同的工厂创建不同的jmstemplate,以将消息发送到不同的代理.

例如：

import javax.jms.ConnectionFactory;
import javax.jms.QueueConnectionFactory;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.brokerService;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;
import org.springframework.jms.core.jmstemplate;

@Configuration
public class ActiveMQConfigurationForJmsCamelRouteConsumeAndForward {
    public static final String LOCAL_Q = "localQ";
    public static final String REMOTE_Q = "remoteQ";

    @Bean
    public brokerService broker() throws Exception {
        final brokerService broker = new brokerService();
        broker.addConnector("tcp://localhost:5671");
        broker.setbrokerName("broker");
        broker.setUseJmx(false);
        return broker;
    }

    @Bean
    public brokerService broker2() throws Exception {
        final brokerService broker = new brokerService();
        broker.addConnector("tcp://localhost:5672");
        broker.setbrokerName("broker2");
        broker.setUseJmx(false);
        return broker;
    }

    @Bean
    @Primary
    public ConnectionFactory jmsConnectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:5671");
        return connectionFactory;
    }

    @Bean
    public QueueConnectionFactory jmsConnectionFactory2() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:5672");
        return connectionFactory;
    }

    @Bean
    @Primary
    public jmstemplate jmstemplate() {
        jmstemplate jmstemplate = new jmstemplate();
        jmstemplate.setConnectionFactory(jmsConnectionFactory());
        jmstemplate.setDefaultDestinationName(LOCAL_Q);
        return jmstemplate;
    }

    @Bean
    public jmstemplate jmstemplate2() {
        jmstemplate jmstemplate = new jmstemplate();
        jmstemplate.setConnectionFactory(jmsConnectionFactory2());
        jmstemplate.setDefaultDestinationName(REMOTE_Q);
        return jmstemplate;
    }

    @Bean
    public JmsListenerContainerFactoryfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        configurer.configure(factory,connectionFactory);
        return factory;
    }

    @Bean
    public JmsListenerContainerFactory


要将消息从一个AMQ实例移动到另一个实例,您可以使用JmsBridgeConnectors：
请注意,通过下面的示例,您不能在要从中转发消息的队列上拥有多个使用者,因为Camel或JmsBridgeConnectors会使用该消息并转发它.如果您只想转发邮件的副本,则可以使用以下解决方案：
1-将队列转换为主题,由持久订阅或追溯使用者管理脱机使用者的消息.
2-将队列转换为复合队列,并使用DestinationsInterceptors将消息复制到另一个队列.
3-使用NetworkConnector for Networkof代理

@Bean
public brokerService broker() throws Exception {
    final brokerService broker = new brokerService();
    broker.addConnector("tcp://localhost:5671");
    SimpleJmsQueueConnector simpleJmsQueueConnector = new SimpleJmsQueueConnector();
    OutboundQueueBridge bridge = new OutboundQueueBridge();
    bridge.setLocalQueueName(LOCAL_Q);
    bridge.setoutboundQueueName(REMOTE_Q);
    OutboundQueueBridge[] outboundQueueBridges = new OutboundQueueBridge[] { bridge };
    simpleJmsQueueConnector.getReconnectionPolicy().setMaxSendRetries(ReconnectionPolicy.INFINITE);
    simpleJmsQueueConnector.setoutboundQueueBridges(outboundQueueBridges);
    simpleJmsQueueConnector.setLocalQueueConnectionFactory((QueueConnectionFactory) jmsConnectionFactory());
    simpleJmsQueueConnector.setoutboundQueueConnectionFactory(jmsConnectionFactory2());
    JmsConnector[] jmsConnectors = new JmsConnector[] { simpleJmsQueueConnector };
    broker.setJmsBridgeConnectors(jmsConnectors);
    broker.setbrokerName("broker");
    broker.setUseJmx(false);
    return broker;
}

或者像下面这样使用Camel：

@Bean
public CamelContext camelContext() throws Exception {
    CamelContext context = new DefaultCamelContext();
    context.addComponent("inboundQueue",ActiveMQComponent.activeMQComponent("tcp://localhost:5671"));
    context.addComponent("outboundQueue",ActiveMQComponent.activeMQComponent("tcp://localhost:5672"));
    context.addRoutes(new RouteBuilder() {
        public void configure() {
            from("inboundQueue:queue:" + LOCAL_Q).to("outboundQueue:queue:" + REMOTE_Q);
        }
    });
    context.start();
    return context;
}

你的制作人必须像这样使用不同的jmstemplates：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.CommandLineRunner;
import org.springframework.jms.core.jmstemplate;
import org.springframework.stereotype.Component;

@Component
public class Producer implements CommandLineRunner {

    @Autowired
    private jmstemplate jmstemplate;

    @Autowired
    @Qualifier("jmstemplate2")
    private jmstemplate jmstemplate2;

    @Override
    public void run(String... args) throws Exception {
        send("Sample message");
    }

    public void send(String msg) {
        this.jmstemplate.convertAndSend(ActiveMQConfigurationForJmsCamelRouteConsumeAndForward.LOCAL_Q,msg);
        this.jmstemplate2.convertAndSend(ActiveMQConfigurationForJmsCamelRouteConsumeAndForward.REMOTE_Q,msg);
    }
}

和消费者：

import javax.jms.Session;

import org.apache.activemq.ActiveMQSession;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer {

    @JmsListener(destination = ActiveMQConfigurationForJmsCamelRouteConsumeAndForward.REMOTE_Q,containerFactory = "jmsListenerContainerFactory2")
    public void receiveQueue(Session session,String text) {
        System.out.println(((ActiveMQSession) session).getConnection().getbrokerInfo());
        System.out.println(text);
    }
}



                
                                原文地址：https://www.jb51.cc/spring/432547.html
                                 版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

spring boot配置多个ActiveMQ实例

相关推荐