[Abp vNext 入坑分享] – 8.Redis与Refit的接入

前言

本章竣事之后,这个abp vnext系列算是开端完结了,基础的组件都已经接入了。若是列位还需要其它的组件的话,可以自己按需要举行接入使用。实在这个只是一个基础的框架,可以自己根据需要举行变通的。好比:若是没有太多需求且更熟悉三层的同砚可以把application和application.contract去掉就是一个三层架构了。基础是基础,用好照样要看列位对营业的明白是否够深入才气施展好框架的作用。

对于各个框架的使用,建议是:先使用起来,然后熟悉它,再然后革新它。并不是根据别人的尺度一味的照抄,每一个框架都市有响应的痛点。。因此在使用的时刻是要根据项目与团队来举行评估是否适用,若不适用的时刻,若何去调整。这个不仅仅是架构师要思量的事情。

小我私家履历(仅作参考):建议每一位有想法开发人员都要保持自己的独立思考能力,无论是针对营业照样手艺。然则前期是先积累手艺自己验证,多在群里友好交流,不说教只剖析。先从大量的文章和博客中获取知识,理出自己需要的举行沉淀。到了一定境界(这个一定境界只能看感受,这种感受会异常的显著,需要自己保持反思,相当于对照大的坎,越过之后就是新的最先的这种)之后,再配合一些好的收费课程和书籍去深入和系统化的学习。好比:曾经我就在群里看到一个大佬的分享然后最先入门算法,那时他分享的是hash算法,后面我有把它很白话的用场景分享给前端同伙,他也才发现原来还能这么玩。有需要的话,可以在谈论区留言,我看下是否需要找个时间整理出来,可能时间会对照长一点。。

简要说明

【项目源码】

【章节目录】

本文主要先容若何在abp vnext中使用redis和httpclient。

首先Redis是现在应用最普遍的分布式缓存方案,这个就不举行更多的先容了。而我们行使的组件是Microsoft.Extensions.Caching.StackExchangeRedis。此组件也是依赖于StackExchange.Redis,本文直接使用IDistributedCache来做字符的缓存,现在此接口主要是支持string与byte[]的操作,因此缓存实体也是通过序列化成字符串来举行缓存。若有更进一步的类型缓存需要的同砚则可以通过StackExchange.Redis的方式来操作如:zset,list,hash等类型,这里就不作过多先容了。到时刻看情况,若是真的有很多人反馈需要的话,我再写下怎么对照完整的接入StackExchange.Redis吧!

其次是httpclient,由于我们的系统经常会请求到列位外部的接口。因此这个的引入也是异常重要的。我们使用来治理的组件是Refit.HttpClientFactory。通过Refit.HttpClientFactory,我们可以使用接口与注解的方式来请求外部接口。治理起来异常利便,同时此组件也是通过HttpClientFactory来治理的,并不需要我们作过多的优化。

具体步骤

1.1、首先我们需要知道的是,我们的Redis是主要是在Application层才会需要使用的。因此,原来Host内里的引入的Redis相关组件可以删除了。定位到AbpVnext.Learn.HttpApi.Host把Microsoft.Extensions.Caching.StackExchangeRedis,Microsoft.AspNetCore.DataProtection.StackExchangeRedis卸载掉。同时删除掉Host中的Module的相关代码。

1.2、然后我们定位到AbpVnext.Learn.Domain层安装我们需要的nuget包Microsoft.Extensions.Caching.StackExchangeRedis。定位到LearnDomainModule,增添以下代码用于注入IDistributedCache的Redis服务:

public override void ConfigureServices(ServiceConfigurationContext context)
        {
            var configuration = context.Services.GetConfiguration();
            context.Services.AddStackExchangeRedisCache(options =>
            {
                options.Configuration = configuration["Redis:Configuration"];
            });
        }

1.3、然后我们在UserAppServices中使用IDistributedCache去操作缓存,如下:

public async Task<UserDto> get_userbyuserid(Guid userid)
        {
            var cachekey = $"user_{userid.ToString()}";
            var userdto_str =await _distributedCache.GetStringAsync(cachekey);
            if (String.IsNullOrEmpty(userdto_str))
            {
                var usermodel = await _repository.get_userinfo(userid);
                if (usermodel != null)
                {
                    var userdto = new UserDto() { Id = usermodel.Id, user_status = usermodel.user_status, user_name = usermodel.user_name, user_phone = usermodel.user_phone };
                    await _distributedCache.SetStringAsync(cachekey, Newtonsoft.Json.JsonConvert.SerializeObject(userdto));
                    return userdto;
                }
            }
            else
            {
                return Newtonsoft.Json.JsonConvert.DeserializeObject<UserDto>(userdto_str);
            }
   return null;
    }

1.4、修改UserAppServices中的get_userbyuserid方式如下:

public async Task<UserDto> get_userbyuserid(Guid userid)
        {
            var cachekey = $"user_{userid.ToString()}";
            var userdto_str =await _distributedCache.GetStringAsync(cachekey);
            if (String.IsNullOrEmpty(userdto_str))
            {
                var usermodel = await _repository.get_userinfo(userid);
                if (usermodel != null)
                {
                    var userdto = new UserDto() { Id = usermodel.Id, user_status = usermodel.user_status, user_name = usermodel.user_name, user_phone = usermodel.user_phone };
                    await _distributedCache.SetStringAsync(cachekey, Newtonsoft.Json.JsonConvert.SerializeObject(userdto));
                    return userdto;
                }
            }
            else
            {
                return Newtonsoft.Json.JsonConvert.DeserializeObject<UserDto>(userdto_str);
            }
           return null;
        }

然后调试项目,挪用init接口,查看Redis如下:

一文带你了解nginx基础

我们可以看到,IDistributedCache的挪用String操作到了Redis内里是使用的hash结构来做存储的。

[Abp vNext 入坑分享] - 8.Redis与Refit的接入

1.5、封装一个RedisHelper来统一操作Redis,这样若是后期修改了组件也不需要修改太多的代码。如下图,

[Abp vNext 入坑分享] - 8.Redis与Refit的接入

修改UserAppServices中的方式如下:

[Abp vNext 入坑分享] - 8.Redis与Refit的接入

调试后,效果与原来的redis一致。

2.1、接下来我们来接入Refit.HttpClientFactory,实在我们的httpclient也是在Application层才使用的。因此我们也是在Domain层举行接入。Refit的接入的话,建议是为每一个差别的外部请求的根域名界说一个接口。然后再引入,这是由于Refit注入是需要server的。下面我们拿一个微信的Api接口来做为入门例子。

2.2、首先界说IWechatApi接口加入以下代码:

		//获取微信民众号的access_token
        [Get("/cgi-bin/token")]
        Task<WechatAccessTokenModel> get_accesstoken(string appid, string secret, string grant_type = "client_credential");

在Dommain.Shared中补充好需要的WechatAccessTokenModel。对应的是微信民众号接口返回的字段。access_token,expires_in,一样平常我会界说一个BaseWechatModel用于吸收errcode,errmsg。如下

 public class BaseWechatModel
    {
        //错误时微信会返回错误码
        public int errcode { get; set; }
        //错误信息
        public string errmsg { get; set; }
    }
 //微信获取Access_Token的模子
    public class WechatAccessTokenModel: BaseWechatModel
    {
        public string access_token { get; set; }
        public int expires_in { get; set; }
    }

2.3、接下来我们回到LearnDomainModule中,注入IWechatApi如下:

context.Services.AddRefitClient<IWechatApi>().ConfigureHttpClient(c => c.BaseAddress = new Uri("https://api.weixin.qq.com"));

然后我们在UserAppServices随便找个方式挪用一下,试试效果如下则示意我挪用的返回是正常的。由于我使用的appid是错误的导致的。

[Abp vNext 入坑分享] - 8.Redis与Refit的接入

原创文章,作者:admin,如若转载,请注明出处:https://www.2lxm.com/archives/12145.html