RabbitMQ消息队列模型

灰太狼 2021-12-04 01:11 342阅读 0赞

之前一直有了解rebbitmq，项目里也没用到，今天专门学习了一下，不得不说，消息队列中间件也是有其优势的 。

1） 同步变异步，当然可以使用线程池解决,但是缺点很明显:要自己实现线程池,并且强耦合，大多数是使用消息队列来解决。

2）流量削峰---秒杀系统

3）rabbitmq采用信道通信。不采用tcp直接通信

RabbitMQ提供了四种Exchange：fanout,direct,topic,header

RabbitMQ中，所有生产者提交的消息都由Exchange来接受，然后Exchange按照特定的策略转发到Queue进行存储

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70][]

AMQP协议模型

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 1][]

RabbitMq的整体架构

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 2][]

AMQP核心概念

Server: 又称Broker，接受客户端的连接，实现AMQP实体服务；
    
        Connection: 连接，应用程序与Broker的网络连接；
    
        Channel: 网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
    
        Message: 消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容。
    
        Virtual Host: 虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual Host里面可以有若干个Exchange或Queue，同一个Virtual Host里面不能有相同名称的Exchange或Queue。
    
        Exchange: 交换机，接收消息，根据路由键转发消息到绑定的队列。
    
        Binding: Exchange和Queue之间的虚拟连接，Binding中可以包含Routing Key。
    
        Routing Key: 一个路由规则，虚拟机可用它来确定如何路由一个特定消息。
    
        Queue: 也称为Message Queue，消息队列，保存消息并将它们转发给消费者。

RabbitMQ消息是如何流转的？

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 3][]

保障100%消息投递成功设计方案

Step1: 业务数据入库 BIZ DB
    Step1: 存储消息记录，入库 MSG DB，消息记录表
    
    消息状态:
        0: 消息发送中    1: 消息发送成功    2: 消息发送失败

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 4][]

参考链接：

[rabbitmq 的几种队列模型][rabbitmq]

[ rabbitmq的三种Exchange模式][rabbitmq_Exchange]

[RabbitMQ 为什么需要信道？为什么不是TCP直接通信？][RabbitMQ _TCP]

[深入理解AMQP协议][AMQP]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70]: /images/20211203/0a7bcb32119247fba88cac45ef05ef6e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 1]: /images/20211203/85ec0706de0b4552a26b92129cc641f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 2]: /images/20211203/73e5147333474203b468c03ce6c2a23c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 3]: /images/20211203/3692e6b7b90a4193951264582cf268c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3NzMyODI5_size_16_color_FFFFFF_t_70 4]: /images/20211203/b54d59750bef4d89a2c8a8bc54a4e5ef.png
[rabbitmq]: https://blog.csdn.net/qq_25911515/article/details/81464271
[rabbitmq_Exchange]: http://hwcrazy.com/34195c9068c811e38a44000d601c5586/be62fc2668c811e3adba000d601c5586/
[RabbitMQ _TCP]: https://www.cnblogs.com/quan-coder/p/8665752.html
[AMQP]: https://blog.csdn.net/weixin_37641832/article/details/83270778