消息队列 RocketMQ 5.0从消息服务到云原生事件流处理平台 - 杨秋弟(曼红).pdf

1、杨秋弟(曼红)阿里云智能高级产品专家Apache RocketMQ 联合创始人消息队列 RocketMQ 5.0从消息服务到云原生事件流处理平台诞生2012 年商业化2016 年ApacheTLPRocketMQ5.02017 年云原生时代 RocketMQ 5.0 发布消息队列 RocketMQ：十年磨一剑 出鞘必锋芒Apache TLP 毕业RocketMQ 4.0 正式发布2022 年阿里集团RocketMQ 诞生阿里云云计算时代 RocketMQ 商业化开源和商业齐头并进共同迈入云原生时代RocketMQ 5.0：从消息服务到云原生事件流处理平台*以上数据来源于阿里云事件驱动微服务集成

2、：主流微服务生态集成联动事件驱动：Serverless 事件触发引擎通知推送：移动端、SaaS等多端投递网关调用：云服务统一网关集成事件流CDC：低延迟、一对多订阅ETL：低代码、模板化处理连接器：标准协议、统一连接流查询计算：轻量化、内聚查询处理多样性：丰富的消息类型，消息治理等完善的企业级特性一致性：事务消息、消息消费、广播消费稳定性：容灾多活、安全巡检等金融级可用性与可靠性高性能：低延迟、百万级客户端实例、无限扩展消息服务RocketMQ轻量化高可用可观测云原生架构升级弹性RocketMQ 5.0：云原生架构升级弹性存算分离，无状态计算节点，海量分级存储高可用Leaderless 多副本

3、策略，多 AZ/Region 组建 Geo 高可用轻量化轻量无状态，Serverless 友好，覆盖主流多语言 SDKRocketMQ云原生内核架构NameServer 集群IaaS基础设施计算云存储VIPName ServerLB Group轻量接入层管控链路富客户端轻量级SDKgRPCProxyName Server云原生可观测SLSARMSAPI互补MQTT ProxyAMQPProxyRemoting 协议gRPC 协议计算集群StoreStoreStoreStoreStoreStore存储集群单副本双副本三副本云原生-容器服务（Kubernetes）EventProxy访问控制多租隔

4、离领域模型数据加密限流降级计量计费负载均衡可观测VPC 网络云原生基础设施运维体系 Kubernetes 化，云原生可观测RocketMQ 5.0：按消息消费模型队列存储：按队列模型队列消费：按消息模型C1C2C3消息发送消息消费不可见可见删除超时可见定时不可见消息消费消息确认可见RocketMQ Proxy 按消息消费模型队列队列Consumer1Consumer2消费：按队列模型队列 按队列消费模型鱼与熊掌兼得 同时支持队列和消息两种消费模型，更好适配消息和流的场景轻量无状态 客户端无状态、连接无状态、消费无状态消息级可控 只需要关心消息而无需关心队列，所有API都可以做到消息级可控Roc

5、ketMQ 5.0：海量消息分级存储RocketMQ 分级存储架构海量数据存储空间：海量数据，无限存储空间存储时长：超过 30 天自定义保存时长自适应弹性消息存储 Serverless 化，按实际存储使用量付费分级存储，对比自建三副本存储，成本降低 67%*以上数据来源于阿里云更高性能计算层代理冷热数据读写分离，收发相互隔离冷数据碎片规整，冷读堆积场景性能更稳定C ol d D ata C ol d D ata M anagerM anagerH ot D ata H ot D ata M anagerM anagerM sgM sg999999M sgM sg998998C ostl y S

6、SDC ostl y SSDM sgM sg100100M sgM sg101101M sgM sg102102M sgM sg0 0M sgM sg1 1M sgM sg2 2M sgM sg700700M sgM sg701701M sgM sg7027021 day1 day3 days3 daysN daysN daysU nl i m i ted U nl i m i ted Low-cost StorageLow-cost StorageM Q ServerM Q ServerB rB rokeroke