手把手教你学Dapr

Posted 2021-11-01 鬼谷子的程序人生

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了手把手教你学Dapr相关的知识，希望对你有一定的参考价值。

上一篇：手把手教你学Dapr - 2. 必须知道的概念

注意：

文章中提到的命令行工具即是Windows Terminal/PowerShell/cmd其中的一个，推荐使用Windows Terminal

运行命令行工具的时候建议以管理员身份，避免踩坑

为了保证操作顺畅，建议使用PowerShell先执行一下set-ExecutionPolicy RemoteSigned

安装Docker

因为Dapr CLI默认会在Docker内启动 redis、zipkin、placement。

当然这些也不是必须要安装的，只是推荐安装可以体验Dapr的完整能力，方便后续章节的学习。

下载并安装Docker Desktop

https://www.docker.com/products/docker-desktop
安装WSL2，使用命令行工具执行命令
```
wsl --instal
```
如果不能使用wsl直接安装的话可以手动安装，运行PowerShell并执行下面两句命令
```
dism.exe /online /enable-feature /featurename:Microsoft-Windows-Subsystem-Linux /all /norestart
dism.exe /online /enable-feature /featurename:VirtualMachinePlatform /all /norestart
```
如果你再次遇到错误提示：0x800f080c 功能名称 VirtualMachinePlatform 未知。

请保证自己的操作系统版本在Windows 10 build 18917以上
重启电脑后下载WSL2内核

https://wslstorestorage.blob.core.windows.net/wslblob/wsl_update_x64.msi
运行命令行工具，设置默认使用WSL2
```
wsl --set-default-version 2
```
下载Ubuntu 20.04

https://www.microsoft.com/store/apps/9n6svws3rx71
设置Docker使用WSL2

你“可能”需要一个小工具

不能说的秘密，看文件名猜功能

https://github.com.cnpmjs.org/dotnetcore/FastGithub/releases/download/2.0.4/fastgithub_win-x64.zip

安装Dapr CLI

官方解释：Dapr CLI 是您用于各种 Dapr 相关任务的主要工具。您可以使用它来运行一个带有Dapr sidecar的应用程序，以及查看sidecar日志、列出运行中的服务、运行 Dapr 仪表板。

CLI是必须要安装吗？其实也不是，但新手不建议去体验这些骚操作。后续文章会讲解脱离dapr cli工作。

运行Windows Terminal或PowerShell，执行命令，这里要耐心等待一下

iwr -useb https://raw.githubusercontent.com/dapr/cli/master/install/install.ps1 | iex

如果是cmd执行下面命令：

powershell -Command "iwr -useb https://raw.githubusercontent.com/dapr/cli/master/install/install.ps1 | iex"

验证安装，重新打开命令行工具执行命令dapr，看到下面的提示即安装正确

         __
    ____/ /___ _____  _____
   / __  / __ \'/ __ \\/ ___/
  / /_/ / /_/ / /_/ / /
  \\__,_/\\__,_/ .___/_/
              /_/

===============================
Distributed Application Runtime

Usage:
  dapr [command]

Available Commands:
  completion     Generates shell completion scripts
  components     List all Dapr components. Supported platforms: Kubernetes
  configurations List all Dapr configurations. Supported platforms: Kubernetes
  dashboard      Start Dapr dashboard. Supported platforms: Kubernetes and self-hosted
  help           Help about any command
  init           Install Dapr on supported hosting platforms. Supported platforms: Kubernetes and self-hosted
  invoke         Invoke a method on a given Dapr application. Supported platforms: Self-hosted
  list           List all Dapr instances. Supported platforms: Kubernetes and self-hosted
  logs           Get Dapr sidecar logs for an application. Supported platforms: Kubernetes
  mtls           Check if mTLS is enabled. Supported platforms: Kubernetes
  publish        Publish a pub-sub event. Supported platforms: Self-hosted
  run            Run Dapr and (optionally) your application side by side. Supported platforms: Self-hosted
  status         Show the health status of Dapr services. Supported platforms: Kubernetes
  stop           Stop Dapr instances and their associated apps. . Supported platforms: Self-hosted
  uninstall      Uninstall Dapr runtime. Supported platforms: Kubernetes and self-hosted
  upgrade        Upgrades a Dapr control plane installation in a cluster. Supported platforms: Kubernetes

Flags:
  -h, --help      help for dapr
  -v, --version   version for dapr

Use "dapr [command] --help" for more information about a command.

初始化Dapr

使用命令行工具执行命令
```
dapr init
```
如此之外还有一个精简版的安装方式
```
dapr init --slim
```
看看官方解释slim

在此模式下安装了两个不同的二进制文件 daprd 和 placement。 placement是给actor用的，之前有提到过。

在此模式下，不会为状态管理或发布/订阅安装任何默认组件（如 Redis），那就只能用服务调用。其他的需要用户自己设置环境和自定义组件。

说白了，你只用服务调用，那slim是可以的，否则的话你需要手动配置来解决CLI代替你做的那部分工作。

验证Dapr版本

dapr --version

当前时间下，我的版本是

CLI version: 1.4.0
Runtime version: 1.4.3

验证容器
```
docker ps
```
dapr init的容器是包括dapr_placement, dapr_redis, dapr_zipkin
验证组件目录，打开目录%USERPROFILE%\\.dapr\\，看到如下结构即代表安装完成

运行一个示例代码看看效果

运行环境准备

vs 2022/2019，建议直接上VS2022体验64位VS

https://visualstudio.microsoft.com/zh-hans/vs/preview/#download-preview

.net 6，如果你用的不是vs2022，需要自行安装.net 6

https://download.visualstudio.microsoft.com/download/pr/5bc3c525-d6d5-4370-8468-e44a1b948c03/fe758c9942966b88b52d92ce2823f6c0/dotnet-sdk-6.0.100-rc.2.21505.57-win-x64.exe

从Github下载示例代码

使用命令行工具克隆代码库到本地

ssh（推荐）用下面的命令

git clone git@github.com:doddgu/dapr-study-room.git

https用下面的命令

git clone https://github.com/doddgu/dapr-study-room.git

没有git的需要先安装一下git，具体教程可以自行百度

https://github.com/git-for-windows/git/releases/download/v2.33.1.windows.1/Git-2.33.1-64-bit.exe

使用Dapr运行.Net示例代码

使用命令行工具，跳转到源码目录dapr-study-room\\Assignment03\\Assignment.Server

Tips：在资源管理器找到源码目录

Win 11可以右键空白区域 -> 在Windows终端中打开即可

Win 11以下在资源管理器输入cmd
执行命令dapr run --app-id assignment-server --app-port 5038 dotnet run

可以先不用了解命令行的意思，后续章节会讲解

看到输入内容如下即运行成功

== APP == info: Microsoft.Hosting.Lifetime[14]
== APP ==       Now listening on: https://localhost:7038
== APP == info: Microsoft.Hosting.Lifetime[14]
== APP ==       Now listening on: http://localhost:5038
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Application started. Press Ctrl+C to shut down.
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Hosting environment: Development
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Content root path: D:\\Project\\OpenSource\\dapr-study-room\\Assignment03\\Assignment.Server
time="2021-10-27T18:06:11.8422605+08:00" level=info msg="application discovered on port 5038" app_id=assignment-server instance=SSHZ014 scope=dapr.runtime type=log ver=1.4.3
time="2021-10-27T18:06:11.8788949+08:00" level=info msg="application configuration loaded" app_id=assignment-server instance=SSHZ014 scope=dapr.runtime type=log ver=1.4.3
time="2021-10-27T18:06:11.8803982+08:00" level=info msg="actor runtime started. actor idle timeout: 1h0m0s. actor scan interval: 30s" app_id=assignment-server instance=SSHZ014 scope=dapr.runtime.actor type=log ver=1.4.3
time="2021-10-27T18:06:11.8844485+08:00" level=info msg="dapr initialized. Status: Running. Init Elapsed 1830.3305ms" app_id=assignment-server instance=SSHZ014 scope=dapr.runtime type=log ver=1.4.3
time="2021-10-27T18:06:11.8920835+08:00" level=info msg="placement tables updated, version: 0" app_id=assignment-server instance=SSHZ014 scope=dapr.runtime.actor.internal.placement type=log ver=1.4.3

还有一个验证方式，使用命令行工具执行命令dapr list

其中APP ID，APP PORT，COMMAND是不变的，其余都是变的

APP ID HTTP PORT GRPC PORT APP PORT COMMAND AGE CREATED PID

assignment-server 49948 49949 5038 dotnet run 13m 2021-10-27 18:06.09 22596

调用Dapr API

重新打开一个命令行工具

测试Dapr API，再打开一个命令行工具

dapr invoke --app-id assignment-server --method hello

验证运行是否成功

执行dapr inovoke的命令行窗口输出如下

App invoked successfully

执行dapr run的命令行窗口输出如下

== APP == Hello World!

这个Hello World就是Assignment.Server的API /hello 打印出来的，此时你的环境已经ok，且第一个示例也运行成功了

给自己点个赞吧

手把手教你学Dapr - 9. 可观测性

介绍

通过Tracing(跟踪)、Metrics(指标)、Logs(日志)和Health(运行状况)监控应用程序。

分布式跟踪

Dapr 使用 Zipkin 协议进行分布式跟踪和 Metrics 收集。由于 Zipkin 协议的普遍性，许多后端都是开箱即用的，例如 Stackdriver、Zipkin、New Relic 等。结合 OpenTelemetry Collector，Dapr 可以将跟踪导出到许多其他后端，包括但不限于 Azure Monitor、Datadog、Instana、Jaeger 和 SignalFX。

Tracing设计

Dapr 在 Dapr Sidecar 中添加了一个 HTTP/gRPC 中间件。中间件拦截所有 Dapr 和应用程序流量，并自动注入关联 ID 以跟踪分布式事务。这种设计有几个好处：

无需代码检测。使用可配置的跟踪级别自动跟踪所有流量。
跨微服务的一致性跟踪行为。跟踪是在 Dapr Sidecar 上配置和管理的，因此它在由不同团队制作并可能用不同编程语言编写的服务之间保持一致。
可配置和可扩展。利用 Zipkin API 和 OpenTelemetry Collector，Dapr 跟踪可以配置为与流行的跟踪后端一起使用，包括客户可能拥有的自定义后端。
您可以同时定义和启用多个导出器。

W3C 关联 ID

Dapr 使用标准的 W3C 跟踪上下文标头。对于 HTTP 请求，Dapr 使用 traceparent 标头。对于 gRPC 请求，Dapr 使用 grpc-trace-bin 标头。当一个没有跟踪 ID 的请求到达时，Dapr 会创建一个新的。否则，它会沿着调用链传递跟踪 ID。

配置

Dapr 使用概率抽样。采样率定义了对跟踪跨度进行采样的概率，其值可以介于 0 和 1（含）之间。默认采样率为 0.0001（即采样 10,000 个跨度中的 1 个）。

要更改默认跟踪行为，请使用配置文件。例如，以下配置对象将采样率更改为 1（即每个跨度都被采样），并使用 Zipkin 协议将跟踪发送到位于 http://zipkin.default.svc.cluster.local 的 Zipkin 服务器

yaml文件路径：%UserProfile%\\.dapr\\config.yaml

apiVersion: dapr.io/v1alpha1
kind: Configuration
metadata:
  name: tracing
  namespace: default
spec:
  tracing:
    samplingRate: "1"
    zipkin:
      endpointAddress: "http://zipkin.default.svc.cluster.local:9411/api/v2/spans"

注：将采样率更改为 0 会完全禁用跟踪。

W3C 跟踪上下文

Dapr 使用 W3C 跟踪上下文对服务调用和发布/订阅消息进行分布式跟踪。Dapr 完成了生成和传播跟踪上下文信息的所有繁重工作，仅在极少数情况下，您需要传播或创建跟踪上下文。

W3C trace context有以下优势：

为单个跟踪和请求提供唯一标识符，允许将多个提供程序的跟踪数据链接在一起。
提供转发特定于供应商的跟踪数据的商定机制，并避免跟踪在多个工具参与单个事务时中断。
提供中间商、平台和硬件提供商可以支持的行业标准。

有两种情况需要了解如何使用跟踪：

Dapr 在服务之间生成并传播跟踪上下文。
Dapr 生成跟踪上下文，您需要将跟踪上下文传播到另一个服务，或者您生成跟踪上下文，Dapr 将跟踪上下文传播到服务。

Dapr 在服务之间生成并传播跟踪上下文

在某些情况下，Dapr 会为您完成所有工作。您不需要创建和传播任何跟踪标头。Dapr 负责创建所有跟踪标头并传播它们。让我们通过示例来了解场景；

单个服务调用（服务 A -> 服务 B）
Dapr 在服务 A 中生成跟踪标头，这些跟踪标头从服务 A 传播到服务 B。
多个顺序服务调用（服务 A -> 服务 B -> 服务 C）
Dapr 在服务 A 中的请求开始时生成跟踪标头，这些跟踪标头从服务 A-> 服务 B -> 服务 C 等传播到进一步启用 Dapr 的服务。
请求是来自外部endpoint（例如从网关服务到启用 Dapr 的服务 A）

Dapr Sidecar 健康检查

Dapr 提供了一种使用 HTTP /healthz endpoint来确定其健康状况的方法。有了这个endpoint，可以探测 Dapr 进程或边车的健康状况，从而确定其准备情况和活跃度。

在将 Dapr 部署到托管平台（例如 Kubernetes）时，会自动为您配置 Dapr health endpoint。您无需进行任何配置。

Health endpoint: 与 Kubernetes 集成

Kubernetes 使用 readiness 和 liveness 探测来确定容器的健康状况。

kubelet使用活动探针来知道何时重新启动容器。例如，活动探测可以捕获死锁，即应用程序正在运行，但无法取得进展。在这种状态下重新启动容器有助于使应用程序更可用，尽管存在缺陷。

kubelet 使用就绪探针来了解容器何时准备好开始接受流量。当 pod 的所有容器都准备就绪时，它就被认为是准备好了的。这种准备信号的一个用途是控制哪些Pods被用作Kubernetes服务的后端。当 Pod 未准备好时，它将从Kubernetes服务负载均衡器中删除。

当与 Kubernetes 集成时，Dapr Sidecar 被注入了一个 Kubernetes 探针配置，告诉它使用 Dapr healthz endpoint。这是由 Sidecar Injector 系统服务完成的。与 kubelet 的集成如下图所示。

如何在 Kubernetes 中配置活性探针

在 pod 配置文件中，在容器规范部分添加了 liveness 探针，如下所示：

livenessProbe:
     httpGet:
       path: /healthz
       port: 8080
     initialDelaySeconds: 3
     periodSeconds: 3

在上面的例子中， periodSeconds 字段指定 kubelet 应该每 3 秒执行一次活性探测。initialDelaySeconds 字段告诉 kubelet 在执行第一次探测之前应该等待 3 秒。

注：任何大于或等于 200 且小于 400 的代码都表示成功。其他代码表示失败。

如何在 Kubernetes 中配置就绪探针

就绪探针的配置类似于活性探针。唯一的区别是您使用 readinessProbe 字段而不是 livenessProbe 字段。

readinessProbe:
      httpGet:
        path: /healthz
        port: 8080
      initialDelaySeconds: 3
      periodSeconds: 3

如何使用 Kubernetes 配置 Dapr Sidecar health endpoint

此配置由 Sidecar Injector 服务自动完成。Dapr 在端口 3500 上有它的 HTTP health endpint /v1.0/healthz，这可以与 Kubernetes 一起使用以进行就绪和活跃度探测。当注入 Dapr sidecar 时，readiness 和 liveness 探针在 pod 配置文件中配置为以下值。

livenessProbe:
      httpGet:
        path: v1.0/healthz
        port: 3500
      initialDelaySeconds: 5
      periodSeconds: 10
      timeoutSeconds : 5
      failureThreshold : 3
readinessProbe:
      httpGet:
        path: v1.0/healthz
        port: 3500
      initialDelaySeconds: 5
      periodSeconds: 10
      timeoutSeconds : 5
      failureThreshold: 3

.Net中使用可观测性

创建Assignment.Server

创建类库项目，并添加Dapr.AspNetCore, OpenTelemetry, OpenTelemetry.Instrumentation.AspNetCore, OpenTelemetry.Instrumentation.Http,OpenTelemetry.Extensions.Hosting和OpenTelemetry.Exporter.ZipkinNuGet包引用，最后修改程序端口为5000。

!!!注：版本很重要，NuGet要打开包含预发行版，并且使用指定版本

OpenTelemetry-1.2.0-beta1

OpenTelemetry.Instrumentation.AspNetCore-1.0.0-rc8

OpenTelemetry.Instrumentation.Http-1.0.0-rc8

OpenTelemetry.Exporter.Zipkin-1.2.0-beta1

OpenTelemetry.Extensions.Hosting-1.0.0-rc8

修改program.cs

using OpenTelemetry.Resources;
using OpenTelemetry.Trace;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddOpenTelemetryTracing((tracerProviderBuilder) =>
    tracerProviderBuilder
        .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService("testobservability"))
        .AddAspNetCoreInstrumentation()
        .AddHttpClientInstrumentation()
        .AddZipkinExporter(zipkinOptions =>
        
            zipkinOptions.Endpoint = new Uri("http://localhost:9411/api/v2/spans");
        
    )
);
var app = builder.Build();

app.Map("/Amazing", async (HttpContext context) =>

    if (context.Request.Headers.TryGetValue("traceparent", out var traceparent))
    
        Console.WriteLine($"TraceParent: traceparent");
    
    if (context.Request.Headers.TryGetValue("tracestate", out var tracestate))
    
        Console.WriteLine($"TraceState: tracestate");
    

    System.Diagnostics.Activity.Current?.SetParentId(traceparent.ToString());
    _ = await new HttpClient().GetStringAsync("https://www.baidu.com");
    Console.WriteLine($"Invoke succeed: traceID:traceparent");
);

app.Run();

可以看到我们直接演示了一个好玩的用法，就是开启.Net的OpenTelemetry，然后修改Diagnostics.Activity的ParentId，让当前的Tracing跟Dapr Sidecar传来的TraceId一致。

运行Assignment.Server

使用Dapr CLI来启动，先使用命令行工具跳转到目录 dapr-study-room\\Assignment07\\Assignment.Server，然后执行下面命令

dapr run --app-id testobservability --app-port 5000 --dapr-http-port 3500 --dapr-grpc-port 50001 dotnet run

使用Dapr CLI发个命令看看

dapr invoke --app-id testobservability --method /Amazing

打开Zipkin，地址：http://localhost:9411/, 来看一下Zipkin的Tracing，不单有Dapr Sidecar的请求记录进来了，还跟HttpClient的捆绑在了起来，是的，有趣的就在这里。

除了可以跟踪HttpClient以外，还有EF Core等都集成了。

至于Metrics和Logs集成也是非常简单，需要搭配不同的后端如Prometheus, Fluentd等。甚至可以通过自定义Exporter自行对接一些云厂商的云服务。

本章源码

Assignment09

https://github.com/doddgu/dapr-study-room

我们正在行动，新的框架、新的生态

我们的目标是自由的、易用的、可塑性强的、功能丰富的、健壮的。

所以我们借鉴Building blocks的设计理念，正在做一个新的框架MASA Framework，它有哪些特点呢？

原生支持Dapr，且允许将Dapr替换成传统通信方式
架构不限，单体应用、SOA、微服务都支持
支持.Net原生框架，降低学习负担，除特定领域必须引入的概念，坚持不造新轮子
丰富的生态支持，除了框架以外还有组件库、权限中心、配置中心、故障排查中心、报警中心等一系列产品
核心代码库的单元测试覆盖率90%+
开源、免费、社区驱动
还有什么？我们在等你，一起来讨论

经过几个月的生产项目实践，已完成POC，目前正在把之前的积累重构到新的开源项目中

目前源码已开始同步到Github（文档站点在规划中，会慢慢完善起来）：

MASA.BuildingBlocks

MASA.Contrib

MASA.Utils

MASA.EShop

BlazorComponent

MASA.Blazor

QQ群：7424099

微信群：加技术运营微信（MasaStackTechOps），备注来意，邀请进群

以上是关于手把手教你学Dapr的主要内容，如果未能解决你的问题，请参考以下文章

手把手教你学Dapr

安装Docker

如果不能使用wsl直接安装的话可以手动安装，运行PowerShell并执行下面两句命令

如果你再次遇到错误提示：0x800f080c 功能名称 VirtualMachinePlatform 未知。

你“可能”需要一个小工具

安装Dapr CLI

初始化Dapr

运行一个示例代码看看效果

运行环境准备

从Github下载示例代码

使用Dapr运行.Net示例代码

调用Dapr API

给自己点个赞吧

手把手教你学Dapr - 9. 可观测性

介绍

分布式跟踪

Tracing设计

W3C 关联 ID

配置

W3C 跟踪上下文

Dapr 在服务之间生成并传播跟踪上下文

Dapr Sidecar 健康检查

Health endpoint: 与 Kubernetes 集成

如何在 Kubernetes 中配置活性探针

如何在 Kubernetes 中配置就绪探针

如何使用 Kubernetes 配置 Dapr Sidecar health endpoint

.Net中使用可观测性

创建Assignment.Server

运行Assignment.Server

本章源码

我们正在行动，新的框架、新的生态

如果不能使用wsl直接安装的话可以手动安装，运行`PowerShell`并执行下面两句命令