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

ServiceComb在华为消费者云的 亿级用户微服务实践 website: http://servicecomb.incubator.apache.org/ gitter: https://gitter.im/ServiceCombUsers/Lobby AGENDA 微服务化总体策略 01 微服务化实践 02 微服务化收益 03 关于我 Website: http://servicecomb 经历：2008年加入华为，从事多年平台中间件、云计算和PaaS平台设计和开发  目前在华为终端消费者云业务从事华为手机应用市场的云化、微服务化架构设计  《Netty权威指南》、《分布式服务框架原理与实践》作者  热爱技术写作和分享 联系方式： Email: li_linfeng@huawei.com 微信号：右侧扫码 华为消费者云服务简介 Website: http://servicecomb.incubator incubator.apache.org/ Gitter: https://gitter.im/ServiceCombUsers/Lobby 以ServiceComb为核心构建的微服务架构体系，极大的提升了消费者云业务研发效率 需求的研发和交付周期缩短，业务更敏捷应对变化 可独立交付和升级的服务越来越多，业务之间逐步解耦，可独立演进 服务之间的接口契约可视化、可度量和管控，架构看护和优化更有章可循

本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 11 > 1.1 RocketMQ 核心概念扫盲篇 3. Client 消息客户端，包括 Producer(消息发送者)和 Consumer(消费消费者)．客户端在同一 时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户 端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 温馨提示：Nameserver consumegroup：消息消费组，一个消费单位的“群体”，消费组首先在启动时需要 订阅需要消费的 topic。一个 topic 可以被多个消费组订阅，同样一个消费组也可以订阅多 个主题。一个消费组拥有多个消费者。 术语解释起来有点枯燥晦涩，接下来我举例来阐述。 例如我们在开发一个订单系统，其中有一个子系统：order-service-app，在该项目 中会创建一个消费组 order_consumer order_consumer 消费组的其中一个消费者。 1. 消费模式 那这三个消费者如何来分工来共同消费 order_topic 中的消息呢？ 在 RocketMQ 中支持广播模式与集群模式。 广播模式：一个消费组内的所有消费者每一个都会处理 topic 中的每一条消息，通常用 于刷新内存缓存。 集群模式：一个消费组内的所有消费者共同消费一个 topic 中的消息，即分工协作，一 个消费者消费一部分数据，启动负载均衡，

70 72 73 74 76 76 76 77 78 80 80 80 81 81 83 83 84 84 进⼊管理⻚⾯ 开启 Binlog 全量数据迁移，记录CommitTS数据 添加消费者 查看消费者 删除消费者 修改 Binlog GC 关闭 Binlog 如何使⽤ 如何使⽤TiFlash 简介 步骤⼀ 开启TiFlash 步骤⼆ 按表构建TiFlash副本 步骤三 使⽤TiFlash 备份恢复 mitTS。 Binlog 同步 分布式NewSQL数据库 TiDB Copyright © 2012-2021 UCloud 优刻得 66/120 添加消费者 添加消费者 点击“添加消费者”按钮打开添加窗⼝， 可为⼀个实例添加多个消费者。 Binlog 同步 分布式NewSQL数据库 TiDB Copyright © 2012-2021 UCloud 优刻得 67/120 Binlog 68/120 选择MySQL协议消费者（如MySQL数据库、TiDB数据库或者其它兼容MySQL协议的数据库）或者Kafka， 输⼊上⼀步中获取的CommitTS数据以及其它需求信息完成添加。 Binlog 同步 分布式NewSQL数据库 TiDB Copyright © 2012-2021 UCloud 优刻得 69/120 查看消费者 查看消费者 当前已有的消费者会⾃动列出 Binlog 同步

内容及数字资产，形成企业数字资产沉淀，统一企业对外形象 及标准化化运营 活动数据，消费者数据，媒体 数据，车联网数据等，全渠道 数据收集追踪，建立数据分析 模型，辅助业务的决策优化 大数据分析 及应用 线上数字化布局 线下数字化布局 车联网及线下店端消费者旅程与线上消费 者旅程相结合，设计多种跨渠道跨屏互动， 引导进店消费者通过扫码，配车，留资等 行为整合线上数据 利用人脸识别等多种技术及平台，通过可 利用人脸识别等多种技术及平台，通过可 配置用户聚类评级模型和数据处理算法， 实现消费者深度洞察，提高销售线索质量 及转化率，助力经销商销售 新媒体营销数字化布局 从微信营销及小程序开始布局其他新兴媒体渠道，如抖 音，汽车之家等，基于360°消费者画像的精准营销触达。 营销触达数据实时跟踪分析，形成数据闭环 消费者权益及服务数字化布局 建设“一个会员、分众运营、复合模式”的会员体 系以及差异化个性化的会员权益服务体系，打造 官网 短信 小程序 公众号 标准体系 标签体系 数据 中台 …… 存储服务 安全服务 接口网关服务 日志服务 网络服务 …… 短信服务 技术 中台 ……. 消费者互动数据 消费者账号 消费者基础信息 消费者交易数据 消费者服务数据 ….. 人 人车关系数据 车况数据 车辆维修保养数 据 ….. 库存物流数据 组织架构数据 活动渠道数据 …… 厂 营销中台 销售中台 内容管理

线程控制方法，理解各线程控制方法对线程状态切换的作 用。 3. 线程的同步：理解临界资源问题，进一步明白线程安全的意 义；了解关键字 synchronized 的用法；了解死锁的概念；通 过生产者—消费者问题分析理解线程同步。 大纲 线程基础 线程控制 线程的同步 大纲 线程基础 相关知识回顾 线程的概念模型 创建线程 后台线程 线程控制 线程生命的周期 线程优先级 线程串行化 线程休眠 线程的同步 生产者—消费者问题 生产者消费者模型就是在一个系统中存在生产者和消费者两种角 色，他们之间通过内存缓冲区进行通信，生产者生产消费者需要 的资料，消费者把资料做成产品。 大纲 线程基础 线程控制 线程的同步 生产者—消费者问题 O 生产者消费者问题是线程模型中的经典问题 ▶ 生产者和消费者在同一时间段内共用同一存储空间，生产者 向空间里生产数据，而消费者取走数据。 ▶ 阻塞 阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处 理能力。这个阻塞队列就是用来给生产者和消费者解耦的。 课程配套代码 ± sample.thread.syn.ProducerAndConsumer.java 大纲 线程基础 线程控制 线程的同步 本节习题 O 简答题 1. 简述线程的基本概念。程序、进程、线程的关系是什么？ 2. 线程的生命周期包括哪些基本状态？这些状态的关系如何？ 状

、制造业智慧供应链等行业解决方案。 发布轻舟低代码平台 2.0 。 大数据开源项目 Kyuubi 全票进入 Apache 软件基金会孵化器。 有数 BI 个人版永久免费；发布机器学习平台、消费者运营平台、标签画像、流量分析等产品。 2020 2021 发布轻舟云原生软件生产力平台、有数全链路数据生产力平台。 网易云品牌升级为网易数帆，发力数字化转型基础软件。 深度参与社区 Spark 离线数据传输 实时数据传输 运维中心 离线开发平台 实时计算平台 集群运维 任务运维 文件管理 任务开发 租户管理 自助分析 权限管理 可视化调度 数据开发及管理平台 标签画像 消费者运营平台 机器学习平台 BI 有数优势 有数全链路数据生产力平台2.0能力全景图 易用 覆盖企业数据全链路的大数 据产品，全面降低数据使用门 槛。 开放 专注大数据技术领域，核心 技术自主可控，支持多云和跨 系统等数据源，为消费者运营 平台奠定数据资产基础。 消费者精准洞察 基于敏捷标签应用体系及业 务需求快速产出品牌标签，提 升数据加工能力，提高人群探 索以及人群圈选的效率。 品牌数据增值 基于消费者洞察数据，产出 围绕消费者全生命周期的运 营模型，提升品牌数据增值 力。 全域营销场景覆盖 涵盖新客获取及老客复购等 多种营销场景，营销人员可灵 活设定人群细分及营销计划， 精细化运营品牌消费者。 管理模式“兼容并包”

实例被创建出现主要就是用于唤醒等 待线程从而避免死锁。std::condition_variable 的 notify_one() 用于唤醒一个线程；notify_all() 则是通知所有线程。下面是一个生产者和消费者模型的例子： #include #include #include #include #include }; // 消费者 auto consumer = [&]() { while (true) { std::unique_lock lock(mtx); while (!notified) { // 避免虚假唤醒 cv.wait(lock); } // 短暂取消锁，使得生产者有机会在消费者消费空前继续生产 lock.unlock(); // 消费者慢于生产者 值得一提的是，在生产者中我们虽然可以使用 notify_one()，但实际上并不建议在此处使用，因为 在多消费者的情况下，我们的消费者实现中简单放弃了锁的持有，这使得可能让其他消费者争夺此锁，从 而更好的利用多个消费者之间的并发。话虽如此，但实际上因为 std::mutex 的排他性，我们根本无法 期待多个消费者能真正意义上的并行消费队列的中生产的内容，我们仍需要粒度更细的手段。 67 7.5 原子操作与内存模型

数据接口标准化：根据标准格式输出数据， 利用o3mini方便不同系统和平台之间的数据 共享，提升跨机构协作效率。 • 情感分析与数据解读：利用o3mini结合 情感分析，对数据进行深入解读，帮助市场调 研等领域理解消费者情感，优化产品和策略。 • 故事化数据呈现：借助o3mini将数据以 故事的形式呈现，增强数据的可读性和吸引力， 帮助公众理解复杂的科学和技术知识。 • 复杂数据模式识别：借助o3mini高效分 揭示市场趋势，帮助商 家精准定位消费者需求， 把握市场动态。 对比产品参数 自动收集并对比同类产 品参数，突出性能差异， 简化消费者的决策流程。 整合用户反馈 整合用户反馈，提炼关 键意见，确保购买决策 基于真实用户体验，提 高决策质量。 提供定制建议 结合个人偏好与历史行 为，提供定制化的购买 建议，提升用户的购物 满意度。 简化决策流程 通过突出产品性能差异， 简化消费者的决策流程， 减少选择困难，提高购 提供深入的市场趋势、消费者行为洞察及竞争格局，为企业制定精准的商业策略提供支持。 01 02 03 04 数据来源：社交媒体、市场调查、 行业报告、消费者反馈等。 信息发现 推理分析 信息整合 生成定制化的商业报告，帮助管理层理解市场 格局、识别潜在机会和风险，做出明智决策。 输出报告 将不同来源的结构化和非结构化数据进行 整合，形成全面的市场和消费者视角。 基于AI推理模型，分析消费者行为、市场

全链路灰度 安全态Sec 发布态 • 离群实例摘除 • 限流降级 • 同AZ优先路由 • 就近容灾路由 高可用 • 服务鉴权 • 漏洞防护 服务治理的区分 服务治理中心 提供者 消费者 Agent Agent 用户 配置中心 治理规则 Dev-Sec-Ops 无损下线 离群实例摘除 标签路由 服务鉴权 链路跟踪 金丝雀发布 API管理 服务测试 限流降级 故障注入 注册中心感知 到服务端下线 客户端感知到 服务端下线 服务调用报错期 客户端视角 正常 服务端视角 下线静默 下线 注册中心 提供者A 消费者A 提供者B 消费者B 1 正常调用 1 服务下线 (prestop) 3 通知消费者 5 应用重启 4 调用其他提供者 Agent 2 主动通知 Agent 3 客户端主动刷新 Agent Agent 无损下线: 白天大流量下发布依然丝般顺滑 http-header: user-id % 100 == 20 • 两种灰度规则 • 按流量百分比路由 • 按请求特征路由：如http header, 方法参数等 • 打通微服务网关 提供者 1 消费者 提供者 2 version=gray 2. 注册环境标签 user-id=121 提供者 3 Deployment1 1. version=normal 1. version=gray