标签：vNext get Redis Refit user usermodel userdto public

前言

本章结束之后，这个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如下：

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

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

修改UserAppServices中的方法如下：

调试后，效果与原来的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是错误的导致的。

标签：vNext,get,Redis,Refit,user,usermodel,userdto,public
来源： https://www.cnblogs.com/twoBcoder/p/12968414.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。