开篇

说到消息队列，相信大家并不陌生。大家在日常的工作中其实都有用过。相信大部分的研发在使用消息队列的过程中也仅仅是停留在用上面，里面的知识点掌握得并不是很系统，有部分强大的功能可能由于本身公司的业务形态或者业务量级的原因根本无法触及到。老猫在工作中就是如此，所使用的MQ都是架构师封装好的，简单调用即可。为了更好地了解其所以然，所以老猫就花时间好好梳理了一下MQ的一系列的知识点，俗话说“好记心不如烂笔头”，所以老猫在学习的过程中就记录了下来。分享出来给有需要的小伙伴，当然也方便后续自己查阅，因此就有了该系列文章。

AMQP协议简介

大家在工作中很多就接触过RabbitMq，其实RabbitMq就是AMQP协议的一种实现。

与其说AMQP是一种协议，其实它更是一种标准。是应用层协议的一个开放标准，为面向消息的中间件设计。AMQP是一个进程间传递异步消息的网络协议。 全称为AMQP（Advanced Message Queuing Protocol）。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。AMQP在消息提供者和客户端的行为进行了强制规定，使得不同卖商之间真正实现了互操作能力。

关于Kafka和AMQP单独补充一个点

相信大家的工作日常中除了用RabbitMQ之外很多小伙伴也用过kafka吧，那么kafka和AMQP有什么关系么？

答案是：没关系。

Kafka根本不是消息队列。按官方说法，Kafka是一个流式处理平台（stream processing platform）。Kafka在设计之初是为了支持高吞吐量的日志处理的，只不过它恰好也可以实现消息队列的大部分功能而已。Kafka所用的“黑科技”（例如零拷贝/内存映射，以及对page cache的利用，当然这些后续分享kafka的时候再和小伙伴同步）都是脱离标准消息队列的设计范畴的，所以不能简单地认为Kafka比RabbitMQ等符合AMQP的消息队列更优。例如，RabbitMQ支持死信队列、延迟队列、优先队列、多租户、推模式消费等，Kafka统统不支持。

AMQP和JMS的区别

说到AMQP协议，就不得不聊JMS。 JMS是早期消息中间件进行标准化的一个尝试，它仅仅是在API级进行了规范。 只适用于Java平台的消息中间件规范，支持Java应用程序之间进行消息交换。并且通过提供标准的生产、发送、接收消息的接口简化企业应用的开发。 如果想要详细了解JMS的小伙伴其实百度百科就有很详细的讲解。具体链接：https://baike.baidu.com/item/JMS/2836691?fr=aladdin，

另外如果有小伙伴想要其具体的接口文档，可以在此进行下载：https://download.oracle.com/otndocs/jcp/7195-jms-1.1-fr-spec-oth-JSpec/

JMS简单概括

JMS主要包括两种模型，（1）点对点模型（2）发布订阅模型

点对点：生产者向队列投递一条消息只有一个监听者才能获取该条消息。

发布订阅：生产者向队列投递一条消息，所有监听该队列的订阅者都可以拿到该消息。

JMS 五种不同的消息正文格式

JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。

  • StreamMessage – Java原始值的数据流
  • MapMessage–一套名称-值对
  • TextMessage–一个字符串对象
  • ObjectMessage–一个序列化的 Java对象
  • BytesMessage–一个字节的数据流

AMQP模型概括

AMQP模型如下

  • Server：又称Broker，接受客户端的连接，实现AMQP实体服务。
  • Connection：连接，应用程序与Broker的网络连接。
  • Channel：网络信道。几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
  • Message：消息，服务器和应用程序之间传送的数据，由Properties和body组成，Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则是消息主体。
  • Virtual host：虚拟地址，由于进行逻辑隔离，最上层的消息路由。一个Virtual Host里面可以有若干个Exchange和Queue,同一个Virtual Host里面不能有相同名称的Exchange或Queue。
  • Exchange：交换机，接收消息，根据路由键转发消息到绑定的队列。
  • Binding：Exchange和Queue之间的虚拟连接，binding中可以包含routing Key。
  • Routing Key：一个路由规则，虚拟机可以用它来确定如何路由一个特定消息。
  • Queue：也称为Message Queue,消息队列，保存消息并将它们转发给消费者。

AMQP和JMS对比

上述做了一些简单的概括，如果小伙伴觉得有所欠缺，不是太全，那么可以自行查阅相关资料。

对比方向JMSAMQP
定义Java API协议
跨语言否是
跨平台否是
对比模型①Peer-2-Peer（点对点）;
②Pub/sub（发布订阅）		①direct exchange；
②fanout exchange；
③topic change；
④headers exchange；
⑤system exchange。
本质来讲，后四种和JMS的pub/sub模型没有太大差别，
仅是在路由机制上做了更详细的划分；
（这块后续老猫和大家分享rabbitMq的时候会详细说到）
消息类型支持多种消息类型 ，
我们在上面提到过		byte[]（二进制）

写在最后

关于AMQP协议的简单介绍大概就到这里。有小伙伴觉得不够详细的地方当然也可以自发去找找更多的资料。后面老猫会重点整理RabbitMq以及Kafka的知识点和大家分享。期待你的持续关注。

聊聊消息中间件(1)，AMQP那些事儿的更多相关文章

  1. 【月光宝盒get√】用时间置换空间，聊聊稀疏数组的那些事儿

    背景 数据结构是指带有结构特性的数据元素的集合.在数据结构中,数据之间通过一定的组织结构关联在一起,便于计算机存储和使用.从大类划分,数据结构可以分为线性结构和非线性结构,适用于不同的应用场景. 线性 ...

  2. 关于display的那些事儿!

    关于display的那些事儿! display,display,display!嘿嘿嘿!display这一CSS属性,还是相当神奇的哦!给它设置不同的值,被修饰的标签相应的就随之变换了自身的属性特性, ...

  3. ActiveMQ-为什么需要消息中间件？

    消息中间件的优势 UNIX的进程间通信就开始运用消息队列技术,一个进程将数据写入某个特定的队列中,其它进程可以读取队列中的数据,从而实现异步通信.对于如今的分布式系统,消息队列已经演变为独立的消息中间 ...

  4. RabbitMQ从概念到使用、从Docker安装到RabbitMQ整合Springboot【1.5w字保姆级教学】

    @ 目录 一.前言 二.RabbitMQ作用 1. 异步处理 2. 应用解耦 3. 流量控制 三.RabbitMQ概念 1. RabbitMQ简介 2. 核心概念 四.JMS与AMQP比较 五.Rab ...

  5. [No0000193]Chrome浏览器控制台（console）花式调试

    对前端开发者来说,Chrome Dev Tools(开发者工具,以下简称CDT)是一个不可或缺的开发调试工具,但是你可能只用过console.log(),却不知道console还有很多功能强大的调试方 ...

  6. RabbitMQ下的生产消费者模式与订阅发布模式

    所谓模式,就是在某种场景下,一类问题及其解决方案的总结归纳.生产消费者模式与订阅发布模式是使用消息中间件时常用的两种模式,用于功能解耦和分布式系统间的消息通信,以下面两种场景为例: 数据接入   假设 ...

  7. 知名APP（支付宝、微信、花瓣等）首页设计技巧及原型实例讲解

    APP首页设计对APP自身来说是至关重要的,一款优秀的APP产品,其首页设计不仅需要清晰的展示产品核心功能,给用户创造良好的用户体验,而且还需要展示公司的品牌形象,提升在用户心中的品牌认知度.今天,就 ...

  8. 《Excel效率手册：早做完，不加班》

    <Excel效率手册:早做完,不加班> 基本信息 作者: 陈锡卢    杨明辉 出版社:清华大学出版社 ISBN:9787302350743 上架时间:2014-5-8 出版日期:2014 ...

  9. openstack rpc机制

    一.概述: 在openstack项目中,api的调用规则: 跨项目:如nova调用keystone, glance,cinder等,使用rest api(通过相应的python-XXXclient 库 ...

  10. JVM的逃逸分析

    我们都知道Java中的对象默认都是分配到堆上,在调用栈中,只保存了对象的指针.当对象不再使用后,需要依靠GC来遍历引用树并回收内存.如果堆中对象数量太多,回收对象还有整理内存,都会会带来时间上的消耗, ...

随机推荐

  1. 根据网址把图片下载到服务器C#代码

    根据网址把图片下载到服务器C#代码 ASPX页面代码: <%@ Page Language="C#" AutoEventWireup="true" Cod ...

  2. iOS-NSURLCache内存缓存

    在IOS应用程序开发中,为了减少与服务端的交互次数,加快用户的响应速度,一般都会在IOS设备中加一个缓存的机制.使用缓存的目的是为了使用的应用程序能更快速的响应用户输入,是程序高效的运行.有时候我们需 ...

  3. oracle 变量赋值

    在oracle 中使用 select 字段 into 变量 from 表 where 条件 这种方法给变量赋值时和MSSQL的行为有比较大区别. 在MSSQL中如果在该表中未检索到任何行,则变量的值保 ...

  4. [Microsoft][ODBC Microsoft Access Driver] INSERT INTO 语句的语法错误。

    遇到的情景: sta.executeUpdate("insert into 表1(longitude,latitude,time) values("+a[0]+",&qu ...

  5. main函数的正确格式

    main函数称之为主函数,一个C程序总是从main()函数开始执行的.在关于C语言的网贴和图书中,可以看到main函数的多种格式,这些格式,有的是正确的,有的是不正确的,为了避免错误,现归纳整理如下. ...

  6. jQuery 源码分析和使用心得 - 序

    众所周知, jQuery (个人简称为jq) 在前端开发中占有着非常重要的地位, 可以说jQuery的存在大大降低了学习网页设计和交互的门槛, 他的简单的语法和顺畅的使用逻辑激发了人们强烈的学习兴趣, ...

  7. Java历程-初学篇 Day08 数组

    一,什么是数组 所谓数组,是相同数据类型的元素按一定顺序排列的集合.若将有限个类型相同的变量的集合命名,那么这个名称为数组名.组成数组的各个变量称为数组的分量,也称为数组的元素,有时也称为下标变量.用 ...

  8. Silverlight的认识

    Microsoft Silverlight是一个跨浏览器的.跨平台的插件.Silverlight提供灵活的编程模型,并可以很方便地集成到现有的网络应用程序中.Silverlight可以对运行在Mac或 ...

  9. Python与R的区别和联系

    转自:http://bbs.pinggu.org/thread-3078817-1-1.html 有人说Python和R的区别是显而易见的,因为R是针对统计的,python是给程序员设计的,其实这话对 ...

  10. 使用idea 在springboot添加本地jar包的方法本地运行有效，一旦需要打jar就会报错，这就需要在

    https://blog.csdn.net/huxiaodong1994/article/details/80702278 1.首先在与src同级的目录下新建一个lib目录,然后将本地jar包放在li ...