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

相关文章:

  • 2021-05-10
  • 2021-09-03
  • 2021-07-16
  • 2021-10-24
  • 2021-11-13
  • 2021-04-04
  • 2021-09-13
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-06-24
  • 2021-08-30
  • 2021-10-11
相关资源
相似解决方案