☆最近项目需要用到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---是不是根本不需要看第二遍?