消息总线。简单理解就是一个消息中心,众多微服务实例可以连接到总线上,实例可以往消息中心发送或接收信息(通过监听)。
比如:实例A发送一条消息到总线上,总线上的实例B可以接收到信息(实例B订阅了实例A),这样的话,消息总线就充当一个中间者的角色,使得实例A和实例B解偶了,很方便。
消息总线(Spring Cloud Bus)
原理
Spring Cloud Bus通过建立多个应用之间的通信频道,管理和传播应用间的消息,从技术角度来说,应用了AMQP消息代理作为通道,通过MQ的广播机制实现消息的发送和接收。
以其典型应用——配置中心客户端刷新为例,说明下工作流程:
(1)修改配置文件,触发webhook向clientA发送bus/refresh;
(2)clientA重新从配置中心获取新的配置信息,同时发送消息到Spring Cloud Bus;
(3)Spring Cloud Bus收到消息,同时通知clientB、clientC(订阅配置更新事件);
(4)clientB、clientC收到通知,重新请求配置中心,获取新的配置信息。
这样,三个客户端均得到最新的配置。
消息代理
这个过程中,作为通道的AMQP消息代理很重要。
AMQP(高级消息队列协议,是一个标准)是一个网络协议,从扮演角色来说,消息代理从生产者(producers)那儿接收消息,并根据既定的路由规则把接收到的消息发送给处理消息的消费者(consumers),这个过程中的发布者,消费者,消息代理可以存在于不同的设备上,下面简单介绍下工作流程(其实跟上面的类似):
消息(message)被发布者(publisher)发送给交换机(exchange),交换机常常被比喻成邮局或者邮箱。然后交换机将收到的消息根据路由规则分发给绑定的队列(queue)。
最后AMQP代理会将消息投递给订阅了此队列的消费者,或者消费者按照需求自行获取。
AMQP作为一个标准协议,主要实现方案有RabbitMQ、ActiveMQ、Qpid等。
这里我主要以RabbitMQ为例进行说明,它是一个优秀的微服务架构消息中间件,与Spring Cloud Bus能够很好的结合使用。
下图显示了RabbitMQ的Web管理首页:
(1)Broker:消息队列服务器,即负责接收生产者消息,发送至消费者的;
(2)Connections:连接,即发送者、消息接收者、消费者之间的物理连接;
(3)Channel:通道,连接生产者、消费者的逻辑结构。一个Connection可以对应多个Channel;
(4)Exchange:消息交换机,消息第一个到达的地方,可以指定路由规则,决定消息分发到不同的消息队列中去;
(5)Queue:消息队列,消息经Exchange路由转发至此,进入逻辑等待状态(等待消费,即客户端获取);
(6)Binding:绑定,把Exchange和Queue按照路由规则进行绑定,即决定Exchange接收消息后,需要发送到哪些Queue中: