您的位置:首页 > 其它

【RabbitMQ】生产者,消费者,信道,队列,交换器和绑定

2017-03-12 21:13 323 查看
  了解消息通信中的一些重点概念对于深化对RabbitMQ的理解有重要的意义;下面从生产者,消费者,信道,队列,交换器和绑定,来介绍他们在消息通信过程中的角色和作用;

生产者:

  创建消息,然后发布到代理服务器(RabbitMQ)

消费者:

连接到代理服务器(RabbitMQ)上,并订阅到队列上。不会知道谁是消息的生产者

整个过程:

生产者创建消息,消费者接收消息。

  消息:包括有效载荷与标签

    有效载荷:要传输的数据

    标签:描述有效载荷,并且RabbitMQ使用标签决定谁将获得消息的拷贝;

信道:

  生产者和消费者与代理服务器之间的通信必须建立一个信道。

为什么会有,作用?

  连接到RabbitMQ,才能消费或者发布消息,信道是建立在“”真实“”TCP连接内的虚拟连接。AMQP命令都是通过信道发送出去的。

TCP连接和信道的关系

  在应用程序与代理服务器之间创建一个TCP连接,TCP一旦打开,就会创建AMQP信道

  电缆相当于TCP,信道是一条独立光纤束,一条TCP连接上创建多少条信道是没有限制的。

为什么不使用TCP连接发送AMQP命令

  1.创建和销毁TCP会话,开销大

  2.如果使用TCP,每个线程连接到RabbitMQ,都要创建连接,造成浪费和性能瓶颈

  3.使用一个TCP连接,能够满足性能,并且保证线程私密性。效果更好。

队列:

  AMQP消息路由必须三部分:交换器,队列,绑定

  生产者把消息发布到交换器,消息最后到达队列,被消费者接收,绑定决定了消息如何从路由器路由到特定的队列。

队列是消息通信的基础模块

  1.为消息提供了处所,消息在此等待消费

  2.对负载均衡来说,队列是绝佳方案,让RabbitMQ循环的方式均匀分配消息。

  3.队列是Rabbit中消息的最后终点(除非消息进入“”黑洞“”)

  


交换器和绑定

  消费者从队列中获取消息,但是消息是如何到达队列的呢?

  将消息投递到队列时,通过把消息发送给交换器来完成。根据确定的规则,RabbitMQ会决定消息投递到那个队列。这个规则叫路由键(routing key),队列通过路由键绑定到交换器。当把消息发送发送到代理服务器时,消息将拥有一个路由键,RabbitMQ会将其和绑定使用的路由键进行匹配。匹配成功,消息会投递到队列,不匹配则进入黑洞

  


  使用交换机和绑定完成解耦,对于发送消息给服务器的一方来说,不需要关系服务器另一端的逻辑。服务器会根据路由键将消息从交换器路由到队列。

  在AMQP中定义类4种类型的交换器:direct,fanout,topic和header。header交换器与其他3个不同,它允许匹配AMQP消息的header而不是路由键,不常用;

消息队列的使用过程大概如下:

  (1)客户端连接到消息队列服务器,打开一个channel。

  (2)客户端声明一个exchange,并设置相关属性。

  (3)客户端声明一个queue,并设置相关属性。

  (4)客户端使用routing key,在exchange和queue之间建立好绑定关系。

  (5)客户端投递消息到exchange。

  (6)exchange接收到消息后,就根据消息的key和已经设置的binding,进行消息路由,将消息投递到一个或多个队列里。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: