本篇内容主要讲解“怎么从零开始使用Dapr简化微服务”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“怎么从零开始使用Dapr简化微服务”吧!
序言
现有的微服务模式需要再业务代码中集成大量基础设施模块，比如注册中心，服务发现，服务调用链路追踪，请求熔断，重试限流等等，使得系统过于臃肿重量级。
Dapr作为新一代微服务模式，使用sidecar模式，简化了现有微服务系统代码，将基础设施层以sidecar模式分离，使得开发人员更集中于业务逻辑编写。
本文以net6和dapr1.5为基础，搭建一个dapr的简单使用示例。
1、安装Docker
Dapr的运行依赖于Docker环境。
作为学习环境，使用Centos 7系统安装Docker。
安装Docker推荐使用daocloud一键安装命令：
curl -sSL https://get.daocloud.io/docker | sh安装完成后运行命令：
[root@localhost ~]# docker -vDocker version 20.10.11, build dea9396显示对应的Docker版本即安装成功。
2、安装Dapr CLI
官方解释：Dapr CLI 是您用于各种 Dapr 相关任务的主要工具。 您可以使用它来运行一个带有Dapr sidecar的应用程序， 以及查看sidecar日志、列出运行中的服务、运行 Dapr 仪表板。
下载Dapr CLI
wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash验证安装情况
dapr -v输出以下内容即安装成功。
CLI version: 1.5.0Runtime version: 1.5.0由于国内网络问题，使用官方的Dapr安装方法一般会遇到各种问题，因此把dapr下载下来，通过脚本进行安装。
修改hosts文件
vi /etc/hosts140.82.114.4 github.com 199.232.69.194 github.global.ssl.fastly.net140.82.114.9 codeload.github.com刷新缓存
yum install -y nscdservice nscd restart首先需要安装Git，然后执行以下命令：
git clone -v https://gitee.com/Two-Twoone/dapr-installer.gitcd dapr-installer/./install.sh虽然还是很慢，但是总比下不了好多了。
上面命令启动了几个容器，运行下列操作来验证：
[root@localhost dapr-installer]# docker ps --format "table {{.ID}}\t{{.Names}}\t{{.Ports}}"CONTAINER ID NAMES PORTSa0565f609846 dapr_placement 0.0.0.0:50005->50005/tcp, :::50005->50005/tcpc392f5cf7a18 dapr_redis 0.0.0.0:6379->6379/tcp, :::6379->6379/tcp2ee68c450b29 dapr_zipkin 9410/tcp, 0.0.0.0:9411->9411/tcp, :::9411->9411/tcp3、安装Net6 SDK
rpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm yum update yum install dotnet-sdk-6.04、创建应用程序
创建2个项目分别为 product，cart 引用Dapr
dotnet add package Dapr.AspNetCoreProgram.cs中对 的 AddDapr 调用将 DaprClient 类注册到 ASP.NET Core注入系统。 注册客户端后，现在可以将 的实例注入服务代码， DaprClient 以与 Dapr sidecar、构建基块和组件进行通信。
builder.Services.AddControllers().AddDapr();4.1、服务调用
在微服务系统中，服务与服务间的调用必不可少，难点主要集中在服务所在位置，发生错误时如何重试，负载均衡等问题。
Dapr中使用sidecar 作为服务的反向代理模块来解决这些问题。
prodcut项目增加下列代码
[Route("api/[controller]")] [ApiController] public class ProductController : ControllerBase { private ILogger<ProductController> _logger; public ProductController(ILogger<ProductController> logger) { _logger = logger; } private static readonly List<string> products = new List<string> { "aa", "bb", "cc", "dd", "ee", "ff", "gg", "hh", "ii", "jj", "kk", "ll", "mm", "nn" }; [HttpGet] public ActionResult Get() { _logger.LogInformation($"调用了获取商品方法"); string[] temps = new string[5]; for (int i = 0; i < 5; i++) { Random random = new Random(Guid.NewGuid().GetHashCode()); temps[i] = products[random.Next(0, products.Count - 1)]; } return Ok( temps); } }# 启动Product 项目dapr run --app-id ProductDemo --app-port 5010 --dapr-http-port 7015 -- dotnet /root/www/product/Dapr.Product.Sample.dll --urls http://*:5010cart项目增加下列代码，dapr支持http，grpc调用方式，这里以常用的webapi为例，使用http方式调用。
InvokeMethodAsync方法中appid对应的就是dapr run 中的appid，无需关系调用地址。
[Route("api/[controller]")] [ApiController] public class CartController : ControllerBase { private readonly DaprClient _daprClient; private readonly ILogger<CartController> _logger; public CartController(DaprClient daprClient, ILogger<CartController> logger) { _daprClient = daprClient; _logger = logger; } [HttpGet] [Route("GetProducts")] public async Task<IActionResult> GetProducts() { _logger.LogInformation($" Cart 获取商品"); var products = await _daprClient.InvokeMethodAsync<List<string>>(HttpMethod.Get, "ProductDemo", "/api/Product/GetAll"); return Ok(products); } }将程序上传到linux服务器，运行程序
# 启动 Cart 项目dapr run --app-id CartDemo --app-port 5020 --dapr-http-port 7025 -- dotnet /root/www/cart/Dapr.Cart.Sample.dll --urls http://*:5020调用接口，可以看到Cart项目几乎没有代码入侵就实现了接口调用。
[root@localhost ~]# curl -X 'GET' 'http://192.168.2.110:5020/api/Cart/GetProducts'["aa","bb","cc","dd","ee","ff","gg","hh","ii","jj","kk","ll","mm","nn"]Dapr内部使用了mDns进行了服务注册发现和负载均衡，部署多个product后调用，可以看到轮询调用效果。
在自承载模式下，Dapr 使用 mDNS 查找它。在 Kubernetes 模式下运行时，Kubernetes DNS 服务确定地址。
在调用失败和瞬态错误的情况下，服务调用会执行自动重试，Dapr 默认是开启了重试，所以接口不支持幂等是十分危险的行为。
4.2、发布订阅
发布订阅模式，主要是用于微服务间基于消息进行相互通信。你可能也会说，这也要拿出来说，我搞个RabbitMQ/Kafka就是了，
原来我们都会根据使用的组件引入不同的sdk，不同的消息队列监听、消费模式还不一样。
Dapr 提供了一个构建基块，可显著简化实现发布/订阅功能，从而和底层基础设施解耦，编写业务逻辑时不需要关心是什么消息队列。
再Program中添加发布订阅支持
app.UseCloudEvents(); app.UseEndpoints(endpoints => { endpoints.MapSubscribeHandler(); });订阅消息，使用Topic特性，传递pubsub和主题名称
[Topic("pubsub", "newUser")] public ActionResult subUserInfo(UserInfo us) { _logger.LogInformation($"接收到订阅消息 id:{us.id} name:{us.name},age:{us.age},sex:{us.sex}"); return Ok("处理完毕"); }发布消息，使用dapr公开方法PublishEventAsync，传递pubsub和主题名称，以及消息体
[HttpPost] public async Task<IActionResult> PubUserInfo(UserInfo us) { await _daprClient.PublishEventAsync("pubsub", "newUser", us); return Ok(); }消息发布订阅组件支持RabbitMQ，Redis，Kafka等。
4.3、状态管理
Dapr 默认使用 Redis 作为状态存储。它也支持MongoDB，PostgreSQL，SQL Server等。
它不会对上层暴露底层用的那个中间件，也就是说在不同环境下可以使用同一套代码来使用不同的中间件。
[HttpPost] [Route("SaveUserList")] public async Task<IActionResult> SaveUserList() { var temps = new List<UserInfo> { new UserInfo("小红",1,true,Guid.NewGuid().ToString()), new UserInfo("小黄",1,true,Guid.NewGuid().ToString()), new UserInfo("小蓝",1,true,Guid.NewGuid().ToString()) }; await _daprClient.SaveStateAsync("statestore", "UserList", temps); return Ok(1); } [HttpGet] [Route("GetUserList")] public async Task<IActionResult> GetUserList() { var list = await _daprClient.GetStateAsync<List<UserInfo>>("statestore", "UserList"); return Ok(list); } [HttpGet] [Route("DeleteUserList")] public async Task<IActionResult> DeleteUserList() { await _daprClient.DeleteStateAsync("statestore", "UserList"); return Ok(1); } public record UserInfo(string name, int age, bool sex, string id);4.4、链路追踪
传统微服务中,要实现链路追踪，对代码的侵入强。
Dapr 在 Sidecar 中添加了一个 http/grpc中间件。拦截所有应用程序流量，并自动注入关联 ID 以跟踪分布式事务。
使用 Zipkin 协议进行分布式跟踪，无需代码检测，使用可配置的跟踪级别自动跟踪所有流量。
到此，相信大家对“怎么从零开始使用Dapr简化微服务”有了更深的了解，不妨来实际操作一番吧！这里是编程网网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
