小白开学Asp.Net Core 《四》

程序员文章站 2023-12-02 12:13:40

小白开学Asp.Net Core《四》 —— 使用AspectCore-Framework 一、AspectCore-Framework 说AspectCore-Framework不得不先谈谈的AOP， AOP：在软件业，AOP为Aspect Oriented Programming的缩写，意为：面 ......

小白开学asp.net core《四》

—— 使用aspectcore-framework

一、aspectcore-framework

　说aspectcore-framework不得不先谈谈的aop，

　　aop：在软件业，aop为aspect oriented programming的缩写，意为：面向切面编程，通过预编译方式和运行期动态代理实现程序功能的统一维护的一种技术。aop是oop的延续，是软件开发中的一个热点，是函数式编程的一种衍生范型。利用aop可以对业务逻辑的各个部分进行隔离，从而使得业务逻辑各部分之间的耦合度降低，提高程序的可重用性，同时提高了开发的效率。(来自于百度百科)

aspectcore-framework 的具体介绍就不在这里造*了，下面列出几遍大佬们写的文章。

二、使用

nuget 安装 aspectcore 及相关组件

小白开学Asp.Net Core 《四》

　　具体结合redis来说明：

　　redis采用的是csredis

nuget csredis 及相关组件的安装

　小白开学Asp.Net Core 《四》

下面就直接贴代码了

分布式redis缓存

 public class distributedcachemanager
    {
        private static idistributedcache instance => aspectcorecontainer.resolve<idistributedcache>();

        public static string get(string key)
        {
            if (redishelper.exists(key))
            {
                return redishelper.get(key);
            }

            return null;
        }

        public static async task<string> getasync(string key)
        {
            if (await redishelper.existsasync(key))
            {
                var content = await redishelper.getasync(key);
                return content;
            }

            return null;
        }

        public static t get<t>(string key)
        {
            var value = get(key);
            if (!string.isnullorempty(value))
                return jsonconvertor.deserialize<t>(value);
            return default(t);
        }

        public static async task<t> getasync<t>(string key)
        {
            var value = await getasync(key);
            if (!string.isnullorempty(value))
            {
                return jsonconvertor.deserialize<t>(value);
            }

            return default(t);
        }

        public static void set(string key, object data, int expiredseconds)
        {
            redishelper.set(key, jsonconvertor.serialize(data), expiredseconds);
        }

        public static async task<bool> setasync(string key, object data, int expiredseconds)
        {
            return await redishelper.setasync(key, jsonconvertor.serialize(data), expiredseconds);
        }


        public static void remove(string key) => instance.remove(key);

        public static async task removeasync(string key) => await instance.removeasync(key);

        public static void refresh(string key) => instance.refresh(key);

        public static async task refreshasync(string key) => await instance.refreshasync(key);

        public static void clear()
        {
            throw new notimplementedexception();
        }
    }

aspectcore framwork 动态代理redis

    [attributeusage(attributetargets.method)]
    public class rediscacheattribute : abstractinterceptorattribute
    {       
        public int expiration { get; set; } = 10 * 60;

        public string cachekey { get; set; } = null;

        public override async task invoke(aspectcontext context, aspectdelegate next)
        {
            var parameters = context.servicemethod.getparameters();
            if (parameters.any(it => it.isin || it.isout))
                await next(context);
            else
            {
                var key = string.isnullorempty(cachekey)
                    ? new cachekey(context.servicemethod, parameters, context.parameters).getrediscachekey()
                    : cachekey;
                var value = await distributedcachemanager.getasync(key);
                if (value != null)
                {
                    if (context.servicemethod.isreturntask())
                    {
                        dynamic result = jsonconvert.deserializeobject(value,
                            context.servicemethod.returntype.generictypearguments[0]);
                        context.returnvalue = task.fromresult(result);
                    }
                    else
                        context.returnvalue = jsonconvert.deserializeobject(value, context.servicemethod.returntype);
                }
                else
                {
                    await context.invoke(next);
                    dynamic returnvalue = context.returnvalue;
                    if (context.servicemethod.isreturntask())
                        returnvalue = returnvalue.result;
                    await distributedcachemanager.setasync(key, returnvalue, expiration);
                }
            }
        }
    }

csredis 服务注册

public static iservicecollection usecsredisclient(this iservicecollection services, params string[] redisconnectionstrings)
        {
            if (services == null) throw new argumentnullexception(nameof(services));
            if (redisconnectionstrings == null || redisconnectionstrings.length == 0)
                throw new argumentnullexception(nameof(redisconnectionstrings));
            csredisclient redisclient;
            if (redisconnectionstrings.length == 1)
                //单机模式
                redisclient = new csredisclient(redisconnectionstrings[0]);
            else
                //集群模式
                redisclient = new csredisclient(noderule: null, connectionstrings: redisconnectionstrings);
            //初始化 redishelper
            redishelper.initialization(redisclient);
            //注册mvc分布式缓存
            services.addsingleton<idistributedcache>(new microsoft.extensions.caching.redis.csrediscache(redishelper.instance));
            return services;
        }

.net core startup.cs 中注册服务

   var redisconnectionstring = configuration.getconnectionstring("redis");
            //启用redis
            services.usecsredisclient(redisconnectionstring);

 return aspectcorecontainer.buildserviceprovider(services);//接入aspectcore.injector