码农知识堂 - 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的反智商设计,这设计的不实用又真废脑啊。

  • 相关阅读:
    【NOI模拟赛】给国与时光鸡(构造)
    NestedConfigurationProperty的作用
    网易云音乐项目————项目准备
    VS Code 扩展开发如何保持用户视觉体验一致
    聊聊基于maven的springboot的“过时“用法
    springboot生成二维码的正确姿势-附视频附源码
    Spring源码解析(十一):spring事务配置类源码
    现代 PHP 新特性 —— 内置的 HTTP 服务器
    MySQL事务管理
    【软件测试】开发/测试模型
  • 原文地址:https://www.cnblogs.com/cyq1162/p/16603461.html
  • 最新文章
  • 攻防演习之三天拿下官网站群
    数据安全治理学习——前期安全规划和安全管理体系建设
    企业安全 | 企业内一次钓鱼演练准备过程
    内网渗透测试 | Kerberos协议及其部分攻击手法
    0day的产生 | 不懂代码的"代码审计"
    安装scrcpy-client模块av模块异常,环境问题解决方案
    leetcode hot100【LeetCode 279. 完全平方数】java实现
    OpenWrt下安装Mosquitto
    AnatoMask论文汇总
    【AI日记】24.11.01 LangChain、openai api和github copilot
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
正则表达式工具 cron表达式工具 密码生成工具

京公网安备 11010502049817号