首页 > 其他分享 >RabbitMQ入门学习系列(五) Exchange的Direct类型

RabbitMQ入门学习系列(五) Exchange的Direct类型

时间:2022-11-25 17:05:57浏览次数:49  
标签:rk1 rk2 Exchange Direct RabbitMQ 消息 类型 消费者


快速阅读

利用Exchange的Direct类型,实现对队列的过滤,消费者启动以后,输入相应的key值,攻取该key值对应的在队列中的消息 。


从一节知道Exchange有四种类型



前面我们说了fanout类型,可以把消息发送给所有的消费者,

在用Fanout类型的时候,我们绑定的时候是没有指定Routing key的【空值】

这次我们说一下Direct类型



生产者代码

  1. 创建连接和信道
  2. 声明交换器名字和指定类型为direct
  3. 发送routingkey=rk1 和rk2的消息各五次


消费者代码

  1. 输入要查看的消息类型,支持rk1 和rk2
  2. 创建连接和信道
  3. 声明交换器名字和指定类型为direct
  4. 指定队列名称,并且把routingkey的值赋值给控制台手动需要输入的rk1或者rk2
  5. 接收消息并回馈,和fanout类型一样的代码了。

查看结果

我们看到生产者分别生产了五条rk1和五条rk2的消息

消费者1输入只查看rk1的消息,成功获得了rk1的消息

同样的

消费者2输入只查看rk2的消息,成功获得了rk2的消息

要注意的是先把先消费者启动起来

RabbitMQ入门学习系列(五) Exchange的Direct类型_公众号


友情提示

我对我的文章负责,发现好多网上的文章 没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题。可以直接在公众号《爱码农爱生活 》留言。必定会再次复查原因。让每一篇 文章的流程都能顺利实现。


标签:rk1,rk2,Exchange,Direct,RabbitMQ,消息,类型,消费者
From: https://blog.51cto.com/u_15834343/5887040

相关文章

  • RabbitMQ入门学习系列(四) 发布订阅模式
    什么时发布订阅模式把消息发送给多个订阅者。也就是有多个消费端都完整的接收生产者的消息换句话说把消息广播给多个消费者消息模型的核心RabbitMQ不发送消息给队列,生产者......
  • RabbitMQ简介
            RabbitMQ是一种消息队列,用于常见的进程通信。支持点对点,请求应答和发布订阅模式并且提供多种语言的支持。常见的java,c#,php都支持。常被用在异步处理,应用......
  • RabbitMQ入门学习系列(二),单生产者消费者
    友情提示我对我的文章负责,发现好多网上的文章没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题。可以直接在公众号《爱码农爱生活》......
  • centos7安装rabbitmq3.9.16
    下载erlangwget--content-disposition--no-check-certificatehttps://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-23.3.4.11-1.el7.x86_64.rpm/download.......
  • rabbitMQ的高级部分
    RabbitMQ的高级特性消息的可靠投递:指的是由消息生产者发动到RabbitMQ中间件,这个过程是必须成功的。在使用RabbitMQ的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败的......
  • RabbitMQ中间件
    RabbitMQ导入依赖<!--集成RabbitMQ--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></de......
  • RabbitMQ笔记
    RabbitMQ笔记个人学习笔记记录参考:尚硅谷1.消息队列2.轮训分发消息3.消息应答4.发布确认5.交换机5.1Exchanges5.1.1Exchanges概念RabbitMQ消息传递模型的核心......
  • FileNotFoundError: [Errno 2] No such file or directory: ‘sample_weight.pkl‘《
    报错的意思是没有找到“sample_weight.pkl”这个文件的地址或者路径解决方法:将本书的源代码文件夹改名为Deeplearningfromscratchcode并存放至jupyternotebook存放文......
  • Spring Boot 整合 RabbitMQ 之 Fanout Exchange模式 (三)
    摘要:那前面已经介绍过了Direct模式(一)Topic转发模式(二),这次介绍下FanoutExchange形式又叫广播形式,因此我们发送到路由器的消息会使得绑定到该路由器的每一个Queue接收......
  • Spring Boot 整合 RabbitMQ 之 Topic转发模式 (二)
    摘要:上一篇介绍了Direct模式的消息发生机制,这篇介绍下Topic转发模式的消息发生机制。一:首先我们看发送端,我们需要配置队列Queue,再配置交换机(Exchange),再把队列按照相应......