• 一、消息队列——AMQP的理解:
  • 二、RabbitMQ概述:
    • 1、RabbitMQ:
    • 2、基础架构:
    • 3、RabbitMQ的六种工作模式:

一、消息队列——AMQP的理解:

AMQP,即 Advanced Message Queuing Protocol(高级消息队列协议),是一个网络协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同的开发语言等条件的限制。

生产者Publisher生产消息发送到交换机Exchange,由交换机分发到指定的队列Queue存储,然后消费者Consumer 从队列获取消息进行消费。

二、RabbitMQ概述:

1、RabbitMQ:

Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。
Erlang 语言由 Ericson 设计,专门为开发高并发和分布式系统的一种语言,在电信领域使用广泛。

2、基础架构:


producer和consumer都是客户端,broker是服务端,客户端和服务端之间通过建立tcp连接来进行通信。

  1. 通信一次就建立一个连接,那么对资源的消耗会相当大,所以在Connection中使用了channel这些管道资源来进行连接,减少资源的消耗。
  2. 服务端broker进行了逻辑分区,划分成很多个虚拟机virtual host,虚拟机中有很多的交换机,交换机绑定到队列上。
  3. Broker:接收和分发消息的应用,RabbitMQ Server就是 Message Broker(消息中间件)
  4. Virtual host:出于多租户和安全因素设计的,把 AMQP 的基本组件划分到一个虚拟的分组中,类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时,可以划分出多个vhost,每个用户在自己的 vhost 创建 exchange/queue 等
  5. Connection:publisher/consumer 和 broker 之间的 TCP 连接
  6. Channel:如果每一次访问 RabbitMQ 都建立一个 Connection,在消息量大的时候建立 TCP Connection的开销将是巨大的,效率也较低。Channel 是在 connection 内部建立的逻辑连接,如果应用程序支持多线程,通常每个thread创建单独的 channel 进行通讯,AMQP method 包含了channel id 帮助客户端和message broker 识别 channel,所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销;
  7. Exchange:message 到达 broker 的第一站,根据分发规则,匹配查询表中的 routing key,分发消息到queue 中去。常用的类型有:direct (point-to-point), topic (publish-subscribe) and fanout (multicast)
  8. Queue:消息最终被送到这里等待 consumer 取走
  9. Binding:exchange 和 queue 之间的虚拟连接,binding 中可以包含 routing key。Binding 信息被保存到 exchange 中的查询表中,用于 message 的分发依据

3、RabbitMQ的六种工作模式:

3.1 简单模式
3.2 work queues
3.3 Publish/Subscribe 发布与订阅模式
3.4 Routing 路由模式
3.5 Topics 主题模式
3.6 RPC 远程调用模式(远程调用,不太算 MQ)

(三)消息队列——AMQP的理解以及RabbitMQ概述相关推荐

  1. 消息队列,我只选RabbitMQ!

    高并发架构是架构师的必修课,而消息队列,则是王冠上最闪亮的那颗明珠!能否驾驭消息队列这款高并发神器,亦成为架构师的试金石.作为专注.NET领域十多年的老架构师,下面从队列本质.技术选型.实战应用三个方 ...

  2. 消息队列技术介绍 : ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ

    一. 消息队列概述 前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合.异步消息.流量削锋等问 ...

  3. php 消息队列_消息队列篇——windows本地搭建RabbitMQ Server

    前言: 最近的PHP项目中有使用AMQP,解耦一些业务性的功能模块.因为工作使用的是线上Linux搭建,为了方便测试所以我决定本地搭建一个MQ服务. RabbitMQ简介: MQ全称为Message ...

  4. 关于消息队列的使用----ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ

    一.消息队列概述 消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构.目前使用较多的消息队列有ActiveMQ,Rabbit ...

  5. 关于消息队列ActiveMQ、RocketMQ、RabbitMQ、Kafka原理机制以及优劣势的分析

    复习要点 本文大概围绕如下几点进行阐述: 为什么使用消息队列? 使用消息队列有什么缺点? 消息队列如何选型? 如何保证消息队列是高可用的? 如何保证消息不被重复消费? 如何保证消费的可靠性传输? 如何 ...

  6. 消息队列-----生成者 Spring整合rabbitmq

    最近做Spring结合Rabbitmq,然后往队列里面发送了一个消息,如何查看消息 打开:http://127.0.0.1:15672 输入用户名和密码:找到你的队列 我们可以找到自己的队列,并且发现 ...

  7. 消息队列(3):RabbitMQ

    RabbitMQ,基于AMQP协议实现. 特点: 消息可靠:持久化消息,传输确认,发布确认. 路由灵活:使用AMQP的Exchange来路由消息,包括RabbitMQ内置的Exchange,还有复杂的 ...

  8. 消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?

    消息队列(MQ) 在百度百科中,消息队列(MQ)是这么解释的:"消息队列"是在消息的传输过程中保存消息的容器(可存可取). 它是分布式系统中重要的组件,使用消息队列主要是为了通过异 ...

  9. 消息队列 MQ 入门理解

    转载于阿里官方文档,把一些基础部分提炼整理了一下 功能特性: 应用场景: 消息队列 MQ 可应用于如下几个场景: 分布式事务 在传统的事务处理中,多个系统之间的交互耦合到一个事务中,响应时间长,影响系 ...

最新文章

  1. 《高性能Linux服务器构建实战》笔记
  2. 高度平衡二叉树的构建_平衡二叉树建立及其增删改查(JAVA)
  3. 怎么查看Beyond Compare所有会话日志消息
  4. Android插件化开发基础之App如何动态加载类
  5. golang 包含 数组_Golang数组类型
  6. 既然报个培训班就可以成为码农,那学计算机专业有什么用?
  7. 线程池如何保证所有子线程运行完再执行主线程
  8. MySQL与Spring事务隔离级别
  9. 【资料】《模拟电子技术基础-童诗白第四版》
  10. Android 微信H5支付,无法拉起微信支付页面
  11. 运用Fluxion高效破解WiFi密码
  12. 前端 DOM、BOM(二)
  13. android模拟器如何模拟蓝牙连接,如何模拟Android模拟器上的蓝牙
  14. HDOJ:1863畅通工程
  15. 评价页面html,利用html与css制作5星好评页面
  16. 有时候qq邮箱不显示图片
  17. Android数据备份(Android Data Backup)
  18. .NET 6 WebApi Swagger 配置 JWT token+Authorize认证
  19. 演讲达人成长记作者1月26日在西单图书大厦做讲座
  20. 开学第一周acm训练总结

热门文章

  1. 员工持股达27亿美金?比特大陆400页招股文件中的十二个秘密
  2. 查询:同一个学校,姓名相同的学生名单。表中包含多个学校学生名单。
  3. 在金融行业中数据挖掘的应用都有哪些(一)
  4. 餐饮点菜收银该如何选择收银系统
  5. Cacti 监控华为5700交换机总流量
  6. 【macbookpro】重装ventura系统
  7. HP M227安装网络打印机指南及问题解决
  8. 国内比较经典的图库资源网站
  9. 网络安全领域目前面临着哪些问题?
  10. 问鼎EDA顶会冠军之后,我们还有哪些路要走?