spring整合rabbitmq使用XML

spring整合rabbitmq使用XML

因为公司老旧框架需要使用rabbitmq，但是因为业务逻辑复杂升级springboot难度大，时间不够只能使用xml方式引入rabbitmq

首先引入jar

  	<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.4.3</version></dependency><dependency><groupId>org.springframework.amqp</groupId><artifactId>spring-rabbit</artifactId><version>2.1.8.RELEASE</version></dependency><dependency><groupId>org.springframework.amqp</groupId><artifactId>spring-amqp</artifactId><version>2.1.8.RELEASE</version></dependency>

spring使用的版本是5.1.9.RELEASE

创建xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns=""xmlns:xsi=""xmlns:rabbit=""xsi:schemaLocation=" .0.xsd .xsd"><!-- 定义连接工厂 --><rabbit:connection-factory id="connectionFactory" virtual-host="#{rabbitmq.rabbitmq_virtual}"host="#{rabbitmq.rabbitmq_host}" port="#{rabbitmq.rabbitmq_port}" username="#{rabbitmq.rabbitmq_username}" password="#{rabbitmq.rabbitmq_password}" /><rabbit:admin connection-factory="connectionFactory" /><!-- 序列化mq数据   <bean id="jsonMessageConverter" class="org.springframework.verter.Jackson2JsonMessageConverter" /><rabbit:template id="rabbitTemplate" connection-factory="connectionFactory" message-converter="jsonMessageConverter"/>--><rabbit:template id="rabbitTemplate" connection-factory="connectionFactory"/><!-- 定义交换机绑定队列（路由模式）使用匹配符
<rabbit:topic-exchange  id="tspTboxExchange" name="tspTboxExchange"><rabbit:bindings><rabbit:binding queue="tspTboxBQueue" pattern="#" /></rabbit:bindings>
</rabbit:topic-exchange>
--><!-- 定义消费者 --><bean id="TspConsumer" class="com.dayunmotor.tbox.gateway.business.mq.TspConsumer" /><!-- 定义队列 --><rabbit:queue  name="tspTboxBQueue" auto-declare="true" durable="true" /><!-- 定义消费者监听队列 --><rabbit:listener-containerconnection-factory="connectionFactory"><rabbit:listener ref="TspConsumer" queues="tspTboxBQueue" /></rabbit:listener-container>
</beans>

本文未写全xml配置，如需要可以进xsd文件查看

创建消费者

@Component
public class TspConsumer implements MessageListener {private TspMQController tspMQController;//接收消息@Overridepublic void onMessage(Message message) {String body="";try{body=new Body(),"utf-8");log.info("接收到消息：{}",body);tspMQController.processMQ(body);}catch(Exception e){("执行失败");}}@Autowiredpublic void setTspMQController(TspMQController tspMQController) {this.tspMQController = tspMQController;}
}

也可以实现ChannelAwareMessageListener接口

创建生产者

@Component
public class RabbitMqProducer {private static final Logger logger= Logger(RabbitMqProducer.class);private RabbitTemplate rabbitTemplate;@Autowiredpublic void setRabbitTemplate(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}//发送消息public void sendMessage(String exchangeKey,String routingkey,Object message){logger.info("exchangeKey{} routingkey{}to send message:{}",exchangeKey,routingkey,message);vertAndSend(exchangeKey,routingkey,message);}
}

然后启动就可以实现消费和发送消息了。
启动rabbitmq监听器可以阻塞主线程一直监听数据；
本人经多次验证无法使用注解版接收mq消息，故放弃使用注解版；