SpringBoot2.x系列教程62--SpringBoot整合消息队列之AMQP协议

2020-04-21 09:51:12

SpringBoot2.x系列教程62--SpringBoot整合消息队列之AMQP协议

作者：一一哥

一. AMQP 协议概述

AMQP的全称为Advanced Message Queuing Protocl,即消息队列协议,它是应用层协议的一个开放标准,为面向消息的中间件而设计.该协议主要用于制定基于队列进行消息传递的开放标准.

消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然.AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全.

二. AMQP 协议的核心概念

虚拟主机vhost;
连接Connection;
信道Channel;
数据交换器Exchanger;
队列Queue;
交换器与队列之间的绑定Binding;
统一负责消息接收和分发的服务端Broker.

由于RabbitMQ是基于AMQP协议实现的,故在RabbitMQ的实现当中也是围绕对这些概念进行内部功能组件的设计,并将这些组件整合起来提供一个完整的消息队列服务.

三. AMQP 的消息流程

AMQP协议规定,AMQP消息必须有三部分构成: 交换机,队列和绑定. 生产者把消息发送到交换机,交换机与队列的绑定关系决定了消息如何路由到特定的队列,终被消费者接收.

注意:

消息是不能直接到达队列(Queue)的.

四. AMQP 的交换机

在AMQP协议中,消息实际上是被投递到交换机,然后具体路由到哪个队列由交换机根据路由键(routing key)完成.

当你发消息到代理服务器时,即便路由键是空的,RabbitMQ也会将其和使用的路由键进行匹配.如果路由的消息不匹配任何绑定模式,消息将会被丢弃.

交换机在队列与消息中间起到了中间层的作用,有了交换机我们可以实现更灵活的功能,RabbitMQ中有三种常用的交换机类型.

可以理解direct为1v1,fanout为1v所有,topic可以1v任意.

五. AMQP 中的消息路由策略

1. 消息路由概述

AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别,AMQP 中增加了 Exchange 和 Binding 的角色.生产者把消息发布到 Exchange 上,消息终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列.

2. Exchange 类型

Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型:direct、fanout、topic、headers. headers 匹配 AMQP 消息的 header 而不是路由键,headers 交换器和 direct 交换器完全一致,但性能差很多,目前几乎用不到了,所以常用的是另外三种类型.

1️⃣. direct类型

消息中的路由键(routing key)如果和 Binding 中的 binding key 一致,交换器就将消息发到对应的队列中,路由键与队列名完全匹配.如果一个队列绑定到的交换机要求路由键为“dog”,则只转发 routing key 标记为“dog”的消息,不会转发“dog.puppy”,也不会转发“dog.guard”等.它是完全匹配、单播的模式.

2️⃣. fanout类型