转载

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题。近日工作中，要实现一个功能，那就是业务层方法里面实现自动缓存。编写业务的C#开发人员只关注如何将业务代码编写正确就可以了，而缓存的代码，大多类似，无非就是判断是否有缓存，有就取出返回，没有就调用数据库代码获取数据再缓存起来而已，于是这部分代码通过使用AOP的方式自动接管掉这种重复性代码。

MrAdvice开源项目github地址： https://github.com/ArxOne/MrAdvice

直接引用MrAdvice.dll文件不能实现AOP拦截功能

1月份的时候写过一篇 使用AOP组件重构老旧 ado.net 代码，统一管理多表操作的事务 的文章，在测试程序中使用的是MrAdvice这个开源组件，对它熟悉，就又使用它了。只不过这次使用有点特殊，以前开发是可以联网的，可以很方便的使用nuget将其安装到本地，而这次是因项目原因内外网隔离，且是断网开发的，就只能在外网写个测试程序，然后将MrAdvice.dll文件复制到内网电脑，内网电脑通过引用dll的方式来使用该组件，结果是不会进入到拦截方法的。

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题 直接引用MrAdvice.dll

通过下图可以看到，成功解决后，可以实现自动缓存了。

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题 实现AOP拦截 

下面是全部的演示程序源码。

演示程序解决方案目录一览

该项目是一个控制台项目，解决方案如下图所示：

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题 演示程序解决.

MrAdvice.dll是直接引用的，不是通过nuget安装的，至于这个dll文件的获取，你可以通过nuget获取了找到它即可。

演示程序的源码

控制台入口的代码比较简单，单纯的调用接口。

程序入口代码

class Program
    {
        static void Main(string[] args)
        {
            Console.Title = "jhrs.com AOP演示程序，通过直接引用MrAdvice.dll编写的代码！";
            DateTime dtNow = DateTime.Now;
            IJhrscom api = new Jhrscom();
            var result = api.GetResult("这是a参数", dtNow, 12342);
            Console.WriteLine();
            Console.WriteLine($"第1次调用时返回结果是："+result.ToJson());
            Console.WriteLine();
            result = api.GetResult("这是a参数", dtNow, 12342);
            Console.WriteLine();
            Console.WriteLine($"第2次调用时返回结果是来自第1次缓存数据，只不过被改了下：" + result.ToJson());
            Console.WriteLine();
            //api.GetPatient(Guid.NewGuid(), result);
        }
    }

程序接口代码

程序接口代码主要是模拟业务方法里面的一些类，定义了一个接口，一个实现类，另外实现类上面是标注了一个自动缓存的特性（AutoCache），该特性的实现代码即为下面所述的核心的AOP拦截代码，具体下面会给出的；另外还有一个输出结果（响应消息）的类。整个源码是放到一个文件里面的，如下所示：

public interface IJhrscom
    {
        ResponseResult GetResult(string a, DateTime dateTime, int id);

        ResponseResult GetPatient(Guid id, ResponseResult t);
    }

    public class Jhrscom : IJhrscom
    {
        [AutoCache(10)]
        public ResponseResult GetPatient(Guid id, ResponseResult t)
        {
            string key = GetKey(new object[] { id, t });
            ResponseResult result = new ResponseResult() { Code = 4444, Message = "第2个方法" };
            return result;
        }

        [AutoCache(cacheMinutes: 12, enableSliding: true)]
        public ResponseResult GetResult(string a, DateTime dateTime, int id)
        {
            ResponseResult result = new ResponseResult() { Code = 1122, Message = "缓存测试消息" };
            string key = GetKey(new object[] { a, dateTime, id });
            return result;
        }

        /// <summary>
        /// 缓存key
        /// </summary>
        /// <param name="pars"></param>
        /// <returns></returns>
        private string GetKey(params object[] pars)
        {
            var method = new StackFrame(1).GetMethod();
            var array = method.GetParameters();
            var key = array.Select(x => { return pars[x.Position].ToJson(); }).ToArray();

            var cacheKey = $"{method.DeclaringType.ToString()}|{method.Name.Replace("′", "")}|{string.Join("_", array.Select(x => x.Name))}|{string.Join("_", key)}".GetMd5();
            Console.WriteLine($"【{method.Name.Replace("′", "")}】实现类里面的缓存Key：" + cacheKey);
            return cacheKey;
        }
    }

    /// <summary>
    /// 输出结果
    /// </summary>
    public class ResponseResult
    {
        public int Code { get; set; }
        public string Message { get; set; }

        //.....其它属性
    }

核心的AOP拦截代码

该代码是用于实现自动缓存功能，思路就是在调用业务方法前，根据缓存key，缓存key按一定规则生成，保证唯一就可以了，具体源码中有说明，从缓存里面取出数据，如果存在缓存就直接返回给调用者即可，并终止业务方法的执行（体现在不调用context.Proceed()方法上）；如果不存在缓存数据或者缓存过期了，则调用业务方法获取数据后并缓存就可以了。

/// <summary>
    /// 用AOP来实现自动缓存
    /// </summary>
    public class AutoCacheAttribute : Attribute, IMethodAdvice
    {
        /// <summary>
        /// 滑动过期
        /// </summary>
        public bool EnableSliding { get; set; }

        /// <summary>
        /// 缓存时间，分钟
        /// </summary>
        public int CacheMinutes { get; set; }

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="cacheMinutes">缓存时间，分钟，默认5分钟，小于等于0永久缓存</param>
        /// <param name="enableSliding">使用滑动过期缓存控制策略</param>
        public AutoCacheAttribute(int cacheMinutes = 5, bool enableSliding = false)
        {
            EnableSliding = enableSliding;
            CacheMinutes = cacheMinutes;
        }

        /// <summary>
        /// AOP组件拦截方法，用于实现自动缓存，有缓存时直接返回；
        /// 没有缓存时，调用被拦截方法后，有返回值则将数据自动缓存起来
        /// </summary>
        /// <param name="context"></param>
        public void Advise(MethodAdviceContext context)
        {
            var key = GetKey(context);
            if (context.HasReturnValue && key.TryGetCache(out object m))
            {
                var r = m as ResponseResult;
                r.Message = "在拦截方法里面改了缓存里面取出来的数据！";

                context.ReturnValue = r;
                //context.ReturnValue = m;  

                //context.Proceed();  //直接取出缓存返回，不用执行原来取数据方法。
            }
            else
            {
                context.Proceed();//执行被拦截的方法
                if (context.HasReturnValue && context.ReturnValue != null)
                {
                    //被拦截方法有返回值，并且返回值不为null
                    if (EnableSliding && CacheMinutes > 0)
                        context.ReturnValue.SetCache(key, TimeSpan.FromMinutes(CacheMinutes));
                    else if (CacheMinutes > 0)
                        context.ReturnValue.SetCache(key, DateTime.Now.AddMinutes(CacheMinutes));
                    else
                        context.ReturnValue.SetCache(key);
                }
            }
        }

        /// <summary>
        /// 获取缓存key，key的规则为： md5(类全名｜方法名｜参数列表拆分数组｜参数值的json数组)，这样可以保证唯一
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        private string GetKey(MethodAdviceContext context)
        {
            var array = context.TargetMethod.GetParameters();
            var key = array.Select(x => { return context.Arguments[x.Position].ToJson(); }).ToArray();

            var cacheKey = $"{context.Target.ToString()}|{context.TargetName}|{string.Join("_", array.Select(x => x.Name))}|{string.Join("_", key)}".GetMd5();
            return cacheKey;
        }
    }

    /// <summary>
    /// 缓存扩展方法，可使用其它缓存替代
    /// </summary>
    public static class CacheExtensions
    {
        private static MemoryCache cache = new MemoryCache("https://jhrs.com");

        /// <summary>
        /// 设置缓存，一直不过期
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="value"></param>
        /// <param name="key"></param>
        public static void SetCache<T>(this T value, string key)
        {
            if (string.IsNullOrWhiteSpace(key)) throw new ArgumentException($"缓存键参数{nameof(key)}不能为null或空");
            if (value == null) throw new ArgumentException($"缓存值参数{nameof(value)}不能为null");
            CacheItemPolicy policy = new CacheItemPolicy();
            cache.Set(key, value, policy);
        }

        /// <summary>
        /// 设置缓存，固定过期时间
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="value"></param>
        /// <param name="key"></param>
        /// <param name="absoluteExpiration"></param>
        public static void SetCache<T>(this T value, string key, DateTimeOffset? absoluteExpiration)
        {
            if (string.IsNullOrWhiteSpace(key)) throw new ArgumentException($"缓存键参数{nameof(key)}不能为null或空");
            if (value == null) throw new ArgumentException($"缓存值参数{nameof(value)}不能为null");
            CacheItemPolicy policy = new CacheItemPolicy() { AbsoluteExpiration = (DateTimeOffset)absoluteExpiration };
            cache.Set(key, value, policy);
        }

        /// <summary>
        /// 设置缓存，滑动过期
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="value"></param>
        /// <param name="key"></param>
        /// <param name="slidingExpiration"></param>
        public static void SetCache<T>(this T value, string key, TimeSpan? slidingExpiration)
        {
            if (string.IsNullOrWhiteSpace(key)) throw new ArgumentException($"缓存键参数{nameof(key)}不能为null或空");
            if (value == null) throw new ArgumentException($"缓存值参数{nameof(value)}不能为null");
            CacheItemPolicy policy = new CacheItemPolicy() { SlidingExpiration = (TimeSpan)slidingExpiration };
            cache.Set(key, value, policy);
        }

        /// <summary>
        /// 获取缓存数据
        /// </summary>
        /// <typeparam name="T">对象类型</typeparam>
        /// <param name="key"><缓存key/param>
        /// <param name="value">返回的缓存数据对名</param>
        /// <returns></returns>
        public static bool TryGetCache<T>(this string key, out T value)
        {
            value = default(T);
            if (cache.Contains(key))
            {
                value = (T)cache.Get(key);
                return true;
            }
            return false;
        }

        /// <summary>
        /// 获取字符串MD5值
        /// </summary>
        /// <param name="value"></param>
        /// <returns></returns>
        public static string GetMd5(this string value)
        {
            byte[] bytes = Encoding.UTF8.GetBytes(value);

            StringBuilder sb = new StringBuilder();
            MD5 hash = new MD5CryptoServiceProvider();
            bytes = hash.ComputeHash(bytes);
            foreach (byte b in bytes)
            {
                sb.AppendFormat("{0:x2}", b);
            }
            return sb.ToString();
        }
    }

附加的JSON扩展类

该扩展类只是方便将对象转为JSON而已，代码不复如，如下所示：

public static class JsonExtensions
    {
        /// <summary>
        /// 将对象转换为JSON字符串
        /// </summary>
        /// <param name="obj">要转换的对象</param>
        /// <param name="camelCase">是否小写名称</param>
        /// <param name="indented"></param>
        /// <returns></returns>
        public static string ToJson(this object obj, bool camelCase = false, bool indented = false)
        {
            JsonSerializerSettings settings = new JsonSerializerSettings();
            if (camelCase)
            {
                settings.ContractResolver = new CamelCasePropertyNamesContractResolver();
            }
            if (indented)
            {
                settings.Formatting = Formatting.Indented;
            }
            return JsonConvert.SerializeObject(obj, settings);
        }

        /// <summary>
        /// 把Json字符串转换为强类型对象
        /// </summary>
        public static T FromJson<T>(string json)
        {
            if (string.IsNullOrWhiteSpace(json)) return default(T);
            json = JsonDateTimeFormat(json);
            return JsonConvert.DeserializeObject<T>(json);
        }

        /// <summary>
        /// 处理Json的时间格式为正常格式
        /// </summary>
        private static string JsonDateTimeFormat(string json)
        {
            json = Regex.Replace(json,
                @"///Date/((/d+)/)///",
                match =>
                {
                    DateTime dt = new DateTime(1970, 1, 1);
                    dt = dt.AddMilliseconds(long.Parse(match.Groups[1].Value));
                    dt = dt.ToLocalTime();
                    return dt.ToString("yyyy-MM-dd HH:mm:ss.fff");
                });
            return json;
        }
    }

解决直接引用MrAdvice.dll不能拦截的问题

出现这个问题的根源是，MrAdvice这个组件是在编译时会给你的项目源码编织一些AOP拦截代码，熟悉PostSharp的应该对此了解，这也是在MrAdvice项目地址的issues处得到解答，地址是： https://github.com/ArxOne/MrAdvice/issues/140

所以我们需要在项目文件csproj里面添加一些配置，并且把MrAdvice的目录复制到断网开发项目的packages目录。通过完成这两个步骤就可以解决了。

You’ve missed the point: Mr Advice is a post-build weaver, which changes the assembly at build-time after the csc compiler has generated it. To achieve this, is inserts a task in the csproj. So if you want to do the same manually, you need to also add the build task in your csproj. If you have a VS2017 solution with a project working, you’ll only need to copy the lines that were added to the csproj into your own project.

解决步骤

  • 联网新建一个项目，通过nuget安装MrAdvice，然后在解决方案的packages目录里面将nuget下载的MrAdvice目录包，复制到你断网环境的解决方案的packages目录，如下图所示：

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题 MrAdvice 目录

  • 修改项目文件，即修改csproj文件，csproj文件可以使用记事本或者其它软件打开，增加以下节点，如下图所示：

直接引用MrAdvice.dll文件不能实现AOP拦截，教你1分钟解决这个问题 csproj文件

配置节点为如下：

<Import Project="../packages/MrAdvice.2.8.8/build/MrAdvice.targets" Condition="Exists('../packages/MrAdvice.2.8.8/build/MrAdvice.targets')" />
  <Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
    <PropertyGroup>
      <ErrorText>这台计算机上缺少此项目引用的 NuGet 程序包。使用“NuGet 程序包还原”可下载这些程序包。有关更多信息，请参见 http://go.microsoft.com/fwlink/?LinkID=322105。缺少的文件是 {0}。</ErrorText>
    </PropertyGroup>
    <Error Condition="!Exists('../packages/MrAdvice.2.8.8/build/MrAdvice.targets')" Text="$([System.String]::Format('$(ErrorText)', '../packages/MrAdvice.2.8.8/build/MrAdvice.targets'))" />
  </Target>

好了，通过以上步骤就可以在断网环境里面愉快的使用MrAdvice这个AOP拦截组件来省点体力劳动了。

源码可以在首发地址下载，本文首发于：

https://jhrs.com/2019/33367.html

原文  http://www.cnblogs.com/jessory/p/11888630.html
正文到此结束
所属分类： Java 编程技术

热门推荐

相关文章

阿里云首购8折
说给你听

本文目录
随机标签
书籍教程
springboot-demo Java入门教程 bootstrap3 CSS Apache基础教程 php ionic 教程 Python mysql教程 eclipse Ubuntu VPS系统配置 AngularJS 教程 MongoDB教程 Struts2教程 Redis教程 Spring教程 Git教程 Jenkins进阶系列 openfire参考指南 Java设计模式 HBase教程 Maven教程 hibernate教程 Docker 教程 memcached教程 Quartz指南 Hive教程 Ant教程 ANTLR教程 SpringCloud java实例教程 springcloud-demo XStream教程 Hazelcast教程 Elastic-Job-Lite 深入浅出MyBatis SVN教程 ibaties教程 rabittmq教程 solr教程 Hadoop教程 WebService CXF学习 JPA教程 ActiveMQ中文指南 java-demo Java内存模型 dubbo教程 python3-demo Linux入门视频教程
近期评论
  1. 1 Spring Cloud Consul实现选举机制
  2. 2 Spring Boot集成ShedLock实现分布式定时任务
  3. 3 利用oss进行数据库和网站图片备份
  4. 4 Spring Cloud Stream实现数据流处理
  5. 5 Python3访问MySQL数据库快速入门Demo
  6. 6 Github开源项目作者可以免费申请 JetBrains 全家桶
  7. 7 Spring Cloud Vault快速入门Demo
  8. 8 Spring Cloud Gateway快速入门Demo
  9. 9 Spring Cloud Contract快速入门Demo
  10. 10 Spring Cloud Consul快速入门Demo
网站信息
  • 文章总数：82,714 篇
  • 文件总数：284,287 个
  • 标签总数：2,393 个
  • 分类总数：85 个
  • 留言数量：2,560 条
  • 在线人数：613 人
  • 运行天数：4,409天
  • 最后更新：2024年11月22日01点
Loading...

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[HBLOG]公众号 HBLOG HBLOG