基于云原生的下一代微服务(ServiceMesh)框架—Dapr初体验

原创IT点滴

Service Mesh作为下一代微服务架构已越来越受欢迎&＃xff0c;其Sidecar模式可以很好地让应用开发回归业, 目前流行的Service Mesh方案有Istio(谷歌)、Linkerd2(Buoyant)、Dapr(微软)。 Dapr发展势头十分迅猛&＃xff08;基于go语言实现&＃xff09;&＃xff0c;目前已经在 GitHub 上收获了12.5K星星&＃xff0c;阿里是 Dapr 开源项目的深度参与者和早期采用者&＃xff0c;率先进行了生产落地。

Dapr 是一个可移植的、事件驱动的运行时&＃xff0c;它使任何开发人员能够轻松构建出弹性的、无状态和有状态的应用程序&＃xff0c;并可运行在云平台或边缘计算中&＃xff0c;它同时也支持多种编程语言和开发框架。其口号Any language, any framework, anywhere&＃xff08;任何语言&＃xff0c;任何框架&＃xff0c;任何地方&＃xff09;&＃xff0c;dapr目前最新版本v1.1.1

any framework, anywhere&＃xff1a;Dapr 是和平台无关的&＃xff0c;可以在本地、K8S(Kubernetes)群集或者其它集成 Dapr 的托管环境中运行应用程序。 这使得能够在云平台和边缘计算中运行微服务应用。

Any language&＃xff1a;使用 Dapr可以使用任何语言、任何框架轻松构建微服务应用&＃xff0c;并运行在任何地方(特别适合企业内部存在多语言构建的微服务程序的场景)。

dapr

Dapr由7大构建块组成&＃xff08;服务间调用、状态管理、发布订阅、资源绑定、Actors、Observability、Secrets&＃xff09;&＃xff0c;并且具有可扩展性以添加新的构建块。

dapr

为了让不同的开发语言者更方便地使用Dapr 其提供RESTful接口&＃xff0c;以及提供不同语言使用的SDK&＃xff08;C&＃43;&＃43;、Go、Java、Javascript、.NET 、Python &＃xff09;。SDK 通过类型化的语言来使用Dapr 构建块中的功能&＃xff08;如保存状态&＃xff0c;发布事件或创建Actor&＃xff09;。

Dapr CLI 是用于管理Dapr 相关任务的主要工具。Dapr 可以配置为在本地计算机上运行、或者运行在Docke容器、Kubernetes 集群运行。为了方便我们在Center OS虚拟机上安装Dapr CLI

wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash

执行上述命令发现没有任何反应&＃xff0c;我们去掉wget命令-q参数&＃xff08;安静模式无信息输出&＃xff09;&＃xff0c;

发现无法访问githubusercontent&＃xff0c;我们从github上下载加速github访问的host文件更新替换本地的etc/hosts。再次执行上述wget -url命令&＃xff0c;便可以看到正在下载dapr_linux_amd64.tar.gz&＃xff0c;下载比较慢耐心等待即可。

wget 安装Dapr CLI

安装完毕后&＃xff0c;我们执行下dapr命令&＃xff0c;控制台会有dapr 的相关输出&＃xff0c;我们可以看到大大的dapr字符画&＃xff0c;以及相关命令参数。

dapr runtime

在上面的步骤1我们已经安装好了了Dapr CLI&＃xff0c;接下来我们使用CLI在本机初始化 Dapr 。
不依赖 Docker初始化 Dapr&＃xff08;初始化命令dapr init --slim&＃xff09;

依赖 Docker 初始化 Dapr&＃xff08;初始化命令dapr init&＃xff09;

我们使用dapr init --slim命令来初始化&＃xff0c;安装完毕后提示Success! Dapr is up and running。

不使用 Docker 自托管模式&＃xff1a;会安装了daprd 和 placement&＃xff08;在自托管安装中用于启动 actors&＃xff09;&＃xff0c;不会为状态管理或发布/订阅安装任何默认组件(Redis)。这意味着&＃xff0c;除了服务调用&＃xff0c;没有其他构建块功能可用&＃xff0c;我们可以设置自定义环境和组件。

使用Docker 自托管模式&＃xff1a;初始化前需要安装docker&＃xff0c;dapr init完毕后启动daprio/dapr、openzipkin、zipkin、 redis等4个容器镜像。

dapr init success

在上面的步骤2完成后&＃xff0c;我们测试使用Dapr的服务调用功能&＃xff0c;运行Java/.net程序&＃xff08;sidecar模式&＃xff0c;无代码侵入&＃xff09;。

我们运行一个Java Spring Boot的测试应用

dapr run --app-id myjava --app-port 8080 -- java -jar order-0.0.1-SNAPSHOT.jar

dapr run java

上述dapr run命令&＃xff0c;app-id指定了应用ID&＃xff0c;app-port指定了应用的端口&＃xff08;spring boot应用本身设置的端口&＃xff09;&＃xff0c;后跟java -jar启动对应的jar包。执行命令后界面提示&＃xff1a;Starting Dapr with id myjava. HTTP Port:46213. gRPC Port:46307&＃xff0c;说明Dapr成功启动了刚才的java应用&＃xff0c;可以通过http端口45213端口访问&＃xff0c;gRPC服务端口46307。

我们直接访问下spring boot接口&＃xff0c;http://ip:8080/order 显示正常。
然后通过dapr暴露服务访问&＃xff0c;
http://ip:39445/v1.0/invoke/myjava/method/order

上面我们的测试java代码没有任何dapr的代码侵入

&＃64;RestController
&＃64;RequestMapping("/order")
public class OrderController {&＃64;GetMapping("index")public String index() {return "hello world";}
}

运行.NET 5的测试应用
同样的我们新建一个简单的WebApi工程&＃xff0c;同样的通过dapr暴露的.net服务访问正常

dapr run --app-id mydonet --app-port 5000 -- dotnet run
开始体验step 4—使用Dapr的其他特性

State management&＃xff08;状态管理&＃xff09;: Dapr 可以通过HTTP API的方式进行状态的存储和读取&＃xff0c;支持进行并发控制&＃xff0c;另外还可以通过SDK的方式&＃xff0c;如dapr-java-sdk示例代码&＃xff1a;

DaprClient client &＃61; new DaprClientBuilder().build()
client.saveState(String storeName, String key, Object value).block();
client.deleteState
client.executeStateTransaction

另外还有消息发布及订阅、资源绑定及事件触发、Actors、Observability、Secrets等特性,由于篇幅有限在此不再累述&＃xff0c;我们可以从github上下载相应语言的SDK代码&＃xff0c;里面有各种examples示例代码可供参考。