淘先锋技术网

首页 1 2 3 4 5 6 7

MQ:
消息队列(Message Queue),由消息系统来确保消息传递的可靠性
作用:异步处理,解耦合,削峰填谷
AMQP:
Advanced Message Queuing Protocol,高级消息队列协议它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制。
JMS:
Java 消息服务(Java Message Service) 应用程序接口是一个 Java 平台中关于面向消息中间件(MOM)的 API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。
Erlang:
最初用于交换机领域的架构模式,这样使得RabbitMQ在Broker之间进行数据交互的性能非常优秀(Erlang有着和原生Socket一样的延迟)。

RabbitMQ:
提供了6种模式:简单模式,work模式,Publish/Subscribe发布与订阅模式,Routing路由模式,Topics主题模式,RPC远程调用模式(远程调用,不太算MQ;暂不作介绍);
在这里插入图片描述

RabbitMQ各组件功能:
在这里插入图片描述

Broker:标识消息队列服务器实体.
Virtual Host:虚拟主机。标识一批交换机、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质上就是一个mini版的RabbitMQ服务器,拥有自己的队列、交换器、绑定和权限机制。vhost是AMQP概念的基础,必须在链接时指定,RabbitMQ默认的vhost是 /。
Exchange:交换器,用来接收生产者发送的消息并将这些消息路由给服务器中的队列。
Queue:消息队列,用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面,等待消费者连接到这个队列将其取走。
Banding:绑定,用于消息队列和交换机之间的关联。一个绑定就是基于路由键将交换机和消息队列连接起来的路由规则,所以可以将交换器理解成一个由绑定构成的路由表。
Channel:信道,多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟链接,AMQP命令都是通过信道发出去的,不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成。因为对于操作系统来说,建立和销毁TCP都是非常昂贵的开销,所以引入了信道的概念,以复用一条TCP连接。
Connection:网络连接,比如一个TCP连接。
Publisher:消息的生产者,也是一个向交换器发布消息的客户端应用程序。
Consumer:消息的消费者,表示一个从一个消息队列中取得消息的客户端应用程序。
Message:消息,消息是不具名的,它是由消息头和消息体组成。消息体是不透明的,而消息头则是由一系列的可选属性组成,这些属性包括routing-key(路由键)、priority(优先级)、delivery-mode(消息可能需要持久性存储[消息的路由模式])等。

RabbitMQ高级特性:
rabbitmq 整个消息投递的路径为:
producer —> rabbitmq broker —> exchange —> queue —> consumer
消息从 producer 到 exchange 则会返回一个 confirmCallback 。
消息从 exchange 到 queue 投递失败则会返回一个 returnCallback 。
1、confirm确认模式:

  1. 确认模式开启:ConnectionFactory中开启publisher-confirms=“true”
  2. 在rabbitTemplate定义ConfirmCallBack回调函数
    2、Return回退模式:
  3. 开启回退模式:publisher-returns=“true”
  4. 设置ReturnCallBack
  5. 设置Exchange处理消息的模式:
  6. 如果消息没有路由到Queue,则丢弃消息(默认)
  7. 如果消息没有路由到Queue,返回给消息发送方ReturnCallBack
    3、TTL:
    TTL 全称 Time To Live(存活时间/过期时间)。当消息到达存活时间后,还没有被消费,会被自动清除。RabbitMQ可以对消息设置过期时间,也可以对整个队列(Queue)设置过期时间。
    4、死信队列(DLX):
    当消息成为Dead message后,可以被重新发送到另一个交换机,这个交换机就是DLX。
    在这里插入图片描述

消息成为死信的三种情况:
队列消息长度到达限制;
消费者拒接消费消息,basicNack/basicReject,并且不把消息重新放入原目标队列,requeue=false;
原队列存在消息过期设置,消息到达超时时间未被消费;

5、延迟队列:
延迟队列,即消息进入队列后不会立即被消费,只有到达指定时间后,才会被消费。
在rabbitMQ中未提供延迟队列的功能,可以通过TTL+死信队列完成此项功能
在这里插入图片描述

RabbitMQ应用问题
1、消息可靠性保障
提出需求:如何能够保证消息的 100% 发送成功?
首先大家要明确任何一个系统都不能保证消息的 100% 投递成功,我们是可以保证消息以最高最可靠的发送给目标方。
在RabbitMQ中采用 消息补充机制 来保证消息的可靠性
在这里插入图片描述

步骤分析:
参与部分:消息生产者、消息消费者、数据库、三个队列(Q1、Q2、Q3)、交换机、回调检查服务、定时检查服务
消息的生产者将业务数据存到数据库中
发送消息给 队列Q1
消息的生产者等待一定的时间后,在发送一个延迟消息给队列 Q3
消息的消费方监听 Q1 队列消息,成功接收后
消息的消费方会 发送 一条确认消息给 队列Q2
回调检查服务监听 队列Q2 发送的确认消息
回调检查服务接收到确认消息后,将消息写入到 消息的数据库表中
回调检查服务同时也会监听 队列Q3延迟消息, 如果接收到消息会和数据库比对消息的唯一标识
如果发现没有接收到确认消息,那么回调检查服务就会远程调用 消息生产者,重新发送消息
重新执行 2-7 步骤,保证消息的可靠性传输
如果发送消息和延迟消息都出现异常,定时检查服务会监控 消息库中的消息数据,如果发现不一致的消息然后远程调用消息的生产者重新发送消息。
2、消息幂等性处理
幂等性指一次和多次请求某一个资源,对于资源本身应该具有同样的结果。也就是说,其任意多次执行对资源本身所产生的影响均与一次执行的影响相同。
在MQ中指,消费多条相同的消息,得到与消费该消息一次相同的结果。
在本教程中使用 乐观锁机制 保证消息的幂等操作
在这里插入图片描述