Dapr 服务调用

通过使用服务调用，您的应用程序可以使用标准的 gRPC 或 HTTP 协议与其他应用程序可靠、安全地通信。

1.  为什么不直接用HttpClientFactory

先问几个问题：

• 如何发现和调用不同服务的方法
• 如何安全地调用其他服务，并对方法应用访问控制
• 如何处理重试和瞬态错误
• 如何使用分布式跟踪指标来查看调用图来诊断生产中的问题

此时你会发现这些事情HttpClientFactory没有帮你完成，而在微服务中这些又是必不可少的能力，接下来看看服务调用都做了什么。

2.  服务调用如何工作

先看一下两个服务之间的调用顺序：

1. 服务A 向服务 B 发起一个 HTTP/gRPC 的调用。调用转到了本地的 Dapr sidecar；
2. Dapr 使用名称解析组件发现服务 B 的位置；
3. Dapr 将消息转发至服务 B 的 Dapr sidecar；

   注: Dapr sidecar 之间的所有调用都通过 gRPC 来提高性能。仅服务与 Dapr sidecar 之间的调用可以是 HTTP 或 gRPC。

4. 服务 B 的 Dapr sidecar 将请求转发至服务B 上的特定端点 (或方法) 。 服务B 随后运行其业务逻辑代码；
5. 服务 B 发送响应给服务 A。 响应将转至服务B 的 Dapr sidecar；
6. Dapr 转发响应至服务 A 的 Dapr sidecar；
7. 服务 A 接收响应。

3. 命名空间作用域

默认情况下，调用同一个命名空间的其他服务可以直接使用 AppID（假设是：nodeapp）。

localhost:3500/v1.0/invoke/nodeapp/method/neworder

服务调用也支持跨命名空间调用，在所有受支持的宿主平台上，Dapr AppID 遵循 FQDN 格式，其中包括目标命名空间。

FQDN：(Fully Qualified Domain Name)全限定域名：同时带有主机名和域名的名称，并通过符号 “.”  连接在一起。

例如：主机名是 bigserver，域名是 mycompany.com，那么 FQDN 就是 bigserver.mycompany.com。

​ 注：FQDN 是通过符号 . 来拼接域名的，这也就解释了AppID 为什么不能用符号 .，这里不记住的话，应该会有不少小伙伴会踩坑。

​ 比如 .net 开发者习惯用 A.B.C 来命名项目，但 AppID 需要把 . 换成 - ，且所有单词最好也变成小写 ，建议把它变成约定遵守。

比如调用命名空间：production，AppID：nodeapp

localhost:3500/v1.0/invoke/nodeapp.production/method/neworder

这在 K8s 集群中的跨名称空间调用中特别有用。

4. 服务间安全性

通过托管平台上的相互(mTLS)身份验证，包括通过 Dapr Sentry 服务的自动证书转移，可以确保 Dapr 应用程序之间的所有调用的安全。 下图显示了自托管应用程序的情况。

5. 访问控制

应用程序可以控制哪些其他应用程序可以调用它们，以及通过访问策略授权它们做什么。 这使您能够限制具有个人信息的敏感应用程序不被未经授权的应用程序访问，并结合服务到服务的安全通信，提供了软多租户部署。

6. 重试

在调用失败和瞬态错误的情况下，服务调用执行自动重试，并在回退时间段内执行。

注：自动重试，默认是开启的，也可以关闭。如果不关闭并且业务又不支持幂等的话，就会很危险。建议服务的接口要设计支持幂等，这在微服务里也是一个标配的选择。

导致重试的错误有:

• 网络错误，包括端点不可用和拒绝连接。
• 由于在调用/被调用的Dapr sidecars上更新证书而导致的身份验证错误。
• 每次呼叫重试的回退间隔为1秒，最多为3次。
• 通过 gRPC 与目标 Sidecar 连接的超时时间为5秒。

7. 可插拔的服务发现

Dapr 可以在各种托管平台上运行。 为了启用服务发现和服务调用，Dapr 使用可插拔的名称解析组件。

例如，K8s 名称解析组件使用 K8s DNS 服务来解析集群中运行的其他应用程序的位置。

自托管机器可以使用mDNS名称解析组件。

Consul名称解析组件可以在任何托管环境中使用，包括K8s或自托管环境。

自托管机器使用mDNS，在开发环境中后面文章会推荐 VS 上的无缝开发体验，就是基于 mDNS。

但它有点点小问题，我们已经解决了。你只需要像开发一个控制台程序一样，基于Minimal API开心的F5就可以。

8. 使用mDNS进行轮询负载均衡

mDNS轮询调用：

9. 可观测性的跟踪和指标

默认情况下，将跟踪应用程序之间的所有调用，并收集指标，以提供应用程序的洞察力和诊断，这在生产场景中尤其重要。

这为您提供了服务之间调用的调用图和指标。

10. 服务调用API和gRPC代理

pythonapp 通过Dapr sidecar 调用 nodeapp，通过服务调用的 API 及 gRPC 代理依然是上面见到的那个调用流程，做到了语言无关。

11. 使用 HTTP 调用服务

创建Assignment.Server

创建ASP.NET Core空项目，并修改launchSettings.json，让启动HTTP的启动端口变为5000

profiles.Assignment.Server.applicationUrl 的值改为 "https://localhost:6000;http://localhost:5000"

修改Program.cs文件

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();

app.MapPost("/", () => Console.WriteLine("Hello!"));

app.MapGet("/Hello1", () =>
{
    Console.WriteLine("Hello World1!");
    return $"\"Hello World1!\"";
});

app.MapPost("/Hello2", () => Console.WriteLine("Hello World2!"));

app.Map("/Hello3", () => Console.WriteLine("Hello World3!"));

app.Run();

此时一共有4个服务

• / ：Post方法，打印Hello!
• /Hello1：Get方法，打印Hello World1!，返回Hello World1!

  注：返回的类型要是Json字符串，方便SDK反序列化

• /Hello2：Post方法，打印Hello World2!
• /Hello3：不带后缀表示适配所有方法，打印Hello World3!

先使用Dapr CLI来验证一下

运行Assignment.Server：在目录dapr-study-room\Assignment04\Assignment.Server打开命令行工具，并执行下面命令

dapr run --app-id assignment-server --app-port 5000 dotnet watch

细心的小伙伴应该可以发现与上一篇的命令有一点点不同，dontet run变成了dotnet watch，这样会开启热重载，方便调试

调用服务：再打开一个新的命令行工具，并执行下面命令

dapr invoke --app-id assignment-server --method /
dapr invoke --app-id assignment-server --method Hello1
dapr invoke --app-id assignment-server --method Hello2
dapr invoke --app-id assignment-server --method Hello3

可以发现4个命令都调用成功了，但是Assignment.Server输出结果有点意外

== APP == Hello!
== APP == Hello World2!
== APP == Hello World3!

是的，没有Hello World1!，那怎么办呢？我们把Hello1的命令改一下

dapr invoke --app-id assignment-server --method Hello1 --verb GET

invoke调用的输出除了App invoked successfully以外还多了一行Hello World1!

与此同时Assignment.Server的输出正确了

== APP == Hello World1!

除此之外invoke还有一些参数，比如--data,--data-file，喜欢研究Dapr CLI的小伙伴可以继续尝试。不过一般情况下用SDK就可以了

创建Assignment.Client

HTTP服务调用

创建控制台应用程序项目，使用NuGet包管理器添加Dapr.Client SDK，并修改Program.cs文件

using Dapr.Client;

var appId = "assignment-server";

var client = new DaprClientBuilder().Build();

await client.InvokeMethodAsync(appId, "/");

var resp = await client.InvokeMethodAsync<string>(HttpMethod.Get, appId, "Hello1");
Console.WriteLine($"Hello1 Response: {resp}");

await client.InvokeMethodAsync(appId, "Hello2");

await client.InvokeMethodAsync(appId, "Hello3");

看几个细节

• DaprClient是从DaprClinetBuilder Build出来的

  还有一种方式使用DaprClient，通过DI

  首先都是需要添加Dapr.AspNetCore NuGet包

  然后开始有分支了，如果是以前Web API的方式可以在Startup.cs文件ConfigureServices方法加入一行代码

  services.AddControllers().AddDapr();
  

  如果使用Minimal API默认是没有Controllers的，那可以在var builder = WebApplication.CreateBuilder(args); 之后加入一行代码

  builder.Services.AddDaprClient();
  

  成功的注入进来了，在构造函数或者[FromServices]里愉快的玩耍吧

• HttpMethod.Post 的我都没有指定，默认就是Post
• HttpMethod.Get的时候，返回值会自动用Json反序列化

  不喜欢Json？可以通过 DaprClient.CreateInvokeHttpClient 构造 HttpClient，聪明的你肯定知道后面怎么办了

注：

1. Minimal API虽香，但新，所以不是所有功能都支持，比如从参数中直接映射状态管理，要等Minimal API支持Model Binder以后且SDK也同步支持了才可以
2. DaprClient是TCP的，也是线程安全的，可以大胆的复用，如果不用DI的话不需要频繁构建DaprClient

验证调用成功

使用命令行工具打开目录dapr-study-room\Assignment04\Assignment.Client，然后执行命令

dotnet run

如果你不是用VS Code终端的PowerShell执行dapr run就可能遇到下面的错误

即便你没有遇到也建议了解一下如何支持非默认端口

An exception occurred while invoking method: '/' on app-id: 'assignment-server'
 ---> System.Net.Http.HttpRequestException: 由于目标计算机积极拒绝，无法连接。 (127.0.0.1:3500)
 ---> System.Net.Sockets.SocketException (10061): 由于目标计算机积极拒绝，无法连接。

因为上面使用dapr run的时候没有指定dapr http port，而默认client访问的是3500端口

解决的办法有两种：

1. 修改Assignment.Server启动参数，增加--dapr-http-port 3500，这个方法治标不治本，因为将来我们可能启动多个服务

   dapr run --app-id assignment-server --app-port 5000 --dapr-http-port 3500 dotnet watch
   

2. 修改Assignment.Client的环境变量

   首先执行dapr list查看端口，以下面为例，HTTP PORT是51460

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

   assignment-server 51460 51461 5000 dotnet watch 7s 2021-10-29 14:13.49 11676

   修改Assignment.Client的启动参数，注意把51460换成你自己的端口，使用PowerShell执行下面命令

   $Env:DAPR_HTTP_PORT = 51460
   dotnet run
   

再执行一次dotnet run就可以看到正确的输出结果了

Hello1 Response: Hello World1!

gRPC服务调用

调用 InvokeMethodGrpcAsync，然后 dapr-http-port 换成 dapr-grpc-port，DAPR_HTTP_PORT 换成 DAPR_GRPC_PORT。

12. 查看跟踪

还记得dapr init的时候docker里有个zipkin吧，通过zipkin可以看一下调用跟踪，通过浏览器打开下面地址：http://localhost:9411/。

此时页面为空：

根据步骤操作一下就可以看到：

随便点开一行数据尾部的SHOW，就可以看到调用详情

13. 本章源码

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