Apache RocketMQ 云原生统一消息引擎.pdf

1、Apache RocketMQ 云原生统一消息引擎林清山阿里云消息负责人New Future on CloudContents目录01Apache RocketMQ 简介02Apache RocketMQ 5.x 统一消息引擎03走向ServerlessApache RocketMQ 简介01New Future on Cloud80年代，诞生 The Information Bus90年代，国际商业软件巨头，IBM MQ诞生期，商业闭源时代2000-2007开源崛起，ActiveMQ、RabbitMQ标准形成，JMS、AMQP传统企业级应用开源时代，单机架构PC 互联网、移动互联网爆发互联网

2、中间件、大数据中间件KAFKA、RocketMQ、Notify互联网时代，分布式架构云计算、IoT、云原生 AWS SNS+SQS，Azure Service Bus,RocketMQ 5.0云计算时代，云原生架构1980-20002007-20172014-2022消息队列演进趋势New Future on Cloud“五彩石”项目，Notify诞生，阿里电商分布式应用解耦2007Apache RocketMQ 发展历程New Future on Cloud2014消息队列 RocketMQ 诞生，日志采集、CDC、大吞吐场景RocketMQ 在 GitHub 开源RocketMQ 和 No

3、tify 完成架构统一，RocketMQ 成为阿里集团统一消息中间件阿里云首个消息服务 MNS 上线业界首个开源消息云服务 RocketMQ 上线Apache RocketMQ 4.0发布，成为Apache TLP阿里云 MNS 和 RocketMQ 完成架构统一，RocketMQ 成为阿里云的统一消息内核Apache RocketMQ 5.0正式发布互联网时代 云计算时代2012201320172016201720182022Apache RocketMQ 5.x 统一消息引擎02New Future on CloudMQTT智能家居Apache RocketMQ 5.X 业务全景New F

4、uture on CloudRocketMQ 5.0“消息、事件、流”一体，“云边端”一体的实时数据平台。Messaging：轻量多语言 SDK、IoT 消息 MQTT、全新 HAEventing：支持 CloudEvent、EDA架构新界面、事件集成生态Streaming：批量索引、逻辑弹性队列、流数据库 RSQLDB汽车智能穿戴设备充电桩工业设备手机RocketMQ 5.0边缘应用A边缘应用BRSQLDBRStreams边缘计算云产品事件SaaS事件业务事件事件源Connector云端应用RocketMQ 5.0Serverless消息队列数据库通知:钉钉/短信Web hook计算引擎事件

5、目标RSQLDBRStreams微服务MQTTHigh value DataCloudEventCloudEvent规则引擎端边云消息和流的统一New Future on Cloud消息-业务集成连接业务应用、解耦应用架构上下游。低延迟优先、异步通信、单条执行业务逻辑、无状态处理、类OLTP。RocketMQWarehouseSearchMonitorFlink/SparkDBDataXLogWeb ActivityDB应用XRocketMQ会员购物车物流支付应用Z应用X交易应用YM1M1M2M2M1M2M3M4M1M2M3M4流-数据集成连接数据组件，解耦数据架构上下游。吞吐量优先、批量有状

6、态计算、类OLAP。M1M2消息和流的统一New Future on Cloud访问模式 消息：基于 Topic 的发送，基于订阅关系的消费，single 模式 流：基于 Topic-MessageQueue 的发送，基于 Topic-MessageQueue+位点的读取，batch 模式Messaging ProducerStreaming ProducerTopicM5M4M3M2M1Message QueueConsumerConsumerConsumerMessaging Consumer GroupConsumerConsumerConsumerStreamingConsumer G