分布式消息队列RocketMQ概述与分类

分布式消息队列RocketMQ.pdf 分布式消息队列RocketMQ主讲人Reythor雷（老雷）从MQ的概述开始，详细介绍了MQ的概念、用途、常见MQ产品等知识点。 **MQ概述** MQ，即Message Queue，是一种提供消息队列服务的中间件，也称为消息中间件，是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据，一般消息的体量不会很大。 **MQ用途** MQ有三大用途： 1. 限流削峰：MQ可以将系统的超量请求暂存其中，以便系统后期可以慢慢进行处理，从而避免了请求的丢失或系统被压垮。 2. 异步解耦：MQ可以将系统的调用从同步转换为异步，减少系统的耦合度，提高系统的吞吐量和并发度。 3. 数据收集：MQ可以用于分布式系统中的海量级数据流的实时或批量采集汇总，然后对这些数据流进行大数据分析。 **常见MQ产品** 常见的MQ产品有： 1. ActiveMQ：使用Java语言开发的一款MQ产品，早期很多公司与项目中都在使用，但现在的社区活跃度已经很低。 2. RabbitMQ：使用ErLang语言开发的一款MQ产品，吞吐量较Kafka与RocketMQ要低，且由于其不是Java语言开发，所以公司内部对其实现定制化开发难度较大。 3. Kafka：使用Scala/Java语言开发的一款MQ产品，具有高吞吐率，常用于大数据领域的实时计算、日志采集等场景。 4. RocketMQ：使用Java语言开发的一款MQ产品，经过数年阿里双11的考验，性能与稳定性非常高，已经成为SpringCloudAlibaba的推荐选择。 **MQ产品比较** | 产品名称 | 开发语言 | 单机吞吐量 | | --- | --- | --- | | ActiveMQ | Java | 万级 | | RabbitMQ | ErLang | 万级 | | Kafka | Scala/Java | 十万级 | | RocketMQ | Java | 十万级 | 分布式消息队列RocketMQ是一种高性能、稳定的MQ产品，已经成为业界的热门选择。