首页 > 其他分享 >RabbitMQ学习笔记一

RabbitMQ学习笔记一

时间:2022-09-27 21:44:19浏览次数:45  
标签:Exchange 队列 笔记 学习 交换机 RabbitMQ 路由 消息

RabbitMQ整体架构模型

RabbitMQ是一个开源的消息代理和队列服务器,RabbitMQ上使用Erlang语言来编写的,并且基于AMQP协议的。

AMQP协议

  • AMQP全称: Advanced Message Queuing Protocol,高级消息队列协议
  • 定义:具有现代特征的二进制协议,是一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。
  • AMQP协议模型:
    AMPQ协议模型
  • AMQP核心概念
    • Server:称Broker,接受客户端的连接,实现AMQP实体服务
    • Connection:连接,应用程序与Broker的网络连接
    • Channel: 网络信道,几乎所有的操作都在Channel中进行,Channel上进行消息读写的通道。客户端可以建立多个Channel,每个Channel代表一个会话任务。
    • Message: 消息,服务器和应用程序之间传递的数据,有Properties和Body组成。Properties可以对消息进行修饰,比如消息的优先级、延迟等高级特性;Body则是消息体内容。
      • 属性:
        • delivery mode:送达模式,到exchange的持久化
        • header: 自定义属性
        • content_type:
        • content_encoding: 内容编码
        • priroity: 优先级
        • correlation_id: 一般作为的唯一id,做ack、消息的路由、幂等
        • reply_to:作为重复队列,消息失败返回哪个队列
        • expiration:消息的过期时间
        • message_id: 消息id
        • timestamp、type、user_id、app_id、cluster_id
    • Virtualhost: 虚拟主机,用于进行逻辑隔离,最上层的消息路由。一个Virtualhost可以有若干个Exchange和Queue,同一个Virtualhost不能有相同名称的Exchange和Queue
    • Exchange: 交换机,接受消息,根据路由键转发消息到绑定的对列
    • Binding: Exchange和Queue之间的虚拟连接,binding中可以包含routing key
    • Routing key: 一个路由规则,虚拟机可以用它来确定如何路由一个特定消息
    • Queue: 也成Message Queue,消息队列,保存消息并转发给消费者
      • 属性:
        • Durability: 是否持久化,Durable是,Transient:否
        • Auto delete: 若是yes,代表当最后一个监听被移除后,该队列会被自动删除

RabbitMQ高性能的原因

  • Erlang语言最初用于交换机领域的架构模式,使得RabbitMQ在Broker之间进行数据交互的性能上非常优秀。
  • Erlang有点,Erlang有着和原生Socker一样的延迟

RabbitMQ的优势:

  • 开源、性能优秀、稳定性保障
  • 提供可靠性消息投递(confirm)、返回模式(return)
  • 集群模式丰富、表达式配置、HA(高可用)模式、镜像队列模型
  • 保证数据不丢失的前提下做到高可靠性、可用性
  • API丰富

RabbitMQ消息流转

RabbitMQ消息生产与消费

RabbitMQ交换机

  • Exchange: 接受消息,并根据路由键转发消息所绑定的对列
  • 交换机属性:
    • Name: 交换机名称
    • Durability: 是否需要持久化,true为持久化
    • auto delete: 当最后一个绑定到exchange上的队列删除后,自动删除该Exchange
    • Internal:当前exchange是否用于RabbitMQ内部使用,默认为false
    • Arguments:扩展参数,用于AMQP协议自定义使用
  • 交换机类型:
    • direct: 所有发送到Direct Exchange的消息被转发到RouteKey指定的Queue。Direct模式可以使用RabbitMQ自带的Exchange:default Exchange,所以不需要将Exchange进行任何绑定(binding)操作,消息传递时,RouteKey必须完全匹配才会被队列接受,否则消息会被抛弃。
    • topic:所有发送到Topic Exchange的消息被转发到所有关心RouteKey中指定Topic的Queue上,即Exchange将RouteKey和某Topic进行模糊匹配,此时队列需要绑定一个Topic
    • fanout:不处理路由键,只需要简单的将队列绑定到交换机上,发送到交换机的消息都会转发到该交换机绑定的所有队列上,Fanout交换机转发消息是最快的
    • headers:消息头路由,不常用

标签:Exchange,队列,笔记,学习,交换机,RabbitMQ,路由,消息
From: https://www.cnblogs.com/simple-record/p/16733055.html

相关文章

  • 《软件工程》学习日记(一)
    浅谈软件工程笔者系上海交通大学电子信息与电气工程学院的一名大三学生,目前正辅修CS专业,在这里写下本人的第一篇博客,浅谈一下自己对软件工程的理解。软件工程意味“完......
  • C++学习 Day9-01 指针-定义及使用
    指针变量定义语法:数据类型*变量名;示例:intmain(){ //1、指针的定义 inta=10;//定义整型变量a //指针定义语法:数据类型*变量名; int*p; //指针变量......
  • 小学二年级都能看懂的 虚树学习笔记
    过不去那道题?事实:它数据范围很大而且每一次询问都得O(n)暴力出题人最坏了!介绍……虚树!介绍先看这么一道题P2495[SDOI2011]消耗战题目大意:每一次给k个特殊点,每次......
  • 路飞学城七: 课程学习进度
    七:课程学习进度我的课程个人中心里面展示我的课程界面效果src/components/user/Course.vue,代码:<template><divclass="right-containerl"><divclass="right......
  • 《代码大全》笔记第一篇
                             第一部分:打好基础这部分主要分成四部分,欢迎进入软件构建的世界,用隐喻来更充分地理解软......
  • 数据结构学习----树的遍历
    树的遍历前言在一个平常的星期二下午,一节数据结构课中,想着做点什么的我,打开了力扣。正好老师在讲树,我也从二叉树最基础的遍历开始刷题,没想到打开了新世界的大门····......
  • 《软件测试的艺术》读书笔记(五)
    第5章模块(单元)测试对于完全没有编程基础的人来说,第五章和第四章一样难懂。不过好在都是比较简单明了的单词和运算符号组成的,差不多也能猜到是什么意思。作者同样使用......
  • 关于python的opencv库的学习笔记,腐蚀与膨胀
    importcv2importnumpyasnp##img=cv2.imread('cat.jpeg')##cv2.imshow('cat',img)##cv2.waitKey()##cv2.destroyAllWindows()##对图像进行腐蚀操作#ken=np.ones......
  • opencv学习笔记,关于图片的平滑处理
    在opencv的图像平滑处理,有高斯滤波,中值滤波,均值滤波的处理方法importcv2importnumpyasapimportmatplotlib.pyplotaspltimg=cv2.imread('cat.jpeg')cv2.imshow('cat......
  • 大码世网络安全学习决心书
    1.未来三个月计划在大码世如何度过?✅考勤:每日按时上课,不迟到不早退,遵守班级考勤纪律。✅学习:上课做好笔记,认真听讲,积极完成实操练习,复习-学习-巩固,当天学习要当天消化。✅......