标签：出现 数据一致性 提高 处理 routing 单词 生产 alt 异步通信
1、mq的应用场景：
1） 对于数据量大或者处理耗时长的操作，我们可以引入 MQ 实现异步通信，减少客户端的等待，提升响应速度。
2） 对于改动影响大的系统之间，可以引入 MQ 实现解耦，减少系统之间的直接依赖。
3） 对于会出现瞬间的流量峰值的系统，我们可以引入 MQ 实现流量削峰，达到保护应用和数据库的目的
2、使用消息队列带来的问题：
1）系统可用性降低：原来是两个节点的通信，现在还需要独立运行一个服务，如果 MQ 服务器或者通信网络出现问题，就会导致请求失败。
2）系统复杂性提高： 为什么说复杂？
第一个就是你必须要理解相关的模型和概念，才能正确地配置和使用 MQ。
第二个，使用 MQ 发送消息必须要考虑消息丢失和消息重复消费的问题。一旦消息没有被正确地消费，就会带来数据一致性的问题
3、rabbitmq简介：
3-1、基本特性：
1）高可靠：RabbitMQ 提供了多种多样的特性让你在可靠性和性能之间做出权衡，包括持久化、发送应答、发布确认以及高可用性。
2）灵活的路由：通过交换机（Exchange）实现消息的灵活路由。
3）支持多客户端：对主流开发语言（Python、Java、Ruby、PHP、C#、JavaScript、 Go、Elixir、Objective-C、Swift 等）都有客户端实现。
4）集群与扩展性：多个节点组成一个逻辑的服务器，支持负载。
5）高可用队列：通过镜像队列实现队列中数据的复制。
6）权限管理：通过用户与虚拟机实现权限管理。
7）插件系统：支持各种丰富的插件扩展，同时也支持自定义插件。
8）与 Spring 集成：Spring 对 AMQP 进行了封装。
3-2、AMQP协议
AMQP：高级消息队列协议，是一个工作于应用层的协议
除了 RabbitMQ 之外，AMQP 的实现还有 OpenAMQ、Apache Qpid、RedhatEnterprise MRG、AMQP Infrastructure、ØMQ、Zyre。
除了 AMQP 之外，RabbitMQ 支持多种协议，STOMP、MQTT、HTTP and WebSockets。
可以使用 WireShark 等工具对 RabbitMQ 通信的 AMQP 协议进行抓包。
3-2rabbitmq的工作模型
1）、Broker：RabbitMQ 的服务，默认是 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）、Vhost：VHOST 可以提高硬件资源的利用率，还可以实现资源的隔离和权限的控制。它的作用类似于编程语言中的 namespace 和 package，不同的 VHOST 中可以有同名的 Exchange 和 Queue，它们是完全透明的。
如果某个业务系统不想跟别人混用一个系统，怎么办？
这个时候，我们可以为不同的业务系统创建不同的用户（User），然后给这些用户分配 VHOST 的权限。比如给风控系统的用户分配风控系统的 VHOST 的权限，这个用户可以访问里面的交换机和队列。给超级管理员分配所有 VHOST 的权限。
7）、消息的路由方式：
（1）直连（Direct）：队列与直连类型的交换机绑定，需指定一个精确的绑定键。生产者发送消息时会携带一个路由键。只有当路由键与其中的某个绑定键完全匹配
时，这条消息才会从交换机路由到满足路由关系的此队列上。
例 如 ： channel.basicPublish(“MY_DIRECT_EXCHANGE”,”spring”,”msg1”); 只有第一个队列能收到消息
（2）主题（topic）：
解读：第一个队列支持路由键以 excel 开头的消息路由，后面可以有单词，也可以没有。
第二个队列支持路由键以 word开头，并且后面是一个单词的消息路由。
第三个队列支持路由键以 ppt结尾，并且前面是一个单词的消息路由。
例如：
channel.basicPublish("MY_TOPIC_EXCHANGE","excel .fjd.klj","msg 2"); 只有第一个队列能收到消息。
channel.basicPublish("MY_TOPIC_EXCHANGE","excel.ppt", "msg 3"); 第一个队列和第三个队列能收到消息。
（3）广播（fanout）：
主题类型的交换机与队列绑定时，不需要指定绑定键。因此生产者发送消息到广播类型的交换机上，也不需要携带路由键。消息达到交换机时，所有与之绑定了的队列，
都会收到相同的消息的副本。
例如：channel.basicPublish("MY_FANOUT_EXCHANGE", "", "msg 4"); 三个队列都会收到 msg4。
标签：出现 数据一致性 提高 处理 routing 单词 生产 alt 异步通信
原文地址：https://www.cnblogs.com/sunny-miss/p/13173490.html
