温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么从零开始使用Dapr简化微服务

发布时间:2021-11-29 15:05:31 来源:亿速云 阅读:349 作者:iii 栏目:开发技术

本篇内容主要讲解“怎么从零开始使用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 -v
    Docker 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.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/tcp

    3、安装Net6 SDK

    rpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm
     yum update
     yum install dotnet-sdk-6.0

    4、创建应用程序

    创建2个项目分别为 product,cart 引用Dapr

    dotnet add package Dapr.AspNetCore

    Program.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://*: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简化微服务

    在调用失败和瞬态错误的情况下,服务调用会执行自动重试,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简化微服务

    怎么从零开始使用Dapr简化微服务

    到此,相信大家对“怎么从零开始使用Dapr简化微服务”有了更深的了解,不妨来实际操作一番吧!这里是亿速云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI