码迷,mamicode.com
首页 > 其他好文 > 详细

初学RabbitMQ

时间:2016-06-02 23:15:21      阅读:179      评论:0      收藏:0      [点我收藏+]

标签:

一、RabbitMQ中的一些概念

 (1)Connection(连接)

  与RabbitMQ建立连接,由ConnectionFactory创建每个Connection至于一个物理server进行连接,此链接基于Socket进行连接,可以理解为一个dbConnection

 (2)Channel(通道)

  在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务

 (3)Exchange(交换器)

   交换机,决定了消息路由规则,路由到哪个队列。

 (4)Queue(队列)

   消息队列载体,每个消息都会被投入到一个或多个队列。

 (5)Bind(绑定器)

  把exchange和queue按照路由规则绑定起来

 (6)RoutingKey(路由关键字最多不能超过255个字符)

  exchange根据这个关键字进行消息投递

二、消息队列使用过程

  (1)客户端连接到消息服务器
    (2)打开一个channel
    (3)声明一个exchange并设置属性
    (4)声明一个queue并设置属性
    (5)使用Routing key在exchange和queue之间绑定关系
    (6)客户端消息发送到exchange
    (7)Exchange接受到消息,根据key和已经设置的bingding,进行消息路由,将消息发送到一个或多个队列中
    (8)消费者消费
 
三、这个过程走分三个部分:
  (1)客户端(生产消息队列)
    (2)RabbitMQ服务端(负责路由规则的绑定与消息的分发)
    (3)客户端(消费消息队列中的消息)
 
四、一个消息可以走一次网络却被分发到不同的消息队列中,然后被多个的客户端消费,那么这个过程就是RabbitMQ的核心机制,RabbitMQ的路由类型与消费模式
 
五、RabbitMQ中Exchange的类型

类型有4种,direct,fanout,topic,headers。其中headers不常用,本篇不做介绍,其他三种类型,会做详细介绍。

    (1)Exchange类型direct
        他是根据交换器名称与routingkey来找队列的。

Note:消息从client发出,传送给交换器ChangeA,RoutingKey为routingkey.ZLH,那么不管你发送给Queue1,还是Queue2一个消息都会保存在Queue1,Queue2,Queue3,三个队列中。这就是交换器的direct类型的路由规则。只要找到路由器与routingkey绑定的队列,那么他有多少队列,他就分发给多少队列。

    (2)Exchange类型fanout
        这个类型忽略Routingkey,他为广播模式。

Note:消息从客户端发出,只要queue与exchange有绑定,那么他不管你的Routingkey是什么他都会将消息分发给所有与该exchang绑定的队列中。

    (3)Exchange类型topic
        这个类型的路由规则如果你掌握啦,那是相当的好用,与灵活。他是根据RoutingKey的设置,来做匹配的,其中这里还有两个通配符为:

*,代表任意的一个词。例如topic.zlh.*,他能够匹配到,topic.zlh.one ,topic.zlh.two ,topic.zlh.abc, ....

#,代表任意多个词。例如topic.#,他能够匹配到,topic.zlh.one ,topic.zlh.two ,topic.zlh.abc, ....

 

六、消息队列的消费与消息确认Ack

  (1)消息队列的消费

Note:如果一个消息队列中有大量消息等待操作时,我们可以用多个客户端来处理消息,这里的分发机制是采用负载均衡算法中的轮询。第一个消息给A,下一个消息给B,下下一个消息给A,下下下一个消息给B......以此类推。

    (2)为啦保证消息的安全性,保证此消息被正确处理后才能在服务端的消息队列中删除。那么rabbitmq提供啦ack应答机制,来实现这一功能。

ack应答有两种方式:1、自动应答,2、手动应答。具体实现如下。

 

 

初学RabbitMQ

标签:

原文地址:http://www.cnblogs.com/ck168/p/5554470.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!