码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。


    系列目录

    RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。

    RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。

    RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。

    RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消息、接收消息。

    RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。

    RabbitMQ 入门系列:6、保障消息:不丢失:发送方、Rabbit存储端、接收方。

    RabbitMQ 入门系列:7、保障消息:不重复消费:产生消息的唯一ID。

    RabbitMQ 入门系列:8、扩展内容:接收信息时:可否根据RoutingKey过滤监听信息,答案是不能。

    RabbitMQ 入门系列:9、扩展内容:死信队列:真不适合当延时队列。

    RabbitMQ 入门系列:10、扩展内容:延时队列:延时队列插件及其有限的适用场景。

    前言:

    本篇介绍交换机的进阶介绍及编码方式。

    1、 交换机的类型:

    在第二篇文时,曾简单介绍过交换机,但没太深入,那是为了避免入门阻碍太多。

    本篇再稍为加深一下交换机的介绍,但也是点到为止:

    交换机默认有4个类型:

    direct:1条信息仅允许发送到1个队列。(RoutingKey匹配队列名)

    fanout:1条信息发送到所有绑定的队列。(忽略RoutingKey)

    header:1条信息发送到匹配的队队。(用header头部数据匹配)

    topic:1条信息发送到匹配RoutingKey规则的队列。(一般用#和*通配符)

    通配符号#(无视.点号)和*(遇到.点号则中止)说明:

    topic.#那么这个队列会接收topic开头的消息,如topic.hello.world
    topic.*那么这个队列只接收topic开头后面一个的消息,如topic.hello

    1、交换机:direct类型及其使用编码

    实际上,之前的介绍中,在使用的代码中都避开了交换机。

    其实不是没用到,只是用到的是默认交换机(AMQP default):

    1、它是direct类型,因此RoutingKey匹配队列名。
    
    2、它默认通向所有的队列,即绑定了所有的队列。
    
    3、交换机名称传值时默认传空值。

    下面进行1个简单的消息发送:

    channel.BasicPublish(“”, “first", false, null, Encoding.UTF8.GetBytes("这是要发送的内容aaa"));

    从Web控制中心查看数据,可以看到,路由使用了默认的,而RoutingKey 则是对应了队列了名称。

    3、交换机:fanout类型的使用编码

    对fanout类型的使用,所有的routekey都传空值即可。

    复制代码
    using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
    {
        //定义队列
        channel.QueueDeclare("user.order");
        channel.QueueDeclare("user.birth");
    
        //定义交换机
        channel.ExchangeDeclare("user", "fanout");
    
        //交换机绑定2个队列
        channel.QueueBind("user.order", "user", "");
        channel.QueueBind("user.birth", "user", "");
    
        //发送到交换机,直接到达2个队列
        channel.BasicPublish("user", "", false, null, Encoding.UTF8.GetBytes("两个队列都收到信息"));
    
    }
    复制代码

    管理界面可以看到信息:

    4、交换机:topic类型编码

    对于交换机类型来说:

    direct类型:队列名就是routing key。
    
    fanout类型:只关注交换机名称,routing key都是空。
    
    topic类型:只有这个是重心放在routing key,而不关心队列起名规则。

    下在看代码(用first、first2、first3)来演示(演示前会清空数据):

    复制代码
    using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
    {
      
    //定义交换机 channel.ExchangeDeclare("user_topic", "topic"); //交换机绑定3个队列 channel.QueueBind("first", "user_topic", "#.order"); channel.QueueBind("first2", "user_topic", "#.birth"); channel.QueueBind("first3", "user_topic", "#.birth");
    //发送到交换机,直接到达2个队列 channel.BasicPublish("user_topic", "user.order", false, null, Encoding.UTF8.GetBytes("1队列都收到信息")); channel.BasicPublish("user_topic", "user.birth", false, null, Encoding.UTF8.GetBytes("2队列都收到信息")); }
    复制代码

    数据结果:

     

    这里必须吐槽一下,这个规则的设计反智商啊:

    这种设计,用topic模块,一个信息只能发送到一个队列:

    泥媒,这真是妥委的direct加强版,还真是只能到一个队列,加了个匹配规则,变成一个很弱鸡的功能。

    要同时满足发送到多个队列,就必须绑定多个绑定规则......

    个人觉得设计应该反过来才对:

    绑定交换机时,定义完整的路径,发布消息时,带上通配符,去匹配规则,达到可以发送一个或多个队列去才合理。

    5、交换机:header类型及其使用编码

    这个类型不常用,暂未想到应用场景,暂不介绍。 

    总结:

    本篇介绍如交换机介绍及以使用其发送消息到多个队列,特别是topic的路由key的反智商设计,这设计的不实用又真废脑啊。

  • 相关阅读:
    RL 基础 | Value Iteration 的收敛性证明
    源码探索-ArrayList
    2024前端面试准备之HTML篇
    Redis缓存的使用
    ES6迭代器详细介绍
    string类详解
    基于区域的图像分割
    MYSQL基础——函数
    官宣|Apache Flink 1.16 发布公告
    爬虫 — Bs4 数据解析
  • 原文地址:https://www.cnblogs.com/cyq1162/p/16603461.html
  • 最新文章
  • 沪漂五周年了:我越来越迷茫了
    Agentic Skill Routing 实战:别再把所有 Skill 塞进 AI Agent 上下文
    MySQL-Seconds_behind_master的精度误差
    [MAF预定义ChatClient中间件-03]CachingChatClient——利用缓存省钱省时间
    AI的至暗历史:从万众期待到被政府撤资,AI的两次死亡徘徊
    Agent OS :五种驯服不确定性的范式
    PortSwigger SQL注入LAB11
    数据库即时编译JIT
    [Begin]AI Learn Data Day 0
    深度学习进阶(二十七)现代 LLM 的核心架构设计其二:SwiGLU
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
小工具 小游戏
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

京公网安备 11010502049817号