## 消费者云CSE微服务实践 李林锋 ## 关于我 9年电信软件平台中间件开发、设计、架构经验 精通Netty、Mina等网络通信框架 华为软件 短信/彩信/WAP网关平台SGP、API开放集成网关API Fabric首席设计师 华为软件分布式服务框架DSF首席设计师 《Netty权威指南》、《分布式服务框架原理与实践》作者 微博、微信：Nettying 公众号：Netty之家 6/2816e8fd9c1e245b4d9cafff6180bc3c/p2_3.jpg) ## ServiceComb ## 议题 • 华为消费者云业务简介 • 微服务框架技术选型 • CSE在消费者云业务的实践 ## 华为消费者云业务简介 华为消费者云业务包括 华为应用市场、华为视频、华为钱包、华为运动健康等服务，为华为和荣耀手机提供精品云服务，提升用户体验 ## ← 应用详情 微服务框架技术选型-结果 为什么业务最终选择CSE作为微服务框架？ 无论是华为内部的DSF，还是开源的Netflix、Spring Cloud等，都无法完全满足业务的选型诉求，而CSE则能够很好地满足我们的需求 ✓ 仔细阅读了CSE的主要模块代码，包括网络通信、线程调度模型等，代码质量非常高，对细节的把握比较好 ✓ 选型试用时，大家对CSE的接受度比较高，使用CSE改造已有的Spring MVC代码相对较容易些

KEN) 工单 服务实例#N (SpringBoot + 华为云CSE) 客户和线索 服务实例 #N (SpringBoot + 华为云CSE) OBS存储 REDIS 缓存 系统管理 服务实例 #N (SpringBoot + 华为云CSE) 客户和线索数据库 工单 数据库 系统管理 数据库 数据库 华为云CSE介绍 服务中心（>Eureka） 治理中心 (Hystrix+Ribbon增强) Apache ServiceComb 配置中心（etcd增强） 公有云对接能力 UAT和PROD使用CSE企业版；本地开发和SIT使用本地轻量级CSE服务 阿里云集成 服务实例 #N (SpringBoot + 华为云CSE) 更多新业务 服务实例 #N (SpringBoot + 华为云CSE) ![Image](/uploads/documents/0/2/6/3/0263295775

public static void main(String[] args) { String result = restTemplate.getForObject("cse://springmvc/helloworld/syaHello?name={name}", String.class, "Ta"); } } ## JAXRS import public static void main(String[] args) { String result = restTemplate.getForObject("cse://jaxrs/helloworld/syaHello?name={name}", String.class, "Tank"); } } ## 性能保证 ![Im AS|1|1k|100|97586|1.01|3| |机型|协议|规格(CPU/内存/网卡)|CSE SDK|实例数|报文大小|调用线程数|TPS|时延(ms)|| |VM|REST|8U16G1G|CSE SDK|1|1k|100|70669|1.414|| |物理机|REST|24U64G1G|CSE SDK|1|1k|100|107126|0.933|| |机型|协议|规格(CPU/内存/网

String sayHello(); } String result = hello.sayHello(); String result = restTemplate.getForObject("cse://{name}/sayHello", String.class); ## 整体线程模型  Microservice (Process) cse.executors.default Schema ( Interface ) cse.executors.Provider.[schemaId] Operation ( Method ) cse.executors.Provider.[schemaId].[operationId] ## Handlers.asyncResponse callback helloImpl.sayHello() 微服务引擎商业版：http://www.huaweicloud.com/product/cse.html ServiceComb Github：https://github.com/apache?q=servicecombServiceComb 官网：http://servicecomb

required: true}, // TODO: split required rules and optimizing rules {name: "zero arg cse", fn: zcse, required: true}, // required to merge OpSB values {name: "opt deadcode" deadcode, required: true}, // remove any blocks orphaned during opt {name: "generic cse", fn: cse}, {name: "phiopt", fn: phiopt}, {name: "nilcheckelim", fn: nilcheckelim} Machine-dependent Passes { name: "lower", fn: lower, required: true}, name: "lowered cse", fn: cse}, name: "elim unread autos", fn: elimUnreadAutos}, name: "lowered deadcode"

9d8f35253174a791385963633/p18_1.jpg) ## Mesher • Service Mesh的一种实现 - 基于自研的Go语言微服务框架（即将开源）开发 使用CSE注册中心与配置中心 - 以Sidecar的方式部署在微服务所运行的环境中，也可以PerHost模式运行 - 支持多种部署方式 • 占用资源小（闲置10多M，并发运行时30多M） ![Im • Service Mesh在华为内部的技术演进 - 实现一个Service Mesh - 使用Service Mesh快速构建微服务 • 生态与扩展 与PaaS平台结合 ## 整体架构 CSE as control plane Service Service Service Service Monitoring Service center Mesher Zipkin Mesher 本地或虚机部署: 样例 • kubernetes部署 • ServiceStage部署 ## 最小化配置项 HTTP_PROXY • SERVICE_NAME • PROVIDER_ADDR CSE_REGISTRY_ADDR ## 部署复杂性提升，如何消弭？ • Infrastructure as Code—开发者自行选型 命令行注入工具—Mesher开发团队定制 • 编排服务自动注入—最完整的产品体验

100a36efb/p26_1.jpg) Qingkai Shi Hong Kong University of Science and Technology, China qshiaa@cse.ust.hk Xiao Xiao Sourcebrella Inc China xx@sbrella.com Jinguo Zhou Sourcebrella Inc China jinguo@sbrella Kong University of Science and Technology, China gfan@cse.ust.hk Rongxin Wu Hong Kong University of Science and Technology, China wurongxin@cse.ust.hk ## Abstract When dealing with millions of error detection, path- Charles Zhang Hong Kong University of Science and Technology, China charlesz@cse.ust.hk Flow Analysis for Million Lines of Code. In Proceedings of 39th ACM SIGPLAN Conference on Programming

public static void main(String[] args) String result = restTemplate.getForObject("cse://jaxrs/helloworld/syaHello?name={name}", String.class, "Tank"); } ## 异步事件操作保证系统性能 ![ AS|1|1k|100|97586|1.01|3| |机型|协议|规格(CPU/内存/网卡)|CSE SDK|实例数|报文大小|调用线程数|TPS|时延(ms)|| |VM|REST|8U16G1G|CSE SDK|1|1k|100|70669|1.414|| |物理机|REST|24U64G1G|CSE SDK|1|1k|100|107126|0.933|| |机型|协议|规格(CPU/内存/网

尽最大可能插件化各功能模块 - 透明的产品体验：整合容器平台，微服务引擎，API网关，指标监控，日志审计等云上服务，封装为微服务平台，让用户感知不到背后的复杂 ## 整体架构 ## API gateway CSE as control plane Data plane Monitoring Service Service Service Service Zipkin Service center Router使用统一配置模型，支持插件对接不同生态 Resolver Resolve 请求特征： • Service Name Request • Headers • Consumer metadata CSE Router Read Route Rule and Convert Target Service Infos: Service name Metadata Istio Query Instance 18_2.jpg) 内部服务地址 ☐ 请输入内部服务地址，例：127.0.0.1:3000 背后发生了什么？ • 为应用容器设置环境变量http_proxy - 为mesher设置CSE地址（注册中心，配置中心） • 为mesher对接APM 日志收集 • 为mesher对接APM metrics收集 • 为mesher 对接APM 调用链追踪 - 告知mesher业务服务的版本以及监控端口

control plane solutions Registry Config security Archaius service discovery registrator Huawei CSE Ctrip Apollo local mTLS ServiceComb Istio ServiceComb file system Kubernetes Consul Istio 拥抱混合云架构 - 同时支持客户端自注册与平台注册 - 打通k8s与虚机等基础设施，可实现VM向容器平滑迁移 ## 一 站式解决方案：开发框架与Mesher混合使用 API gateway CSE as control plane Data plane Monitoring Service Service Service Service Zipkin Governance Web 3.jpg) 内部服务地址 ☐ 请输入内部服务地址，例：127.0.0.1:3000 ## 背后发生了什么？ • 为应用容器设置环境变量http_proxy - 为mesher设置CSE地址（注册中心，配置中心） • 为mesher对接APM 日志收集 • 为mesher对接APM metrics收集 • 为mesher对接APM调用链追踪 • 告知mesher服务的版本以及监控端口