CICD:DaprDemo在K8S云端托管项目架构及实现

1、架构 1.1、架构概览

为了模仿服务间的相互调用，定义了2个service，Service02调用Service01的API。每个运行的服务都有一个 Dapr 运行时进程(Daprd)以Sidecar模式运行。Sidecar 编程模型鼓励每个应用程序与自己的 Dapr 实例对话，Dapr 实例会相互发现并进行通信。在k8s集群中国，Dapr 使用 CoreDNS 协议提供负载均衡，将Service02的请求分布到两个Service01的实例上。 1.2、架构优势

关注点分离

Service02只需要知道Service01的app-id即可Service01不需要知道SideCar的存在Service01

不同实例使用相同app-id不同实例使用不同端口Service02

不需要知道Service01的实例数量不需要知道Service01的端口号SideCar

Service02不需要知道SideCar的端口号Service01的实例可以随意增加和减少SideCar通过心跳发现或剔除Service01的实例2、新建一个ASP.NET Core Web API项目 Service01

新建HelloController定义一个API: api/hello每个Service01实例分配不同的InstanceIdAPI被访问时，返回InstanceId，来验证负载均衡效果

using Microsoft.AspNetCore.Mvc;namespace Service01.Controllers{ [ApiController] public class HelloController : Controllerbase { // 每个Service01实例分配不同的InstanceId private static readonly string InstanceId = Guid.NewGuid().ToString(); [HttpGet("api/Hello")] public async Task Hello() { await Task.CompletedTask; // API被访问时，返回InstanceId，来验证负载均衡效果 return Ok(new { Service = "Service01", InstanceId }); } }}

3. 新建一个ASP.NET Core Web API项目 Service02 3.1、引用Dapr.AspNetCore包

net6.0 enable enable

3.2、注入Dapr service

var builder = WebApplication.CreateBuilder(args);builder.Services.AddControllers() .AddDapr(); // 注入Dapr servicevar app = builder.Build();app.UseAuthorization();app.MapControllers();app.Run();

3.3. 新建HelloController

通过dapr访问Service01的API

using Dapr.Client;using Microsoft.AspNetCore.Mvc;namespace Service02.Controllers{ [ApiController] public class HelloController : Controllerbase { private readonly DaprClient _daprClient; public HelloController(DaprClient daprClient) { _daprClient = daprClient; } [HttpGet("api/Hello")] public async Task Hello() { // 通过dapr访问Service01的API var result = await _daprClient.InvokeMethodAsync