本篇内容主要讲解“怎么从零开始使用Dapr简化微服务”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“怎么从零开始使用Dapr简化微服务”吧!
现有的微服务模式需要再业务代码中集成大量基础设施模块，比如注册中心，服务发现，服务调用链路追踪，请求熔断，重试限流等等，使得系统过于臃肿重量级。
Dapr作为新一代微服务模式，使用sidecar模式，简化了现有微服务系统代码，将基础设施层以sidecar模式分离，使得开发人员更集中于业务逻辑编写。
本文以net6和dapr1.5为基础，搭建一个dapr的简单使用示例。
Dapr的运行依赖于Docker环境。
作为学习环境，使用Centos 7系统安装Docker。
安装Docker推荐使用daocloud一键安装命令：
curl -sSL https://get.daocloud.io/docker | sh
安装完成后运行命令：
[root@localhost ~]# docker -v Docker version 20.10.11, build dea9396
显示对应的Docker版本即安装成功。
官方解释：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.0 Runtime version: 1.5.0
由于国内网络问题，使用官方的Dapr安装方法一般会遇到各种问题，因此把dapr下载下来，通过脚本进行安装。
修改hosts文件
vi /etc/hosts 140.82.114.4 github.com 199.232.69.194 github.global.ssl.fastly.net 140.82.114.9 codeload.github.com
刷新缓存
yum install -y nscd service nscd restart
首先需要安装Git，然后执行以下命令：
git clone -v https://gitee.com/Two-Twoone/dapr-installer.git cd dapr-installer/ ./install.sh
虽然还是很慢，但是总比下不了好多了。
上面命令启动了几个容器，运行下列操作来验证：
[root@localhost dapr-installer]# docker ps --format "table {{.ID}}\t{{.Names}}\t{{.Ports}}"
CONTAINER ID NAMES PORTS
a0565f609846 dapr_placement 0.0.0.0:50005->50005/tcp, :::50005->50005/tcp
c392f5cf7a18 dapr_redis 0.0.0.0:6379->6379/tcp, :::6379->6379/tcp
2ee68c450b29 dapr_zipkin 9410/tcp, 0.0.0.0:9411->9411/tcp, :::9411->9411/tcprpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm yum update yum install dotnet-sdk-6.0
创建2个项目分别为 product，cart 引用Dapr
dotnet add package Dapr.AspNetCore
Program.cs中对 的 AddDapr 调用将 DaprClient 类注册到 ASP.NET Core注入系统。 注册客户端后，现在可以将 的实例注入服务代码， DaprClient 以与 Dapr sidecar、构建基块和组件进行通信。
builder.Services.AddControllers().AddDapr();
在微服务系统中，服务与服务间的调用必不可少，难点主要集中在服务所在位置，发生错误时如何重试，负载均衡等问题。
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://*:5010
cart项目增加下列代码，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 默认是开启了重试，所以接口不支持幂等是十分危险的行为。
发布订阅模式，主要是用于微服务间基于消息进行相互通信。你可能也会说，这也要拿出来说，我搞个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等。
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);传统微服务中,要实现链路追踪，对代码的侵入强。
Dapr 在 Sidecar 中添加了一个 http/grpc中间件。拦截所有应用程序流量，并自动注入关联 ID 以跟踪分布式事务。
使用 Zipkin 协议进行分布式跟踪，无需代码检测，使用可配置的跟踪级别自动跟踪所有流量。
到此，相信大家对“怎么从零开始使用Dapr简化微服务”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
