rabbitmq核心概念理解

1、Connection(连接rabbitmq)
rabbitmq是遵循AMQP协议的,换句话说其实rabbitmq就是erlang语言实现的AMQP协议的封装,AMQP说到底就是一个通讯协议,协议就一定会包含报文的交互,协议就是人为规定好的,我们只要遵从AMQP协议定义好的命令,就如同我们熟悉的http协议一样,GET,POST等方法在AMQP中也有相应的命令在生产者和消费者连接到rabbitmq的流转过程下图所示:

rabbitmq生产者.png

rabbitmq 消费者.png

2、信道(channel)
上图还出现了一个channel的名称,我们知道其实建立连接以后其实就可以发送命令得到响应了,那为什么会出现信道这个概念呢,当建立了连接以后,其实就是创建了一个TCP连接,rabbitmq的信道就是在connection的基础上建立的,每个信道都会分配唯一的标示,而AMQP的指令都是通过信道传输的。

  • 那我们思考为什么需要设计信道这个概念呢?
    因为对于操作系统来说创建和销毁连接是一个很消耗性能的操作,当遇到高峰的时候,性能会出现瓶颈,rabbitmq采用多路复用的方式进行管理连接,信道复用了TCP连接,节省了资源提高了性能,到流量不大的时候,多个信道可以复用一个Connection。如图所示:
    信道和连接.png

    3、生产者和消费者
    rabbitmq是依据生产者消费者模型,在官方文档中rabbitmq是这样的介绍自己的。
You can think about it as a post office: when you put the mail that you want posting in a post 
box, you can be sure that Mr. or Ms. Mailperson will eventually deliver the mail to your 
recipient. In this analogy, RabbitMQ is a post box, a post office and a postman.
  • 生产者:生产者顾名思义就是消息的创建方,然后将创建好的消息发送到rabbitmq broker中;
  • broker:消息中间件的服务节点,换句话说就是一个rabbitmq服务;
  • 消费者:消息的消费方,注意消费者只知道消费,他不知道生产这个消息的人是谁,但是谁也不重要;
    4、队列(Queue)
    rabbitmq中的一个内置的对象,就是一条队列,rabbitmq的消息只能存在队列里面
    producer consumer.png

    消费者订阅或者是监听一个队列,就可以获取到生产者发布到这个队列的数据,一个队列可以有多个消费者,但是rabbitmq不支持广播的操作,多个消费者监听同一条队列,队列的消息会被平均分摊到多个消费者身上。
    5、交换器,路由键,绑定关系(exchange,Routingkey,Binding)
    交换器也是rabbitmq的一个内置对象,生产者生产完消息不是一下子就扔到队列中,而是先要经过一层交换器,交换器根据消息的类型路由到一个或多条队列中,如果找不到目标,可能会消息丢失或者返回给生产者。
    交换器.png
  • 那交换器是如何路由的,它是如何知道那条消息该被送到哪?
    当生产者发送消息的时候,会对消息进行一个标示,就是标示消息应该被发送到哪一条队列,rabbitmq叫这个标示为路由键RoutingKey,而这个路由键必须和交换机类型绑定在一起才可以使用。
  • 绑定:绑定是就rabbitmq把交换器和队列关联起来的一种方式,在绑定的时候会指定一个BindingKey
  • 结论:这三种概念的关系我们来捋一下,当生产者发送消息到交换器的时候需要一个Routingkey,当bindingkey和Routingkey相同的时候就知道这个消息该送到哪个队列了,这几个概念确实比较绕,让人摸不得头脑。
  • 沿用rabbitmq官方文档的比喻,把rabbitmq比喻为邮局,那交换器就是邮局门口的一个邮筒,生产者就是一个来寄件人,他把消息封装在信封里,但是信封上必须写上一些信息,这个信息就包含了地址,这个地址就是RoutingKey,比如寄到XX大学,而bindingkey就是这个邮筒会到的地址,如果一看这个新建信件的地址和这个邮筒的地址一致,那皆大欢喜,走你,就去了该去的地方,如果地址错了,不好意思,丢掉或者原路返回。其实在一定情况下这两个玩意就是一个东西。有没有发现。都是地址嘛。所以这个和交换器的类型有关。
    6、交换器的类型
    1、fanout
    此种交换器会将接收到的消息发送给所有与该交换器绑定的队列中;
    这个类型的队列就会无视BindingKey。
    2、direct
    此种交换器会把消息发送到RoutingKey和BindingKey相匹配的队列中;
       //定义一个direct的类型的交换器 名字叫hello
        channel.exchangeDeclare("hello","direct");

        //定义一条队列,名字叫helloWorld
        channel.queueDeclare("helloWorld",true,false,false,null);

        //将队列和交换机进行一个绑定
        channel.queueBind("helloWorld","hello","hello");

Queue.BindOk queueBind(String queue, String exchange, String routingKey) throws IOException;
这个是java的绑定源代码,绑定关系不是应该使用BindingKey吗?这里使用了Routingkey
因为direct类型必须要RoutingKey和BindingKey一摸一样才匹配,这样就给我们了一个潜台词
这两个玩意就是一个东西。
channel.basicPublish("hello","hello",MessageProperties.TEXT_PLAIN,"pujinwen".getBytes());

3、topic
这是因为direct的不灵活性,因为一个全等于,让很多业务没办法写,所以出来了topic,他支持一个Routingkey和bindingKey的模糊匹配。支持模糊匹配符号。

4、header
性能很差 ,就不介绍了,是根据发送信息的信息header内容做匹配;

官方文档把这个BindingKey认为是一种特殊的Routingkey,所以我们都称之为路由键,

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,816评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,729评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,300评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,780评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,890评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,084评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,151评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,912评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,355评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,666评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,809评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,504评论 4 334
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,150评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,882评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,121评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,628评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,724评论 2 351

推荐阅读更多精彩内容

  • http://liuxing.info/2017/06/30/Spring%20AMQP%E4%B8%AD%E6%...
    sherlock_6981阅读 15,899评论 2 11
  • 概述 RabbitMQ是目前非常热门的一款消息中间件,不管是互联网行业还是传统行业都在大量地使用 。 Rabbit...
    Tian_Peng阅读 1,667评论 1 4
  • 什么叫消息队列? 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复...
    Agile_dev阅读 2,370评论 0 24
  • RabbitMQ简介 AMQP,即Advanced Message Queuing Protocol,高级消息队列...
    小波同学阅读 863评论 1 5
  • RabbitMQ优异性 RabbitMQ发展到今天,被越来越多的人认可,这和它在易用性、扩展性、可靠性和高可用性等...
    查无此人_chazz阅读 530评论 0 0