Springboot中使用多个AMQ

1.当springboot程序只用一个amq时，只需要在配置文件里面简单配置相关连接项（配置项名字不能改），得益于springboot的自动装配功能，我们不需要写额外的配置类就能在程序里面轻松使用。

2.当springboot程序需要连接多个amq时，就需要手动编写jms的配置类了，这里两个mq（18mq，19mq）

package com.brilliant.ecserver.config;

import org.apache.activemq.ActiveMQConnectionFactory;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jms.config.DefaultJmsListenerContainerFactory;

import org.springframework.jms.config.JmsListenerContainerFactory;

import org.springframework.jms.core.JmsMessagingTemplate;

import javax.jms.ConnectionFactory;

/**

* @ClassName AmpConfig

* @Description ActiveMQ配置类，分别创建2个不同地址的MQ连接

* @Author chengli

* @Date 2021/8/17 14:04

*/

@Configuration

public class AmqConfig {

@Bean(name = "mq19ConnectionFactory")

public ActiveMQConnectionFactory mq19ConnectionFactory(

@Value("${spring.activemq19.broker-url}") String brokerUrl,

@Value("${spring.activemq19.user}") String username,

@Value("${spring.activemq19.password}") String password) {

return createConnectionFactory(brokerUrl, username, password);

}

@Bean(name = "mq19JmsTemplate")

public JmsMessagingTemplate mq19JmsTemplate(

@Qualifier("mq19ConnectionFactory") ActiveMQConnectionFactory connectionFactory) {

JmsMessagingTemplate template = new JmsMessagingTemplate(connectionFactory);

return template;

}

@Bean(name = "mq19JmsListenerContainerFactory")

public JmsListenerContainerFactory mq19JmsListenerContainerFactory(

@Qualifier("mq19ConnectionFactory") ActiveMQConnectionFactory connectionFactory) {

DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();

factory.setPubSubDomain(true);

factory.setConnectionFactory(connectionFactory);

return factory;

}

//========================================================================================

@Bean(name = "mq18ConnectionFactory")

public ActiveMQConnectionFactory mq18ConnectionFactory(

@Value("${spring.activemq18.broker-url}") String brokerUrl,

@Value("${spring.activemq18.user}") String username,

@Value("${spring.activemq18.password}") String password) {

return createConnectionFactory(brokerUrl, username, password);

}

@Bean(name = "mq18JmsTemplate")

public JmsMessagingTemplate mq18JmsTemplate(

@Qualifier("mq18ConnectionFactory") ActiveMQConnectionFactory connectionFactory) {

JmsMessagingTemplate template = new JmsMessagingTemplate(connectionFactory);

return template;

}

@Bean(name = "mq18JmsListenerContainerFactory")

public JmsListenerContainerFactory mq18JmsListenerContainerFactory(

@Qualifier("mq18ConnectionFactory") ConnectionFactory connectionFactory) {

DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();

factory.setPubSubDomain(true);

factory.setConnectionFactory(connectionFactory);

factory.setAutoStartup(true);

return factory;

}

//========================================================================================

/**

* 创建ConnectionFactory

* @param brokerUrl

* @param username

* @param password

* @return

*/

public ActiveMQConnectionFactory createConnectionFactory(String brokerUrl, String username, String password) {

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();

factory.setBrokerURL(brokerUrl);

factory.setUserName(username);

factory.setPassword(password);

return factory;

}

3.创建消费者的时候，注解后面加上containerFactory = "mq18JmsListenerContainerFactory")参数，指定你连接的mq

/**

* 新能源车辆OBD数据

* @param msg

*/

@JmsListener(destination = "${ecserver.MQ_FROM_CLSERVER_VHSTATE}",containerFactory = "mq18JmsListenerContainerFactory")

public void listenVehicle(Message msg) {

vehicleMessageHandler.onMessage(msg);

}

4.生产者的创建在自动注入JmsMessagingTemplate时，实例名写配置类中配置的名字即可mq18JmsTemplate

package com.brilliant.ecserver.amq.publishers;

import org.apache.activemq.command.ActiveMQTopic;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.jms.core.JmsMessagingTemplate;

import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

import javax.jms.Destination;

@Service

public class VehiclePublisher {

@Value("${ecserver.MQ_TO_AVMS_VHSTATE}")

private String topicName;

private Destination destination;

@PostConstruct

void init(){

destination = new ActiveMQTopic(topicName);

}

@Autowired

JmsMessagingTemplate mq18JmsTemplate;

public void sendMessage(String msg) {

mq18JmsTemplate.convertAndSend(destination, msg);

}