基于微软企业库的AOP组件(含源码)

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 软件开发,离不开对日志的操作。日志可以帮助我们查找和检测问题,比较传统的日志是在方法执行前或后,手动调用日志代码保存。但自从AOP出现后,我们就可以避免这种繁琐但又必须要实现的方式。本文是在微软企业库的AOP基础上封装出的组件。

软件开发,离不开对日志的操作。日志可以帮助我们查找和检测问题,比较传统的日志是在方法执行前或后,手动调用日志代码保存。但自从AOP出现后,我们就可以避免这种繁琐但又必须要实现的方式。本文是在微软企业库的AOP基础上封装出的组件。注意:是使用2.0版本,因为2.0以上版本是基于Net4.5类库的。好了,废话不多说。如图-1所示

1.项目布局.png

图-1

说明

    logmethodBillModel文件,是记录AOP详细信息

    IBasicCodeService和BasicCodeService是用于测试的接口和实现类

    AopUtil是实现Aop的类,核心代码

 

继续分析代码。

  步骤1,先创建2个特性,用于标记在类和方法上,表示这个类中这个方法需要被Aop记录

    /// <summary>
    /// 贴在接口上
    /// </summary>
    public class NSAopHandlerAttribute : HandlerAttribute
    {
        public override ICallHandler CreateHandler(Microsoft.Practices.Unity.IUnityContainer container)
        {
            return new NSAopCallHandler();
        }
    }
 

    /// <summary>
    /// 贴在方法上,作用:用于开启AOP功能
    /// 开启AOP日志保存
    /// </summary>
    public class NSAopMethodToMethodHandlerAttribute : System.Attribute
    {
    }

  

  步骤2,继承ICallHandler接口实现Aop功能

    public class NSAopCallHandler : ICallHandler
    {        
        public int Order { get; set; }

        public IMethodReturn Invoke(IMethodInvocation input, GetNextHandlerDelegate getNext)
        {
            //增加其他日志类型,处理方案如下
            //无论是否需记录log_method方法,方法均先执行完成.同时,记录时执行时间

            MethodBase mbCurrent = input.MethodBase;
            string methodName = input.MethodBase.Name;
            string fullName = input.Target.ToString() + "." + methodName; 
            
            //1,方法执行,并记录开始和结束执行时间
            DateTime dtmBegin = DateTime.Now;
            var methodReturn = getNext()(input, getNext);
            DateTime dtmEnd = DateTime.Now;

            TimeSpan ts = dtmEnd - dtmBegin;
            decimal invokeMilliSecond = Convert.ToDecimal(ts.TotalMilliseconds);              

            //6,判断是否需保存Aop日志
            object attriToMethod  = AttributeHelper.GetCustomAttribute(mbCurrent, "NSAopMethodToMethodHandlerAttribute");
            if (attriToMethod != null    )
            {
                string declaringType = input.MethodBase.ToString();
                string instanceName = input.MethodBase.Module.Name;

                //获取参数列表
                Dictionary<string, string> dicParamInfo = new Dictionary<string, string>();
                for (var i = 0; i < input.Arguments.Count; i++)
                {
                    string piName = input.Arguments.ParameterName(i);
                    string piValue = input.Arguments[i] as string;
                    dicParamInfo.Add(piName, piValue);
                }

                //获取方法的层级关系
                //参考地址:http://www.cnblogs.com/mumuliang/p/3939143.html
                string parentFullName = null;
                string parentDeclaringType = null;
                System.Diagnostics.StackTrace st = new System.Diagnostics.StackTrace();
                System.Diagnostics.StackFrame[] sfs = st.GetFrames();
                for (int u = 0; u < sfs.Length; ++u)
                {
                    System.Reflection.MethodBase mb = sfs[u].GetMethod();

                    //数据如下所示                
                    //[CALL STACK][12]: ExampleAOP.AOPProxy.BasicCodeService.DoSomething1
                    //[CALL STACK][13]: ExampleAOP.AOPProxy.AOPProxyTest.Output
                    //[CALL STACK][14]: ExampleAOP.Program.Main
                    string parentInfo = string.Format("[CALL STACK][{0}]: {1}.{2}", u, mb.DeclaringType.FullName, mb.Name);

                    //判断是否包含本方法.若包含,则获取其下一级的数据即可
                    string source = mb.Name;
                    if (source == methodName)
                    {
                        if (u + 1 < sfs.Length)
                        {
                            System.Reflection.MethodBase mbParent = sfs[u + 1].GetMethod();

                            parentFullName = mbParent.DeclaringType.FullName + "." + mbParent.Name;
                            parentDeclaringType = mbParent.ToString();
                        }

                        break;
                    }
                }

                //记录至全局静态变量
                logmethodBillModel modelLog = new logmethodBillModel()
                {
                    MethodName = methodName,
                    FullName = fullName,
                    DeclaringType = declaringType,
                    ParentFullName = parentFullName,
                    ParentDeclaringType = parentDeclaringType,
                    ParamInfo = dicParamInfo,
                    InvokeBeginTime = dtmBegin,
                    InvokeEndTime = dtmEnd,
                    InvokeMilliSecond = invokeMilliSecond,
                    InstanceName = instanceName,
                };
                BaseService.LogMethods.Add(modelLog);
            }

            return methodReturn;
        }
    }

  

  步骤3,就是对接口的使用,当然这里用的是IOC。如下代码所示

        /// <summary>
        /// 创建Service服务类,基于微软企业库
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public static T CreateService<T>() where T : class
        {
            IUnityContainer container = new UnityContainer().AddNewExtension<Interception>();
            container.RegisterType<IBasicCodeService, BasicCodeService>();

            container.Configure<Interception>().SetInterceptorFor<T>(new InterfaceInterceptor());

            T t = container.Resolve<T>();
            return t;
        }

  

好了,搞定收工。看看调用的代码。so easy

    class Program
    {
        static void Main(string[] args)
        {
            IBasicCodeService baService = BaseService.CreateService<IBasicCodeService>();
            string userName = baService.SingleUserCode("user1");
            List<string> listUserCode = baService.GetListUserCode("code1", "name1");

            System.Console.WriteLine("生成日志个数:" + BaseService.LogMethods.Count);

            System.Console.ReadKey();
        }
    }

  

这里有一点要说明下,就是接口中有方法1(需记录Aop);方法2(不需记录)。这种情况下,若方法2引用方法1时,也想生成Aop的话,需这样调用,直接使用this是不行的

        public string SingleUserCode(string userCode)
        {
            IBasicCodeService baService = BaseService.CreateService<IBasicCodeService>();
            var listUserCode = baService.GetListUserCode(userCode, "name1");

            return listUserCode[0];
        }

        public List<string> GetListUserCode(string userCode, string userName)
        {
            return new List<string>() { "UserCode1", "UserCode2" };
        }

  

介绍AOP比较全面的博客

C#进阶系列——AOP?AOP!

 

 源码下载方式
1,关注微信公众号:小特工作室(也可直接扫描签名处二维码)
2,发送:示例4008
即可下载 
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
7月前
|
Java 数据库连接 应用服务中间件
Spring5源码(39)-Aop事物管理简介及编程式事物实现
Spring5源码(39)-Aop事物管理简介及编程式事物实现
55 0
|
4月前
|
Java Spring
Spring的AOP组件详解
该文章主要介绍了Spring AOP(面向切面编程)组件的实现原理,包括Spring AOP的基础概念、动态代理模式、AOP组件的实现以及Spring选择JDK动态代理或CGLIB动态代理的依据。
Spring的AOP组件详解
|
6月前
|
监控 Java Spring
自定义注解+AOP切面日志+源码
自定义注解+AOP切面日志+源码
50 1
|
6月前
|
Java Spring
【JavaEE进阶】 Spring AOP源码简单剖析
【JavaEE进阶】 Spring AOP源码简单剖析
|
7月前
|
Java Spring
【Spring源码】Spring中的AOP底层原理分析
【Spring源码】Spring中的AOP底层原理分析
|
7月前
Spring5源码(31)-基于@AspectJ的AOP
Spring5源码(31)-基于@AspectJ的AOP
59 0
|
7月前
|
Java Spring
Spring5源码(30)-基于Schema的AOP
Spring5源码(30)-基于Schema的AOP
43 0
|
7月前
|
Java Spring
Spring5源码(28)-Aop知识点回顾以及基于Advice接口的增强实现
Spring5源码(28)-Aop知识点回顾以及基于Advice接口的增强实现
52 0
|
XML 开发框架 Java
《Spring6核心源码解析》已完结,涵盖IOC容器、AOP切面、AOT预编译、SpringMVC,面试杠杠的!
全网首个全面解析Spring6核心源码的专栏,涵盖:IOC容器、AOP切面、声明式事务、AOT预编译和SpringMVC,让你从根本上彻底掌握Spring6核心技术。
535 1
《Spring6核心源码解析》已完结,涵盖IOC容器、AOP切面、AOT预编译、SpringMVC,面试杠杠的!
|
Java Spring
深入理解Spring源码之剖析AOP(注解配置方式)(二)
深入理解Spring源码之剖析AOP(注解配置方式)
90 0