RocketMQ简单介绍

RocketMQ是一个消息中间件，MQ的主要特点为解耦、异步、削峰，具有高性能、高可靠、高实时、分布式特点，用于减少数据库压力的业务场景，其中RocketMQ的核心组件概念如下：

RocketMQ结构

Name Server：注册中心（zookeeper）频繁更新offset。

Producer：消息生产者 生产消息 寄件人。

Consumer：消息消费者、复制消息消费、收件人。

Broker：中介（邮政） 提供消息中转服务。

Group ：分组好处（业务区分，便于管理）。

Tag：多个标签 where 。

Key：区分业务系统 。

Msgid： broker在这个系统中它是独一无二的。

PS：消息中间件的最重要的作用是异步和解耦。

图中箭头的含义

RocketMQ事务消息设计思路

业务案例

有一个点赞业务，不限制用户的点赞数只需进行记录(产品需求，开发提议无效)，当每个用户都进行x连击享受数量猛增的快感时如果数据库都需要进行x个点赞数据的插入，数据库毫无疑问会塞死导致崩溃。

于是想到可以尝试下MQ削峰，比如每秒来了5000消息但数据库只能承受2000，那我消费时每次只拉取消费1600就好了，剩下的放在Broker堆积慢慢消费就好。由于之前的消息中心也在用RocketMQ，于是确认使用RocketMQ来进行削峰。

五、结束语

本篇简单介绍了Rocket基本的设计思路和流程，注意要保证数据可靠，需采用同步刷盘和同步双写的方式，但性能会较其他方式低，文章内有任何不正确或不详尽之处请留言指导，谢谢。