RabbitMQ原理及实现

一、RabbitMQ核心概念以及工作原理

我们来看看流行的RabbitMQ消息系统以及它是如何让你的系统之间进行解耦的。

英文原文

RabbitMQ原理及实现

RabbitMQ除了像兔子一样跑的很快以外，还有这些特点：

MQ典型应用场景：

异步处理。把消息放入消息中间件中，等到需要的时候再去处理。
流量削峰。例如秒杀活动，在短时间内访问量急剧增加，使用消息队列，当消息队列满了就拒绝响应，跳转到错误页面，这样就可以使得系统不会因为超负载而崩溃。
日志处理
应用解耦。假设某个服务A需要给许多个服务（B、C、D）发送消息，当某个服务（例如B）不需要发送消息了，服务A需要改代码再次部署；当新加入一个服务（服务E）需要服务A的消息的时候，也需要改代码重新部署；另外服务A也要考虑其他服务挂掉，没有收到消息怎么办？要不要重新发送呢？是不是很麻烦，使用MQ发布订阅模式，服务A只生产消息发送到MQ，B、C、D从MQ中读取消息，需要A的消息就订阅，不需要了就取消订阅，服务A不再操心其他的事情，使用这种方式可以降低服务或者系统之间的耦合。

我们来简单看看RabbitMQ是如何工作的。

首先来看看RabbitMQ里的几个重要概念：

生产者（Producer）发送/发布消息到代理->消费者（Consumer）从代理那里接收消息。哪怕生产者和消费者运行在不同的机器上，RabbitMQ也能扮演代理中间件的角色。

当生产者发送消息时，它并不是直接把消息发送到队列里的，而是使用交换机（Exchange）来发送。下面的设计图简单展示了这三个主要的组件之间是如何连接起来的。

交换机代理（exchange agent）负责把消息分发到不同的队列里。这样的话，消息就能够从生产者发送到交换机，然后被分发到消息队列里。这就是常见的“发布”方法。

RabbitMQ原理及实现

Producer

然后，消息会被消费者从队列里读取并消费，这就是“消费”。

对一个复杂的应用而言，往往会有多个消息队列，所以消息也会被发往多个队列。

RabbitMQ原理及实现

Multiple queues

给带有多个队列的交换机发送的消息是通过绑定和路由键来进行分发的。绑定是你设置的用来连接一个队列和交换机的连接。路由键是消息的一个属性。交换机会根据路由键来决定消息分发到那个队列里（取决于交换机的类型）。

消息并不是直接发布到队里里的，而是被生产者发送到一个交换机上。交换机负责把消息发布到不同的队列里。交换机从生产者应用上接收消息，然后根据绑定和路由键将消息发送到对应的队列里。绑定是交换机和队列之间的一个关系连接。

RabbitMQ原理及实现

Exchange

生产者（producer）把消息发送给交换机。当你创建交换机的时候，你需要指定类型。交换机的类型接下来会讲到。
交换机（exchange）接收消息并且负责对消息进行路由。根据交换机的类型，消息的多个属性会被使用，例如路由键。
绑定（binding）需要从交换机到队列的这种方式来进行创建。在这个例子里，我们可以看到交换机有到两个不同队列的绑定。交换机根据消息的属性来把消息分发到不同的队列上。
消息（message）消息会一直留在队列里直到被消费。
消费者（consumer）处理消息。

RabbitMQ原理及实现

Exchange Type

RabbitMQ Tutorial with Publish/Subscribe Example – 这篇文章里会讲解RabbitMQ，并一步一步来搭建一个”生产者/消费者“的实例。

参考：

https://www.cnblogs.com/sgh1023/p/11217017.html

https://www.jianshu.com/p/256c502d09cd

发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/211343.html原文链接：https://javaforall.net