在非容器(集群)环境下运行dapr

作者：李俱顺

原文：https://www.4async.com/2021/03/2021-03-11-running-dapr-without-container/

前一段时间一直关注的dapr正式发布了v1.0版本(实际上本文发布时还更新了v1.0.1)，代表dapr在某些程度上进入稳定状态，可以尝试在实际中进行运用。作为我一直关注的项目，在第一时间中进行了尝试，并试图引入实际项目中，本文则是针对这些的一些先期测试内容.

什么是dapr？

dapr最早是由微软开源的(不愧是你)，一个可移植的、事件驱动的程序运行时，它使任何开发者都能轻松地构建运行在云和边缘的弹性、无状态/有状态的应用程序，并且可以灵活支持多种开发语言。换而言之，在我看来，dapr可以作为一个serverless落地方案看待和处理，对程序而言，只关注提供的store和消息队列接口，无需关心架构层面更多内容。

不过在官方的示例教程中，使用的环境为容器环境部署和管理dapr。实际上，除了在容器环境或者容器集群环境下，dapr可以配置为在本地机器上以自托管模式运行。

本地安装

dapr安装可以通过官方的dapr-cli实现，dapr-cli可以通过一键安装命令快速安装：

# wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash
Your system is linux_amd64Dapr CLI is detected:
main: line 86: 43656 Segmentation fault      $DAPR_CLI_FILE --version
Reinstalling Dapr CLI - /usr/local/bin/dapr...Getting the latest Dapr CLI...
Installing v1.0.0 Dapr CLI...
Downloading https://github.com/dapr/cli/releases/download/v1.0.0/dapr_linux_amd64.tar.gz ...
dapr installed into /usr/local/bin successfully.
CLI version: 1.0.0
Runtime version: n/aTo get started with Dapr, please visit https://docs.dapr.io/getting-started/

可以通过输入dapr命令确认dapr-cli程序是否被正常安装成功。

接下来使用dapr-cli安装所有的runtime等应用。

# dapr init --slim
⌛  Making the jump to hyperspace...
↘  Downloading binaries and setting up components...
Dapr runtime installed to /root/.dapr/bin, you may run the following to add it to your path if you want to run daprd directly:export PATH=$PATH:/root/.dapr/bin
✅  Downloaded binaries and completed components set up.
ℹ️  daprd binary has been installed to /root/.dapr/bin.
ℹ️  placement binary has been installed to /root/.dapr/bin.
✅  Success! Dapr is up and running. To get started, go here: https://aka.ms/dapr-getting-started# dapr --version
CLI version: 1.0.0
Runtime version: 1.0.1

在官方文档中，如果选择使用init命令初始化，dapr-cli将会自动尝试使用容器环境管理相关程序，只有添加--slim参数才会选择本地化运行。更多用法可以参考dapr help init帮助。默认程序相关内容会安装在$HOME/.dapr目录下，这里因为我为了简便使用了root用户，因此程序命令所在目录为/root/.dapr/bin，共安装了如下命令：

# ls ~/.dapr/bin
daprd  dashboard  placement  web

从文件名可以看出来daprd是deamon进程，dashboard就是管理面板，placement是用于管理actor分布方案和密钥范围的工具。官方文档中提到在安装后会使用Reids作为默认的存储和pub/sub组件，但是我实际安装下来其实是并没没有的，不知道是不是文档有些过期导致的。这时如果按照官方文档的例子进行操作启动程序并尝试在存储中保存数据，则会出现报错的情况：

// 第一个session中执行：
# dapr run --app-id myapp --dapr-http-port 3500// 第二个session中执行：
# curl -X POST -H "Content-Type: application/json" -d '[{ "key": "name", "value": "Bruce Wayne"}]' http://localhost:3500/v1.0/state/statestore{"errorCode":"ERR_STATE_STORES_NOT_CONFIGURED","message":"state store is not configured"}

不过实际上添加组件在dapr中也是比较简单的，可以通过在$HOME/.dapr/components下添加对应yaml文件实现。

添加Redis作为组件

我们可以在官方文档中找到一个Redis组件配置模版，可以快速使用：

# redis-store.yml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: redis-storenamespace: default
spec:type: state.redisversion: v1metadata:- name: redisHostvalue: 127.0.0.1:6379- name: redisPasswordvalue: ""

当然我们也可以使用Redis Stream功能做pub/sub功能，虽然这个功能已经GA，但是介于Redis Stream的特点，你需要谨慎使用这个功能，这里只是因为是演示所以无所谓：

# redis-pubsub.yml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: redis-pubsubnamespace: default
spec:type: pubsub.redisversion: v1metadata:- name: redisHostvalue: 127.0.0.1:6379- name: redisPasswordvalue: ""- name: consumerIDvalue: "myGroup"

这里我们定义了一个store名叫做redis-store，所以我们要把上面的命令修改一下：

# curl -X POST -H "Content-Type: application/json" -d '[{ "key": "name", "value": "Bruce Wayne"}]' http://localhost:3500/v1.0/state/redis-store// 获取存储内容
# curl http://localhost:3500/v1.0/state/redis-store/name
"Bruce Wayne"

同时也可以通过redis-cli获取Redis中存储的内容：

# redis-cli
127.0.0.1:6379> keys *
1) "myapp||name"
127.0.0.1:6379> hgetall "myapp||name"
1) "data"
2) "\"Bruce Wayne\""
3) "version"
4) "1"

我们在添加Redis作为存储时还额外添加了Redis支持发布/订阅功能，这个功能如何实现呢？这里可能就需要编写额外程序实现了。我们这里采用官方的例子进行。订阅在dapr中有两种形式，一种是采用yaml声明组件形式，另外一种则可以通过编写代码形式实现。当然第一种方式和第二种方式互有优劣，前者更适合无缝集成，后者方便开发控制。这里为了演示直观性直接采用了编写代码方式实现。

package mainimport ("io""log""net/http""github.com/gin-gonic/gin"
)func main() {r := gin.Default()r.GET("/dapr/subscribe", func(ctx *gin.Context) {ctx.JSON(http.StatusOK, []map[string]string{{"pubsubname": "redis-pubsub","topic":      "deathStarStatus","route":      "dsstatus",},})})r.POST("/dsstatus", func(c *gin.Context) {b, _ := io.ReadAll(c.Request.Body)defer c.Request.Body.Close()log.Println(string(b))c.JSON(http.StatusOK, map[string]interface{}{"success": true})})r.Run("127.0.0.1:5000")
}

使用如下命令启动编译后的daprdemo，注意指定文件名时需要填写路径或者在$PATH中:

# dapr --app-id subapp --app-port 5000 run ~/daprdemo

在程序启动日志中我们可以看到dapr会尝试访问一些默认的endpoint读取可能的配置：

INFO[0000] application discovered on port 5000           app_id=subapp instance=127.0.0.1 scope=dapr.runtime type=log ver=1.0.1
== APP == [GIN] 2021/03/11 - 10:45:02 | 404 |         949ns |       127.0.0.1 | GET      "/dapr/config"INFO[0000] application configuration loaded              app_id=subapp instance=127.0.0.1 scope=dapr.runtime type=log ver=1.0.1
INFO[0000] actor runtime started. actor idle timeout: 1h0m0s. actor scan interval: 30s  app_id=subapp instance=127.0.0.1 scope=dapr.runtime.actor type=log ver=1.0.1
== APP == [GIN] 2021/03/11 - 10:45:02 | 200 |     540.891µs |       127.0.0.1 | GET      "/dapr/subscribe"INFO[0000] app is subscribed to the following topics: [deathStarStatus] through pubsub=redis-pubsub  app_id=subapp instance=127.0.0.1 scope=dapr.runtime type=log ver=1.0.1
WARN[0000] redis streams: BUSYGROUP Consumer Group name already exists  app_id=subapp instance=127.0.0.1 scope=dapr.contrib type=log ver=1.0.1
INFO[0000] dapr initialized. Status: Running. Init Elapsed 49.674504ms  app_id=subapp instance=127.0.0.1 scope=dapr.runtime type=log ver=1.0.1

接下来我们尝试使用dapr-cli对我们之前启动的myapp发送消息：

dapr publish --publish-app-id myapp --pubsub redis-pubsub --topic deathStarStatus --data '{"status": "completed"}'

在程序日志中获取到的输出为：

== APP == [GIN] 2021/03/11 - 10:45:05 | 200 |      122.15µs |       127.0.0.1 | POST     "/dsstatus"== APP == 2021/03/11 10:45:05 {"id":"9c237504-7cab-4a13-8582-92d9130fd016","source":"myapp","pubsubname":"redis-pubsub","traceid":"00-fba669a086f84650e882e3cadc55082c-ea466c080e359e68-00","data":{"status":"completed"},"specversion":"1.0","datacontenttype":"application/json","type":"com.dapr.event.sent","topic":"deathStarStatus"}

当然，除了pub/sub方式，我们也可以借助dapr提供的路由功能，直接进行服务调用：

# curl http://127.0.0.1:3500/v1.0/invoke/subapp/method/dsstatus -X POST
{"success":true}

其他的组件功能则可以参考官方文档中描述进行配置即可。

总结

dapr是一个功能强大的serverless运行时，除了上面提到的面向消息和请求存储的功能以外，还可以控制程序的HTTP请求与gRPC请求等等。除了这些功能外，还包含了服务的管理，还有可观测性支持等功能，是一个非常有潜力的运行时选择。

Dapr能否引领云原生中间件的未来？
云原生 | 阿里巴巴的Dapr实践与探索
Dapr | 云原生的抽象与实现
Dapr 可视化指南
Dapr 知多少 | 分布式应用运行时
Dapr 正式发布 1.0
Dapr 交通流量控制示例
Dapr是如何简化微服务的开发和部署
微软开源微服务运行时Dapr，赋能云原生应用开发
YARP实现Dapr服务调用的反向代理
Dapr微服务应用开发系列0：概述
Dapr微服务应用开发系列1：环境配置
Dapr微服务应用开发系列2：Hello World与SDK初接触
Dapr微服务应用开发系列3：服务调用构件块
Dapr微服务应用开发系列4：状态管理构件块
Dapr微服务应用开发系列5：发布订阅构建块
Windows环境下Dapr入门
云原生 | .NET 5 with Dapr 初体验
通过Dapr实现一个简单的基于.net的微服务电商系统
通过Dapr实现一个简单的基于.net的微服务电商系统(二)——通讯框架讲解
通过Dapr实现一个简单的基于.net的微服务电商系统(三)——一步一步教你如何撸Dapr
通过Dapr实现一个简单的基于.net的微服务电商系统(四)——一步一步教你如何撸Dapr之订阅发布
通过Dapr实现一个简单的基于.net的微服务电商系统(五)——一步一步教你如何撸Dapr之状态管理
通过Dapr实现一个简单的基于.net的微服务电商系统(六)——一步一步教你如何撸Dapr之Actor服务
通过Dapr实现一个简单的基于.net的微服务电商系统(七)——一步一步教你如何撸Dapr之服务限流
通过Dapr实现一个简单的基于.net的微服务电商系统(八)——一步一步教你如何撸Dapr之链路追踪
通过Dapr实现一个简单的基于.net的微服务电商系统(九)——一步一步教你如何撸Dapr之OAuth2授权
通过Dapr实现一个简单的基于.net的微服务电商系统(九)——一步一步教你如何撸Dapr之OAuth2授权-百度版
通过Dapr实现一个简单的基于.net的微服务电商系统(十)——一步一步教你如何撸Dapr之绑定
通过Dapr实现一个简单的基于.net的微服务电商系统(十一)——一步一步教你如何撸Dapr之自动扩/缩容
WebAssembly + Dapr = 下一代云原生运行时？
dapr 应用开发 | 环境配置
乘风破浪，.Net Core遇见Dapr，为云原生而生的分布式应用运行时
Dapr案例之高德 Serverless 平台建设及实践