第二章 初识RabbitMQ

时间:2024-10-14 07:01:25

目录

一、介绍

二、RabbitMQ的主要特性及应用场景

2.1. 主要特性

2.2. 应用场景

2.3. RabbitMQ的整体架构及核心概念

2.4. MQ的比较与选择


RabbitMQ官网地址:
https://www.rabbitmq.com/docs

一、介绍

 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,由以高性能、健壮以及可伸缩性出名的 Erlang 写成。能够处理大量的并发消息,适用于高吞吐量的应用场景。它支持多种消息协议和安全机制,提供丰富的监控和管理工具,方便运维人员实时监控系统状态和性能指标。RabbitMQ广泛应用于分布式系统、集成系统、子系统之间的对接,以及高并发场景下的流量削峰填谷和数据解耦等任务。‌

RabbitMQ支持下列多种编程语言

Python

Java

Ruby

PHP

C#

JavaScript

Go

Elixir

Objective-C

Swift

二、RabbitMQ的主要特性及应用场景

2.1. 主要特性

可靠性‌:确保消息不会丢失,即使是在网络分区或节点故障的情况下。

灵活的路由‌:支持复杂的消息路由,允许消息根据内容路由到不同的队列。

多种协议支持‌:基于AMQP协议,与其他消息中间件兼容。

高可用性和扩展性‌:支持集群和分布式部署,能够处理高并发和大规模消息处理。

丰富的管理工具‌:提供Web管理界面,方便监控和管理消息队列的状态。

2.2. 应用场景

包括但不限于:

高并发处理‌:在电商平台的秒杀活动中,通过队列缓冲请求,减少服务器压力。

分布式系统集成‌:在微服务架构中,实现服务之间的解耦和异步通信。

任务调度‌:将任务分发到不同的处理节点,提高系统的整体效率。

RabbitMQ的安装和使用相对简单,支持多种部署方式,包括单机和集群模式,适合从小型应用到大型企业的各种规模的应用场景。

2.3. RabbitMQ的整体架构及核心概念

virtual-host(虚拟主机):起到数据隔离的作用

publisher:消息发送者

consumer:消息的消费者

queue(队列):用来存储消息直到消费者处理。

exchange(交换机):负责路由消息,用来接收生产者发送的消息,并且按照一定的规则将消息路由到消息队列。 

绑定(Binding):一个规则,用于告诉交换器消息应该被如何路由到队列。

信道(Channel):建立在连接之上的虚拟连接,RabbitMQ操作都是在信道中进行。

连接(Connection):RabbitMQ客户端和代理服务器之间的TCP连接。

2.4. MQ的比较与选择

在选择消息队列(MQ)时,需要考虑的核心因素包括系统的吞吐量、可靠性、可用性、扩展性以及与现有技术的兼容性。‌ 根据这些因素,以下几种消息队列系统在性能和适用场景上有各自的优势和劣势,ActiveMQ由于它的性能可靠性等各方面都比较差,在实际项目中我们通常是不会使用:

1‌. RabbitMQ‌:

‌特点‌:RabbitMQ是一个轻量级的消息队列系统,部署和使用都非常简单。

‌适用场景‌:适合对性能要求不是特别高,但需要易用性和灵活性的场景。

‌缺点‌:在大量消息堆积时,性能会急剧下降;使用小众语言Erlang开发,扩展和二次开发维护成本较高。

2‌. RocketMQ‌:

‌特点‌:由阿里开发,侧重于消息的顺序投递,具有高吞吐量和可靠性。

‌适用场景‌:适合处理高吞吐量的在线业务场景,如交易系统中的订单处理。

‌缺点‌:与周边生态系统的集成和兼容程度略逊于其他系统。

3‌. Kafka‌:

‌特点‌:Kafka是一个成熟的消息队列产品,支持高可靠性和稳定性。

‌适用场景‌:适合处理大量数据,适用于需要高吞吐量和容错性的场景。

‌缺点‌:单机超过64个队列/分区时,负载会明显增加,响应时间延长;适用于批量处理,同步收发消息的响应时延较高。

‌4. AMQP协议‌:

‌特点‌:AMQP是一种应用层的协议,用于消息队列的开放标准协议。

‌适用场景‌:适用于需要高度标准化的消息传递系统,支持多种消息队列产品。

‌优点‌:提供了生产者、消费者、交换机、队列等标准概念,便于系统间的通信和集成。

选择合适的消息队列系统时,应根据具体需求评估各个系统的特性,选择最适合项目需求的系统。例如,如果项目需要高吞吐量和容错性,Kafka可能是一个好的选择;而如果需要与现有生态系统高度集成,对消息的可靠性要求比较高,RocketMQ或RabbitMQ可能更合适‌。