## 消费者云CSE微服务实践 李林锋 ## 关于我 9年电信软件平台中间件开发、设计、架构经验 精通Netty、Mina等网络通信框架 华为软件 短信/彩信/WAP网关平台SGP、API开放集成网关API Fabric首席设计师 华为软件分布式服务框架DSF首席设计师 《Netty权威指南》、《分布式服务框架原理与实践》作者 微博、微信：Nettying 公众号：Netty之家 2816e8fd9c1e245b4d9cafff6180bc3c/p2_3.jpg) ## ServiceComb ## 议题 • 华为消费者云业务简介 • 微服务框架技术选型 • CSE在消费者云业务的实践 ## 华为消费者云业务简介 华为消费者云业务包括 华为应用市场、华为视频、华为钱包、华为运动健康等服务，为华为和荣耀手机提供精品云服务，提升用户体验 ## ← 应用详情 ![ 微服务框架技术选型-业务服务化目标 系统解耦，功能内聚，提升需求交付效率：通过业务的拆分和解耦，让系统敏捷起来，快速、小批量的交付价值需求，提升业务的交付效率 践行API First：通过服务化，让服务提供者和消费者之间通过微服务API建立契约，利用Swagger OpenAPI规范，最终将微服务API规范化、标准化、在线化。系统从传统单体应用的黑盒调用（本地Java方法调用）转变成透明的API契约调用 服

## ServiceComb在华为消费者云的 亿级用户微服务实践 ## AGENDA ## 01 微服务化总体策略 ## 02 微服务化实践  微服务化收益  联系方式： ## 关于我 ● 经历：2008年加入华为，从事多年平台中间件、云计算和PaaS平台设计和开发 ● 目前在华为终端消费者云业务从事华为手机应用市场的云化、微服务化架构设计 《Netty权威指南》、《分布式服务框架原理与实践》作者 热爱技术写作和分享 微信号：右侧扫码 Email: li_linfeng@huawei li_linfeng@huawei.com  ## 华为消费者云服务简介  云空间 ![Image](

stream computing MySQL cluster ## 使用需求 • 数据缓冲，提高可用性，缓冲服务故障 • 数据广播，分发给多个服务 • 负载均衡，提高消费者的扩展性 ## 使用案例 广告点击数统计 4. 正确消费确认 Web Service Web Service MQ stream computing  stream computing MySQL cluster ## 使用需求 • 数据缓冲，提高可用性，缓冲服务故障 • 数据广播，分发给多个服务 • 负载均衡，提高消费者的扩展性 - 消费反馈，确保消息不丢失 ## 使用案例 广告点击数统计 User Click 5. MQ的可靠性 User Click User Click Web Service Stateless 数据缓冲，提高可用性，缓冲服务故障 • 数据广播，分发给多个服务 • 负载均衡，提高消费者的扩展性 • 消费反馈，确保消息不丢失 • MQ：分布式部署，排除自身单点故障 ## 使用需求 • 数据缓冲，提高可用性，缓冲服务故障 • 数据广播，分发给多个服务 • 负载均衡，提高消费者的扩展性 • 消费反馈，确保消息不丢失 • MQ：分布式部署，排除自身单点故障 • MQ：具备横向扩展性，排除性能瓶颈

consumer.....14 一：consumer 启动流程.....15 二：消费端负载均衡.....17 三：长轮询.....20 四：push 消息—并发消费消息.....24 五：push 消费-顺序消费消息.....26 六：pull 消息消费.....28 七：shutdown.....28 第三章：broker. 分布式事物是基于二阶段提交的 1) 一阶段，向 broker 发送一条 prepared 的消息，返回消息的 offset 即消息地址 commitLog 中消息偏移量。Prepared 状态消息不被消费 发送消息 ok，执行本地事物分支，本地事物方法需要实现 rocketmq 的回调接口 2)2) 2）LocalTransactionExecutor，处理本地事物逻辑返回处理的事物状态LocalTransactionState producer 端 redolog 这个队列其实标记消费到哪了，事物状态的恢复根本上是有 commitlog 来做的 ## 第二章 consumer 有别于其他消息中间件由 broker 做负载均衡并主动向 consumer 投递消息，RocketMq 是基于拉模式拉取消息，consumer 做负载均衡并通过长轮询向 broker 拉消息。 Consumer 消费拉取的消息的方式有两种 1. Push 方式：rocketmq