SpringBoot整合RabbitMQ实战---一遍就懂

 ☆最近项目需要用到MQ,博主还真的没有在实际应用中使用过MQ。这次刚好实践并记录下
PS:关于MQ的一些概念和简介博主在这里就不去赘述了
第一步:添加依赖
1 <!--RabbitMQ依赖-->
2 <dependency>
3     <groupId>org.springframework.boot</groupId>
4     <artifactId>spring-boot-starter-amqp</artifactId>
5 </dependency>

第二步:RabbitTemplate rabbitTemplate;

1 @Autowired
2 RabbitTemplate rabbitTemplate;

第三步:将消息添加到MQ中

1 /将所有的请求到放到MQ中
2 rabbitTemplate.convertAndSend(RabbitMQExchangeQueueConfig.getRabbitmq_direct_exchange(), RabbitMQExchangeQueueConfig.getRabbitmq_routing_key(), urlPath);

第四步:从MQ中消费消息

1 //从队列中取值
2 abbitTemplate.receiveAndConvert(RabbitMQExchangeQueueConfig.getRabbitmq_routing_key());

OVER---是不是根本不需要看第二遍?

原文地址:https://www.cnblogs.com/zyzblogs/p/11338279.html