美文网首页
jfinal aop全局拦截器设置切点

jfinal aop全局拦截器设置切点

作者: 南京确善能 | 来源:发表于2018-06-13 10:46 被阅读0次

    jfianl 的aop分为全局和基于注解两种,spring的aop很复杂,但是spring的aop可以自定义切点,这一点还是相对来说灵活一些,jfinal一般来说定义一个拦截的范围的话在interceptor中设置就可以了,但是明显是下策,最好的方式就是在加载拦截器的时候设置切点,jfinal的aop懒的分析了,直接上代码了。

    1.配置文件

    #globalInterceptorPackage 这里设置切点
    globalInterceptorPackage =com.xxx.xxx
    

    2.InterceptorManager.java 直接将下面代码放入工程

    package com.jfinal.aop;
    
    import java.lang.reflect.Method;
    import java.util.ArrayList;
    import java.util.Iterator;
    import java.util.concurrent.ConcurrentHashMap;
    import com.jfinal.core.Controller;
    import com.jfinal.kit.PathKit;
    import com.jfinal.kit.PropKit;
    
    /**
     * InterceptorManager.
     * 1:管理控制层、业务层全局拦截器
     * 2:缓存业务层 Class 级拦截器数组。在业务层仅有 injectInters、methodInters 数组未被整体缓存
     * 3:用于创建 Interceptor、组装 Interceptor
     * 4:除手动 new 出来的 inject 拦截器以外,其它所有拦截器均为单例
     * 5:重点关注于业务层拦截器组装性能, 控制层所有拦截器已被整体缓存
     * 
     * 无法使用 Method 或 Before 对象缓存业务层 Method 级拦截器:
     * 1:不同对象或相同对象获取同一个 Class 中同一个 Method 得到的对象 id 值不相同
     * 2:不同对象获取同一个 method 之上的 Before 得到的对象 id 值不相同
     */
    public class InterceptorManager {
        
        public static final Interceptor[] NULL_INTERS = new Interceptor[0];
        
        // 控制层与业务层全局拦截器
        private Interceptor[] globalActionInters = NULL_INTERS;
        private Interceptor[] globalServiceInters = NULL_INTERS;
        
        // 单例拦截器
        private final ConcurrentHashMap<Class<? extends Interceptor>, Interceptor> singletonMap = new ConcurrentHashMap<Class<? extends Interceptor>, Interceptor>();
        
        // 业务层 Class 级别拦截器缓存
        private final ConcurrentHashMap<Class<?>, Interceptor[]> serviceClassInters = new ConcurrentHashMap<Class<?>, Interceptor[]>();
        
        private static final InterceptorManager me = new InterceptorManager();
        
        private InterceptorManager() {}
        
        public static InterceptorManager me() {
            return me;
        }
        
        // 此处不缓存控制层 Class 级拦截器,已经在 com.jfinal.core.Action 对象中缓存
        public Interceptor[] createControllerInterceptor(Class<? extends Controller> controllerClass) {
            return createInterceptor(controllerClass.getAnnotation(Before.class));
        }
        
        // 缓存业务层 Class 级拦截器
        public Interceptor[] createServiceInterceptor(Class<?> serviceClass) {
            Interceptor[] result = serviceClassInters.get(serviceClass);
            if (result == null) {
                result = createInterceptor(serviceClass.getAnnotation(Before.class));
                serviceClassInters.put(serviceClass, result);
            }
            return result;
        }
        
        public Interceptor[] buildControllerActionInterceptor(Interceptor[] injectInters, Interceptor[] classInters, Class<? extends Controller> controllerClass, Method method) {
            return doBuild(globalActionInters, injectInters, classInters, controllerClass, method);
        }
        
        public Interceptor[] buildServiceMethodInterceptor(Interceptor[] injectInters, Class<?> serviceClass, Method method) {
            return doBuild(globalServiceInters, injectInters, createServiceInterceptor(serviceClass), serviceClass, method);
        }
        
        private Interceptor[] doBuild(Interceptor[] globalInters, Interceptor[] injectInters, Interceptor[] classInters, Class<?> targetClass, Method method) {
            Interceptor[] methodInters = createInterceptor(method.getAnnotation(Before.class));     
            Class<? extends Interceptor>[] clearIntersOnMethod;
            Clear clearOnMethod = method.getAnnotation(Clear.class);
            if (clearOnMethod != null) {
                clearIntersOnMethod = clearOnMethod.value();
                if (clearIntersOnMethod.length == 0) {  // method 级 @Clear 且不带参
                    return methodInters;
                }
            } else {
                clearIntersOnMethod = null;
            }
            
            Class<? extends Interceptor>[] clearIntersOnClass;
            Clear clearOnClass = targetClass.getAnnotation(Clear.class);
            if (clearOnClass != null) {
                clearIntersOnClass = clearOnClass.value();
                if (clearIntersOnClass.length == 0) {   // class 级 @clear 且不带参
                    globalInters = NULL_INTERS;
                    injectInters = NULL_INTERS;
                }
            } else {
                clearIntersOnClass = null;
            }
            
            ArrayList<Interceptor> result = new ArrayList<Interceptor>(globalInters.length + injectInters.length + classInters.length + methodInters.length);
            for (Interceptor inter : globalInters) {
                if(targetClass.getName().contains(PropKit.get("globalInterceptorPackage"))){ //定义切点
                    result.add(inter);
                }   
            }
            for (Interceptor inter : injectInters) {
                result.add(inter);
            }
            if (clearIntersOnClass != null && clearIntersOnClass.length > 0) {
                removeInterceptor(result, clearIntersOnClass);
            }
            for (Interceptor inter : classInters) {
                result.add(inter);
            }
            if (clearIntersOnMethod != null && clearIntersOnMethod.length > 0) {
                removeInterceptor(result, clearIntersOnMethod);
            }
            for (Interceptor inter : methodInters) {
                result.add(inter);
            }
            return result.toArray(new Interceptor[result.size()]);
        }
        
        private void removeInterceptor(ArrayList<Interceptor> target, Class<? extends Interceptor>[] clearInters) {
            for (Iterator<Interceptor> it = target.iterator(); it.hasNext();) {
                Interceptor curInter = it.next();
                if (curInter != null) {
                    Class<? extends Interceptor> curInterClass = curInter.getClass();
                    for (Class<? extends Interceptor> ci : clearInters) {
                        if (curInterClass == ci) {
                            it.remove();
                            break;
                        }
                    }
                } else {
                    it.remove();
                }
            }
        }
        
        public Interceptor[] createInterceptor(Before beforeAnnotation) {
            if (beforeAnnotation == null) {
                return NULL_INTERS;
            }
            return createInterceptor(beforeAnnotation.value());
        }
        
        public Interceptor[] createInterceptor(Class<? extends Interceptor>[] interceptorClasses) {
            if (interceptorClasses == null || interceptorClasses.length == 0) {
                return NULL_INTERS;
            }
            
            Interceptor[] result = new Interceptor[interceptorClasses.length];
            try {
                for (int i=0; i<result.length; i++) {
                    result[i] = singletonMap.get(interceptorClasses[i]);
                    if (result[i] == null) {
                        result[i] = (Interceptor)interceptorClasses[i].newInstance();
                        singletonMap.put(interceptorClasses[i], result[i]);
                    }
                }
                return result;
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
        
        public void addGlobalActionInterceptor(Interceptor... inters) {
            addGlobalInterceptor(true, inters);
        }
        
        public void addGlobalServiceInterceptor(Interceptor... inters) {
            addGlobalInterceptor(false, inters);
        }
        
        private void addGlobalInterceptor(boolean forAction, Interceptor... inters) {
            if (inters == null || inters.length == 0) {
                throw new IllegalArgumentException("interceptors can not be null.");
            }
            
            for (Interceptor inter : inters) {
                if (inter == null) {
                    throw new IllegalArgumentException("interceptor can not be null.");
                }
                if (singletonMap.containsKey(inter.getClass())) {
                    throw new IllegalArgumentException("interceptor already exists, interceptor must be singlton, do not create more then one instance of the same Interceptor Class.");
                }
            }
            
            for (Interceptor inter : inters) {
                singletonMap.put(inter.getClass(), inter);
            }
            
            Interceptor[] globalInters = forAction ? globalActionInters : globalServiceInters;
            Interceptor[] temp = new Interceptor[globalInters.length + inters.length];
            System.arraycopy(globalInters, 0, temp, 0, globalInters.length);
            System.arraycopy(inters, 0, temp, globalInters.length, inters.length);
            
            if (forAction) {
                globalActionInters = temp;
            } else {
                globalServiceInters = temp;
            }
        }
    }
    
    
    
    
    

    3.测试效果

    //这里是调用切点范围内的方法
    --------------------------------------------interceptor------------------------------------------
    interceptor2:CheckCodeInterceptor
    interceptor3:com.didara.interceptor.CheckCodeInterceptor
    --------------------------------------------interceptor------------------------------------------
    interceptor2:CheckCodeInterceptor
    interceptor3:com.didara.interceptor.CheckCodeInterceptor
    action-target:com.dnn.controller.TbAdminMemberController@4316c30c
    action-args:[Ljava.lang.Object;@500f29b4
    action:com.jfinal.core.Action@32791af6
    //这里是在切点范围内的方法
    --------------------------------------------interceptor------------------------------------------
    interceptor2:GlobalInterceptor
    interceptor3:com.didara.interceptor.GlobalInterceptor
    --------------------------------------------interceptor------------------------------------------
    interceptor2:GlobalInterceptor
    interceptor3:com.didara.interceptor.GlobalInterceptor
    action-target:com.didara.controller.LoginController@4dc6a146
    action-args:[Ljava.lang.Object;@500f29b4
    action:com.jfinal.core.Action@225d14b7
    
    

    相关文章

      网友评论

          本文标题:jfinal aop全局拦截器设置切点

          本文链接:https://www.haomeiwen.com/subject/jmtjeftx.html