RabbitMQ学习总结

RabbitMQ消息队列

• Broker&＃xff1a;简单来说就是消息队列服务器实体。
• Exchange&＃xff1a;消息交换机&＃xff0c;它指定消息按什么规则&＃xff0c;路由到哪个队列。
• Queue&＃xff1a;消息队列载体&＃xff0c;每个消息都会被投入到一个或多个队列。
• Binding&＃xff1a;绑定&＃xff0c;它的作用就是把exchange和queue按照路由规则绑定起来。
• Routing Key&＃xff1a;路由关键字&＃xff0c;exchange根据这个关键字进行消息投递。
• vhost&＃xff1a;虚拟主机&＃xff0c;一个broker里可以开设多个vhost&＃xff0c;用作不同用户的权限分离。
• producer&＃xff1a;消息生产者&＃xff0c;就是投递消息的程序。
• consumer&＃xff1a;消息消费者&＃xff0c;就是接受消息的程序。

• channel&＃xff1a;消息通道&＃xff0c;在客户端的每个连接里&＃xff0c;可建立多个channel&＃xff0c;每个channel代表一个会话任务。

发送消息流程&＃xff1a;

1&＃xff0c;  获取Conection

2&＃xff0c;  获取Channel

3&＃xff0c;  定义Exchange&＃xff0c;Queue

4&＃xff0c;  使用一个RoutingKey将Queue Binding到一个Exchange上

5&＃xff0c;  通过指定一个Exchange和一个RoutingKey来将消息发送到对应的Queue上&＃xff0c;

6&＃xff0c;  接收方在接收时也是获取connection&＃xff0c;接着获取channel&＃xff0c;然后指定一个Queue直接到它关心的Queue上取消息&＃xff0c;它对Exchange&＃xff0c;RoutingKey及如何binding都不关心&＃xff0c;到对应的Queue上去取消息就OK了(这个是重点&＃xff0c;接收方&＃xff0c;只关心queue的名字即可&＃xff0c;其他的都不关心&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;)

换句话说&＃xff1a;

发送放关心&＃xff1a;ExchangName&＃xff0c; QueueName&＃xff0c;BindingKey

接收方关心&＃xff1a;QuueuName

Exchange

在RabbitMQ中有三种常用的转发方式&＃xff0c;分别是&＃xff1a;

DirectExchange&＃xff1a;路由键方式转发消息。
FanoutExchange&＃xff1a;广播方式转发消息。
TopicExchange&＃xff1a;主题匹配方式转发消息

1. Direct: 先策略匹配到对应绑定的队列后 才会被投送到该队列  交换机跟队列必须是精确的对应关系 这种最为简单
2. Topic: 转发消息主要是根据通配符。 在这种交换机下&＃xff0c;队列和交换机的绑定会定义一种路由模式&＃xff0c;那么&＃xff0c;通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息 这种可以认为是Direct 的灵活版  
3. Headers:也是根据规则匹配, 相较于 direct 和 topic 固定地使用 routingkey , headers 则是一个自定义匹配规则的类型
   在队列与交换器绑定时 会设定一组键值对规则 消息中也包括一组键值对( headers 属性) 当这些键值对有一对 或全部匹配时 消息被投送到对应队列
4. Fanout : 消息广播模式 不管路由键或者是路由模式 会把消息发给绑定给它的全部队列  如果配置了routingkey会被忽略

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

四个概念非常重要: 虚拟主机&＃xff08;virtual host&＃xff09;&＃xff0c;交换机&＃xff08;exchange&＃xff09;&＃xff0c;队列&＃xff08;queue&＃xff09;和绑定&＃xff08;binding&＃xff09;

  - 交换器&＃xff08;Exchange&＃xff09;&＃xff0c;它是发送消息的实体。

     - 队列&＃xff08;Queue&＃xff09;&＃xff0c;这是接收消息的实体。

     - 绑定器&＃xff08;Bind&＃xff09;&＃xff0c;将交换器和队列连接起来&＃xff0c;并且封装消息的路由信息。

Exchange指向Queue的黑色线—RoutingKey&＃xff0c;可以将它简单的理解为一条连接Exchange和Queue的路线

Exchange和Queue都需要通过channel来进行定义&＃xff0c;而RoutingKey则只需要在binding时取个名字就行了。