RabbitMQ(2) 一般介绍

RabbitMQ 即一个消息队列,主要是用来实现应用程序的异步和解耦,同时也能起到消息缓冲,消息分发的作用。

消息中间件在互联网公司的使用中越来越多,刚才还看到新闻阿里将RocketMQ捐献给了apache,当然了今天的主角还是讲RabbitMQ。消息中间件最主要的作用是解耦,中间件最标准的用法是生产者生产消息传送到队列,消费者从队列中拿取消息并处理,生产者不用关心是谁来消费,消费者不用关心谁在生产消息,从而达到解耦的目的。在分布式的系统中,消息队列也会被用在很多其它的方面,比如:分布式事务的支持,RPC的调用等等。

特点:高可用性、高性能、灵活性

 

RabbitMQ介绍

RabbitMQ是实现AMQP(高级消息队列协议)的消息中间件的一种,最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时,消费者无法快速消费,那么需要一个中间层。保存这个数据。

AMQP,即Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。

RabbitMQ是一个开源的AMQP实现,服务器端用Erlang语言编写,支持多种客户端,如:Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等,支持AJAX。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。

 

相关概念

通常我们谈到队列服务, 会有三个概念: 发消息者、队列、收消息者,RabbitMQ 在这个基本概念之上, 多做了一层抽象, 在发消息者和 队列之间, 加入了交换器 (Exchange). 这样发消息者和队列就没有直接联系, 转而变成发消息者把消息给交换器, 交换器根据调度策略再把消息再给队列。

  • 左侧 P 代表 生产者,也就是往 RabbitMQ 发消息的程序。
  • 中间即是 RabbitMQ,其中包括了 交换机 和 队列。
  • 右侧 C 代表 消费者,也就是往 RabbitMQ 拿消息的程序。

那么,其中比较重要的概念有 4 个,分别为:虚拟主机,交换机,队列,和绑定。

  • 虚拟主机:一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢?很简单,RabbitMQ当中,用户只能在虚拟主机的粒度进行权限控制。 因此,如果需要禁止A组访问B组的交换机/队列/绑定,必须为A和B分别创建一个虚拟主机。每一个RabbitMQ服务器都有一个默认的虚拟主机“/”。
  • 交换机:Exchange 用于转发消息,但是它不会做存储 ,如果没有 Queue bind 到 Exchange 的话,它会直接丢弃掉 Producer 发送过来的消息。 这里有一个比较重要的概念:路由键 。消息到交换机的时候,交互机会转发到对应的队列中,那么究竟转发到哪个队列,就要根据该路由键。
  • 绑定:也就是交换机需要和队列相绑定,这其中如上图所示,是多对多的关系。

交换机(Exchange)

交换机的功能主要是接收消息并且转发到绑定的队列,交换机不存储消息,在启用ack模式后,交换机找不到队列会返回错误。交换机有四种类型:Direct, topic, Headers and Fanout

  • Direct:direct 类型的行为是”先匹配, 再投送”. 即在绑定时设定一个 routing_key, 消息的routing_key 匹配时, 才会被交换器投送到绑定的队列中去.
  • Topic:按规则转发消息(最灵活)
  • Headers:设置header attribute参数类型的交换机
  • Fanout:转发消息到所有绑定队列

Direct Exchange
Direct Exchange是RabbitMQ默认的交换机模式,也是最简单的模式,根据key全文匹配去寻找队列。

第一个 X - Q1 就有一个 binding key,名字为 orange; X - Q2 就有 2 个 binding key,名字为 black 和 green。当消息中的 路由键 和 这个 binding key 对应上的时候,那么就知道了该消息去到哪一个队列中。

Ps:为什么 X 到 Q2 要有 black,green,2个 binding key呢,一个不就行了吗? - 这个主要是因为可能又有 Q3,而Q3只接受 black 的信息,而Q2不仅接受black 的信息,还接受 green 的信息。

 

Topic Exchange

Topic Exchange 转发消息主要是根据通配符。 在这种交换机下,队列和交换机的绑定会定义一种路由模式,那么,通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息。

在这种交换机模式下:

  • 路由键必须是一串字符,用句号(.) 隔开,比如说 agreements.us,或者 agreements.eu.stockholm 等。
  • 路由模式必须包含一个 星号(*),主要用于匹配路由键指定位置的一个单词,比如说,一个路由模式是这样子:agreements..b.*,那么就只能匹配路由键是这样子的:第一个单词是 agreements,第四个单词是 b。 井号(#)就表示相当于一个或者多个单词,例如一个匹配模式是agreements.eu.berlin.#,那么,以agreements.eu.berlin开头的路由键都是可以的。

具体代码发送的时候还是一样,第一个参数表示交换机,第二个参数表示routing key,第三个参数即消息。如下:

rabbitTemplate.convertAndSend("testTopicExchange","key1.a.c.key2", " this is  RabbitMQ!");

topic 和 direct 类似, 只是匹配上支持了”模式”, 在”点分”的 routing_key 形式中, 可以使用两个通配符:

  • *表示一个词.
  • #表示零个或多个词.

Headers Exchange

headers 也是根据规则匹配, 相较于 direct 和 topic 固定地使用 routing_key , headers 则是一个自定义匹配规则的类型. 在队列与交换器绑定时, 会设定一组键值对规则, 消息中也包括一组键值对( headers 属性), 当这些键值对有一对, 或全部匹配时, 消息被投送到对应队列.

Fanout Exchange

Fanout Exchange 消息广播的模式,不管路由键或者是路由模式,会把消息发给绑定给它的全部队列,如果配置了routing_key会被忽略。

 

参考:

http://www.ityouknow.com/springboot/2016/11/30/springboot(%E5%85%AB)-RabbitMQ%E8%AF%A6%E8%A7%A3.html

转载于:https://www.cnblogs.com/xiaozhuanfeng/p/10711728.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/264235.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Cisco 3550-EMI 交 换 机 配 置 教 程

目录:一、标识交换机二、设置口令及用户三、配置VTP(Vlan中继协议)四、配置中继线(Trunk)五、创建、描述Vlan及设置Vlan IP六、划分、描述及设置Vlan端口七、配置STP(生成树协议)八、启用Vlan间…

struct1标签使用方法笔记

1.<html:text property"" name"">其中property对应作用域变量的属性,name对应作用域里的变量,如果NAME没有,则property里第一个点号[这时至少要有一个点]之前的作为作用域变量.property最后生成了INPUT标签的NAME属性.所以property是必须的.2.<ht…

cop2000计算机组成原理,COP2000计算机组成原理实验系统

COP2000计算机组成原理实验系统3. 万用汇编器用户可以自定义指令/微指令系统&#xff0c;COP2000软件可以对用户自己定义的汇编助记符进行编译&#xff0c;自动生成代码/微代码。实验系统出厂时提供了完善的指令系统&#xff1a;算术运算&#xff1a;ADD、ADDC、SUB、SUBC 逻辑…

python--Websocket实现, 加密 sha1,base64

需要用到gevent-websocket包,这里我们用下图这个 一.websocket简单实现 ep1.py from geventwebsocket.handler import WebSocketHandler from gevent.pywsgi import WSGIServer from geventwebsocket.websocket import WebSocket # 引这个模块为了注释中显示提示用from flask i…

[工具] 解决sublime text运行javascript console无输出问题

1、使用nodeJS在sublime text 运行javascript 下载安装nodeJS在sublime text新建build system&#xff1a;tools->build system->new build system…&#xff0c;输入代码&#xff1a;{ "cmd": ["node", "$file"], "selector"…

计算机考试怎么复制粘贴文件,复制粘贴,教您电脑复制粘贴不能用了怎么解决...

操作电脑过程中经常需要复制、粘贴文字或图片&#xff0c;直接点击右键就可以操作的。但是使用过程中难免遇到一些故障问题导致右键复制粘贴功能无法使用&#xff0c;有些是软件引起的&#xff0c;有些是硬件引起的&#xff0c;怎么解决&#xff1f;下面&#xff0c;小编给大家…

第43周三

晚上下班等公交回去&#xff0c;今天效率还行&#xff0c;但没让培训让我更清醒自己目前在最高领导心中的印象&#xff0c;让我必须更清醒思考自己未来的出路&#xff0c;上午完成了产品需求初稿&#xff0c;下午搭建了总体设计框架&#xff0c;晚上看了几篇前端面试题&#xf…

为什么而设计

当然是为实现功能而设计, 这句话没错. 但是还不够, 针对具体的应用场合, 应该采取不同的设计策略. 例如GUI Client程序, 必须重点注意用户的体验, 为提高易用性而设计 而一般后台应用程序, 就必须在高性能和可靠性方面加强设计 只创建一次的对象, 我们不必在乎其构造时间, 而频…

认识因特网络(小学计算机课件),小学信息技术认识因特网ppt课件.ppt

《小学信息技术认识因特网ppt课件.ppt》由会员分享&#xff0c;可在线阅读&#xff0c;更多相关《小学信息技术认识因特网ppt课件.ppt(9页珍藏版)》请在人人文库网上搜索。1、1.你们知道从什么上获得新闻最新最快&#xff1f; 2.你们知道什么样的信件传的最快&#xff1f; 3.你…

delphi基本语法

//delphi中exit,abort,break,continue 的区别exit: 退出函数体abort: 遇到异常,安静处理,就是不显示不提示break: 退出当前循环体,包括for ,while, repeat等循环体continue: 结束循环内的本次处理,继续从循环体的开始位置继续执行Exit 是跳出当前代码块&#xff0c;也就是当前函…

easy-ui的datagrid

<div id"magazineGrid"></div> <script> $(#magazineGrid).datagrid({height: 340,//在创建完成后会根据url请求数据&#xff0c;通过ajax完成url: <c:url value"/kpOutSystem/view.do?opgetList"/>, method: POST,queryParams…

【未解决】Reporting Services报表在浏览器中的显示

今天把微软的报表重新部署一遍&#xff0c;发现在不同的浏览器中&#xff0c;显示的尺寸大小不一样。在IE8浏览器中是正常的&#xff1a;而在火狐浏览器中却始终只有全屏的四分之一大小&#xff0c;无论在报表中如何修改尺寸也没有变化。看起来&#xff0c;应该是在浏览器的什么…

纽大计算机博士,斑马博士捷报|纽约大学 (NYU) MSc Computer Engineering 计算机工程硕士录取...

原标题&#xff1a;斑马博士捷报|纽约大学 (NYU) MSc Computer Engineering 计算机工程硕士录取马博士 (Dr. Zebra, Since 2010)&#xff0c; 10年来深受海内外名校申请者的青睐&#xff01;“定制化" 助你被“高于自身背景”的名校录取&#xff01;斑马博士、斑马博士留学…

转:靠谱的代码和DRY

http://www.cppblog.com/vczh/archive/2014/07/15/207658.html 靠谱的代码和DRY上次有人来要求我写一篇文章谈谈什么代码才是好代码&#xff0c;是谁我已经忘记了&#xff0c;好像是AutoHotkey还是啥的专栏的作者。撇开那些奇怪的条款不谈&#xff0c;靠谱的 代码有一个共同的特…

omitting directory `folder/'

题记&#xff1a;一个问题&#xff0c;若遇见第一次&#xff0c;不知道如何解决&#xff0c;经查资料后处理掉可以原谅&#xff1b;若遇见第二次&#xff0c;还是一头雾水&#xff01;反省自己&#xff0c;特此备录。 在linux CentOS6.5 系统中复制文件夹时提示如下&#xff1a…

GridView中的CheckBox单击事件(oncheckedchanged)

在GridView中加入 CheckBox控件&#xff0c;想通过单击选中出现如下图所示效果&#xff1a; 具体做法是&#xff1a; 前台GV部份省掉。只加关键的CheckBox部份。 <asp:CheckBox ID"ItemCheckBox" oncheckedchanged"ItemCheckBox_CheckedChanged" AutoPo…

我的世界服务器怎么找到指定路径,[小白]MC服务端目录详解

服务器的前期准备工作都做好了&#xff0c;是时候上传服务端到服务器了。不过……先等等&#xff0c;在上传前你应该先了解一下服务端目录的结构以便于后期的维护&#xff01;如图所示的是MCPC1.6.4的服务端结构示意图&#xff0c;其他开服端基本相同&#xff0c;接下来我将逐一…

第四章:条件语句(if)和循环结构(while)

1.流程控制 含义与作用 Python程序执行&#xff0c;一定按照某种规律在执行 a.宏观一定是自上而下(逻辑上方代码一定比逻辑下方代码先执行)&#xff1a;顺序结构b.遇到需要条件判断选择不同执行路线的执行方式&#xff1a;分支结构c.有些事情需要重复不断的去执行(当满足某种条…

ArcGis开发过程中遇到HRESULT:0x80040213错误

ArcGis开发过程中遇到HRESULT:0x80040213错误&#xff1a;错误原因&#xff1a; COM资源没完全释放。数据量少时&#xff0c;不会出现问题&#xff0c;但是如果是几百个数据&#xff0c;循环调用&#xff0c;肯定会出现该问题。解决方法&#xff1a;释放资源&#xff0c;.Net环…

css样式加入的法方,初学必知:XHTML网页中加入CSS的五种方_css

在Xhtml网页中如何加入css呢&#xff1f;这篇教程告诉大家引入CSS的几种方式。XHTML文件是通过CSS样式进行显示的控制的&#xff0c;也就是结合XHTML与CSS来表现页面内容。那么到底有哪些方式在XHTML文件中引入CSS样式呢&#xff1f;一、使用STYLE属性将STYLE属性直接加在个别的…