Rabbitmq应用场景

shenzhenzsw 2020-06-21

1mq的应用场景:

1) 对于数据量大或者处理耗时长的操作,我们可以引入 MQ 实现异步通信,减少客户端的等待,提升响应速度。

2) 对于改动影响大的系统之间,可以引入 MQ 实现解耦,减少系统之间的直接依赖。

3) 对于会出现瞬间的流量峰值的系统,我们可以引入 MQ 实现流量削峰,达到保护应用和数据库的目的

2、使用消息队列带来的问题:

1)系统可用性降低:原来是两个节点的通信,现在还需要独立运行一个服务,如果 MQ 服务器或者通信网络出现问题,就会导致请求失败。

2)系统复杂性提高: 为什么说复杂?

第一个就是你必须要理解相关的模型和概念,才能正确地配置和使用 MQ

第二个,使用 MQ 发送消息必须要考虑消息丢失和消息重复消费的问题。一旦消息没有被正确地消费,就会带来数据一致性的问题

3rabbitmq简介

3-1、基本特性:

1)高可靠:RabbitMQ 提供了多种多样的特性让你在可靠性和性能之间做出权衡,包括持久化、发送应答、发布确认以及高可用性。

2)灵活的路由:通过交换机(Exchange)实现消息的灵活路由。

3)支持多客户端:对主流开发语言(PythonJavaRubyPHPC#JavaScriptGoElixirObjective-CSwift 等)都有客户端实现。

4)集群与扩展性:多个节点组成一个逻辑的服务器,支持负载。

5)高可用队列:通过镜像队列实现队列中数据的复制。

6)权限管理:通过用户与虚拟机实现权限管理。

7)插件系统:支持各种丰富的插件扩展,同时也支持自定义插件。

8)与 Spring 集成:Spring AMQP 进行了封装。

3-2AMQP协议

AMQP:高级消息队列协议,是一个工作于应用层的协议

 Rabbitmq应用场景

除了 RabbitMQ 之外,AMQP 的实现还有 OpenAMQApache QpidRedhatEnterprise MRGAMQP InfrastructureØMQZyre

除了 AMQP 之外,RabbitMQ 支持多种协议,STOMPMQTTHTTP and WebSockets

可以使用 WireShark 等工具对 RabbitMQ 通信的 AMQP 协议进行抓包。

3-2rabbitmq的工作模型

 Rabbitmq应用场景

1)、BrokerRabbitMQ 的服务,默认是 5672 的端口。中文翻译是代理/中介,MQ 服务器帮助我们做的事情就是存储、转发消息。

2)、Connection:无论是生产者发送消息,还是消费者接收消息,都必须要跟 Broker 之间建立一个连接,这个连接是一个TCP 的长连接。

3)、Channel:如果所有的生产者发送消息和消费者接收消息,都直接创建和释放 TCP 长连接的话,对于 Broker 来说肯定会造成很大的性能损耗,因为 TCP 连接是非常宝贵的资源,创建和释放也要消耗时间。所以在 AMQP 里面引入了 Channel 的概念,它是一个虚拟的连接。我们把它翻译成通道,或者消息信道。这样我们就可以在保持的 TCP 长连接里面去创建和释放Channel,大大了减少了资源消耗。另外一个需要注意的是,Channel RabbitMQ 原生 API 里面的最重要的编程接口,也就是说我们定义交换机、队列、绑定关系,发送消息消费消息,调用的都是 Channel 接口上的方法。

4)、Queue:队列是真正用来存储消息的,是一个独立运行的进程,有自己的数据库(Mnesia)。

消费者获取消息有两种模式

一种是 Push 模式,只要生产者发到服务器,就马上推送给消费者。

另一种是 Pull 模式,消息存放在服务端,只有消费者主动获取才能拿到消息

我们可以基于事件机制,实现消费者对队列的监听由于队列有 FIFO 的特性,只有确定前一条消息被消费者接收之后,才会把这条消息从数据库删除,继续投递下一条消息。

5)、Exchange:在RabbitMQ 里面永远不会出现消息直接发送到队列的情况。因为在 AMQP 里面引入了交换机(Exchange)的概念,用来实现消息的灵活路由。

交换机是一个绑定列表,用来查找匹配的绑定关系。队列使用绑定键(Binding Key)跟交换机建立绑定关系。生产者发送的消息需要携带路由键(Routing Key),交换机收到消息时会根据它保存的绑定列表,决定将消息路由到哪些与它绑定的队列上。

注意:交换机与队列、队列与消费者都是多对多的关系。

6)、VhostVHOST 可以提高硬件资源的利用率,还可以实现资源的隔离和权限的控制。它的作用类似于编程语言中的 namespace package,不同的 VHOST 中可以有同名的 Exchange Queue,它们是完全透明的。

如果某个业务系统不想跟别人混用一个系统,怎么办?

这个时候,我们可以为不同的业务系统创建不同的用户(User),然后给这些用户分配 VHOST 的权限。比如给风控系统的用户分配风控系统的 VHOST 的权限,这个用户可以访问里面的交换机和队列。给超级管理员分配所有 VHOST 的权限。

7)、消息的路由方式:

1)直连(Direct):队列与直连类型的交换机绑定,需指定一个精确的绑定键。生产者发送消息时会携带一个路由键。只有当路由键与其中的某个绑定键完全匹配

时,这条消息才会从交换机路由到满足路由关系的此队列上。

Rabbitmq应用场景

channel.basicPublish(MY_DIRECT_EXCHANGE,spring,msg1); 只有第一个队列能收到消息

(2)主题(topic):

 Rabbitmq应用场景

解读:第一个队列支持路由键以 excel 开头的消息路由,后面可以有单词,也可以没有。

第二个队列支持路由键以 word开头,并且后面是一个单词的消息路由。

第三个队列支持路由键以 ppt结尾,并且前面是一个单词的消息路由。

例如:

channel.basicPublish("MY_TOPIC_EXCHANGE","excel .fjd.klj","msg 2"); 只有第一个队列能收到消息。

channel.basicPublish("MY_TOPIC_EXCHANGE","excel.ppt", "msg 3"); 第一个队列和第三个队列能收到消息。

(3)广播(fanout):

主题类型的交换机与队列绑定时,不需要指定绑定键。因此生产者发送消息到广播类型的交换机上,也不需要携带路由键。消息达到交换机时,所有与之绑定了的队列,

都会收到相同的消息的副本。

 Rabbitmq应用场景

例如:channel.basicPublish("MY_FANOUT_EXCHANGE", "", "msg 4"); 三个队列都会收到 msg4

相关推荐