初学RabbitMQ

Posted 2020-07-19 ck168

一、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、手动应答。具体实现如下。