RabbitMQ的介绍-Toy模板网

这篇具有很好参考价值的文章主要介绍了RabbitMQ的介绍。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

为什么使用 MQ？

流量削峰和缓冲
如果订单系统最多能处理一万次订单，这个处理能力在足够应付正常时段的下单，但是在高峰期，可能会有两万次下单操作，订单系统只能处理一万次下单操作，剩下的一万次被阻塞。我们可以使用消息队列做缓冲，取消这个限制，把一秒内下的订单分散成一段时间来处理，减少了系统的压力，增强了用户的体验效果。
应用解耦
不同的应用程序可以通过消息队列的方式解耦，生产者和消费者之间不需要直接相互通信，而是通过共享的消息队列进行通信。应用解耦使系统更灵活。
异步处理
在秒杀任务中，大量用户下单时，将订单信息和库存信息保存在缓存中，之后使用消息队列的更改数据库中的数据。

	RabbitMQ	ActiveMQ	RocketMQ	Kafka
公司/社区	Rabbit	Apache	阿里	Apache
开发语言	Erlang	Java	Java	Scala&Java
协议支持	AMQP，XMPP，SMTP，STOMP	OpenWire,STOMP，REST,XMPP,AMQP	自定义协议	自定义协议
可用性	高	一般	高	高
单机吞吐量	一般	差	高	非常高
消息延迟	微秒级	毫秒级	毫秒级	毫秒以内
消息可靠性	高	一般	高	一般

追求可用性：Kafka、 RocketMQ 、RabbitMQ

追求可靠性：RabbitMQ、RocketMQ

追求吞吐能力：RocketMQ、Kafka

追求消息低延迟：RabbitMQ、Kafka

RabbitMQ的介绍,RabbitMQ,rabbitmq,分布式,中间件

Publisher：生产者，也就是要发送消息的程序，但是不再发送到队列中，而是发给交换机
Exchange：交换机。一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange有以下3种类型：
- Fanout：广播，将消息交给所有绑定到交换机的队列
- Direct：定向，把消息交给符合指定routing key 的队列
- Topic：通配符，把消息交给符合routing pattern（路由模式）的队列
Consumer：消费者，与以前一样，订阅队列，没有变化
Queue：消息队列也与以前一样，接收消息、缓存消息。

Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

RabbitMQ的介绍,RabbitMQ,rabbitmq,分布式,中间件文章来源地址https://www.toymoban.com/news/detail-850769.html

Broker：
接收和分发消息的应用，RabbitMQ Server 就是 Message Broker
Virtual host
出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时，可以划分出多个 vhost，每个用户在自己的 vhost 创建 exchange／queue 等，实现不同服务之间的隔离。
Connection
publisher／consumer 和 broker 之间的 TCP 连接。
Channel
如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立 TCP Connection 的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程序支持多线程，通常每个 thread 创建单独的 channel 进行通讯，AMQP method 包含了 channel id 帮助客户端和 message broker 识别 channel，所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销。

到了这里，关于RabbitMQ的介绍的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！