反应式微服务框架 Apache ServiceComb设计思想 王启军 华为云 IoT⾸席架构师 王启军，华为云IoT首席架构师，曾担 任PaaS团队架构师，负责微服务框架 的开发。曾任当当网架构师，主导电 商平台架构设计；曾就职于搜狐负责 手机微博的研发。《持续演进的Cloud Native》作者，微信公众号“奔跑中 的蜗牛”博主。 p为什么微服务框架需要 Reactive 为什么微服务框架需要Reactive？ • 微服务架构调用次数更多 • 更高的性能，规模效应 • 更好的用户体验 业界趋势 n Java 9中把反应式流规范以 java.util.concurrent.Flow 类的方式添加到了标准库中 n Spring 5对反应式编程模型提供了内置支持，并增加了新的 WebFlux 模块来支持反应 式 Web 应用的开发 ServiceComb Apache孵化的第一个微服务框架。

����������� 唐成 CONTENTS 01 什什么是物联⽹网平台 02 为什什么需要反应式架构 03 我们做了了什什么 什什么是物联⽹网平台 什什么是物联⽹网平台 Sensor / Actuator Platform Application Network 物联⽹网平台的构成 Message Hub Device Shadow Rules Engine Developer . MQTT Client Device Management Device Shadow Rules Engine Tenant & User Certificate 为什什么需要反应式架构 设备影⼦子业务说明 1. 设备上报状态 2. 将上报状态持久化到数据库 3. 应⽤用查询上报的状态 4. 应⽤用设置期望的状态 6. 期望状态和上报状态的 差异 (delta)

淘宝应⽤用架构升级 反应式架构的探索与实践 淘宝 泽彬(许泽彬) • 花名：泽彬 • 就职于阿⾥里里，经历： • 负责淘宝应⽤用架构升级 • 核⼼心开发 - 建设⽤用户增⻓长设施与平台建设 • 负责过分布式调⽤用链跟踪框架 & 系统 • 核⼼心开发 - 分布式数据库同步系统 • Github ：https://github.com/zavakid • 开源项⽬目：

⾼高并发调度，通道让异步编程更更简单 3 Scala （1）简洁的异步编程 （2）AKKA：分布式计算框架 4 Java （1）fork/join （2）CompletableFuture （3）反应式编程（Reactive Programming ) next: JavaScript 关键点：不不再有回调地狱，变异步为顺序化思维，程序更更加可读 2010年年 ECMAScript 5 2017年年 Java 7：fork/join Java 8：CompletableFuture Java 9：反应式编程 Java7 fork/join 分解合并问题 例例⼦子fork/join实现 例例⼦子Java8 CompletableFuture实现 Java9 反应式编程 • Reactive Programming。 • 异步、⾮非阻塞。 • 4个基本概念 Publisher ⾼高并发调度，通道让异步编程更更简单 3 Scala （1）简洁的异步编程 （2）AKKA：分布式计算框架 4 Java （1）fork/join （2）CompletableFuture （3）反应式编程（Reactive Programming ) 谢谢！ 陶召胜

提供了头等支持。 它是由 Red Hat 维护的开源框 架。 Quarkus 是为 Kubernetes 全新构建、并利用数百个（还在增加）最佳 库提供内聚的全栈框架。 Vert.x 是在 JVM 上构建反应式 Web 应用程序的框架， 为 Kotlin 提供了专 门支持，包括完整的文档。 kotlinx.html 是可在 Web 应用程序中用于构建 HTML 的 DSL。 它可以作为 传统模板系统 当我们正在开发桌面应用，移动应用，甚至服务器端应用 程序时，我们希望避免让用户等待或导致更糟糕的原因成为阻碍应用程序扩展 的瓶颈。 有很多途径来解决这种问题，包括： 线程 回调 Future、 Promise 及其他 反应式扩展 协程 在解释协程的含义之前，让我们简要回顾一些其他解决方案。 线程 到目前为止，线程可能是最常见的避免应用程序阻塞的方法。 fun postItem(item: Item) { 错误处理很复杂。嵌套模型使错误处理和传播变得更加复杂。 回调在诸如 JavaScript 之类的事件循环体系结构中非常常见，但即使在那里， 通常人们已经转而使用其他方法，例如 promises 或反应式扩展。 Future、 Promise 及其他 futures 或 promises 背后的想法（这也可能会根据语言/平台而有不同的术 语），是当我们发起调用的时候，我们承诺在某些时候它将返回一个名为

提供了头等支持。 它是由 Red Hat 维护的开源框架。 Quarkus 是为 Kubernetes 全新构建、并利用数百个（还在增加）最佳库提供内聚的全栈框架。 Vert.x 是在 JVM 上构建反应式 Web 应用程序的框架， 为 Kotlin 提供了专门支持，包括完 整的文档。 kotlinx.html 是可在 Web 应用程序中用于构建 HTML 的 DSL。 它可以作为传统模板系统 当我们正在开发桌面应用，移动应用，甚至服务器端应用程序时，我们希望避免让用户 等待或导致更糟糕的原因成为阻碍应用程序扩展的瓶颈。 有很多途径来解决这种问题，包括： 线程 回调 Future、 Promise 及其他 反应式扩展 协程 在解释协程的含义之前，让我们简要回顾一些其他解决方案。 线程 到目前为止，线程可能是最常见的避免应用程序阻塞的方法。 fun postItem(item: Item) { 错误处理很复杂。嵌套模型使错误处理和传播变得更加复杂。 回调在诸如 JavaScript 之类的事件循环体系结构中非常常见，但即使在那里，通常人们已经转 而使用其他方法，例如 promises 或反应式扩展。 Future、 Promise 及其他 futures 或 promises 背后的想法（这也可能会根据语言/平台而有不同的术语），是当我们发起 调用的时候，我们承诺在某些时候它将返回一个名为

（不管是键盘还是触摸屏） 及输出设备 （例如电 脑屏幕或直接由打印机打印出来），让你可以输入数据使该机器产生信息的， 那就是一部计算机了。 Tips 电脑可以协助人们进行大量的运算！以前如果要计算化学反应式都得要算个老半天，有了电脑仿真软件后，就 有不一样的情况发生了！ 以下图为例，鸟哥的工作中，有一项是需要将人们排放的空气污染物带入电脑模式进行仿真 后，计算出可能产生的空气污染并得到空气品质状态，最后经过分析软件得到各式各样的图表。

管是键盘还是触摸屏） 及输出设备 （例如电脑屏幕或直接由打印机打印出来），让你可以输 入数据使该机器产生信息的， 那就是一部计算机了。 Tips 电脑可以协助人们进行大量的运算！以前如果要计算化学反应式都得要算个老半天，有 了电脑仿真软件后，就有不一样的情况发生了！ 以下图为例，鸟哥的工作中，有一项是需要 将人们排放的空气污染物带入电脑模式进行仿真后，计算出可能产生的空气污染并得到空气 品质