当前位置: 首页 > 网络应用技术

兔子消息队列延迟队列和死信队列

时间:2023-03-07 13:34:44 网络应用技术

  如果您不熟悉RabbitMQ,本文将介绍图形接口的兔子基本方法以及延迟队列和死字母队列的实现方法。

  如果您需要代码实施,请参考:[Java代码](https://gitee.com/xuejianxinokok/springboot2/tree/master/master/rabbitmq

  安装完成后,最好将起始类型修改为手册

  打开RabbitMQ输入的控制台:启用管理插头-in

  RabbitMQ-Plugins启用RabbitMQ_MANAGEMATION

  打开http://127.0.0.0.1:15672/

  超级管理员帐户和密码是:访客

  交换和队列建立一个约束关系。Exchange在队列中分布所有与之具有约束力关系的队列。十个队列必定会将消息分配以进行分发。

  创建2个队列以接收粉丝消息

  创建一个开关

  创建绑定关系

  最终绑定关系

  然后检查是否在队列中收到消息

  查看消息

  您可以看到消息的特定内容

  准备消息并将其发送到名为SendService的直接开关。此开关主要用于发送服务,因此它绑定了两个队列,SMS队列和邮件队列发送短信和电子邮件。或邮件)。RoutingKey对应于最终发送的队列。将交给SMS队列

  创建队列邮报和Smsqueue

  创建一个开关

  与队列设置绑定关系

  发送短信消息

  发送邮件

  测试消费者消息与粉丝相同

  *:可以模糊这个词。

  由于添加了两个-type定义符号,因此主题开关的RoutingKey也有所改变。RutingKey可以使用它。单独的单词。

  创建一个开关

  https://www.rabbitmq.com/community-plugins.html版本太旧且不可用,不能支持3.8.14

  https://www.rapbitmq.com/priority.html支持优先队列

  channel ch = ... ;;

  地图 args =新的哈希玛普();args.put(“ x-max-priority”,10);ch.queuedeclare(“ my-priority-queue”,是的,错误,false,args);延迟10s

  单独设置消息ttl,以便添加消息以添加普通的队列测试

  参考文档:

  https://mp.weixin.qq.com/s/szrsuiqsirxciket98ez2whttps://mp.weixin.qq.com/s/iigkqrmks9rbztpnhzicjg

  https://gitee.com/he--erduo/spring-loot-rearning-demo/tree/master

  相关文章:尚未使用消息队列?一篇文章需要您体验兔子相关的文章:经历经历后的兔子?一篇文章带您带Springboot+RabbitMQ发送和接收与消息相关的文章:我开始使用RabbitMQ?让我们开始使用。查看其开关(交换)相关文章:RabbitMQ高级保证消息可靠性如何?相关文章:RabbitMQ高级新闻限制和延迟队列

  

  原始:https://juejin.cn/post/7095299294629986340

猜你喜欢