zoukankan      html  css  js  c++  java
  • 读写切换切面

    #taskUser读
    taskuser.read=0
    #taskUser写
    taskuser.write=1
    #taskUserData读
    taskuserdata.read=1
    #taskUserData写
    taskuserdata.write=1
    @Aspect
    @Component
    public class TaskUserDaoMapperAspect {
        private static final Logger logger = LoggerFactory.getLogger(TaskUserDaoMapperAspect.class);
        private static final List<String> readList = Lists.newArrayList("find", "poll");
        private static final List<String> writeList = Lists.newArrayList("insert", "update");
    
        @Resource
        private TaskUserDataMapper taskUserDataMapper;
    
        @Resource
        private ConfigService configService;
    
        @Around("execution(* cn.hello.dal.mapper.TaskUserMapper.*(..))")
        public Object around(ProceedingJoinPoint pjp) {
            Object result = null;
            try {
                String methodName = pjp.getSignature().getName();
                logger.info("TaskUserMapper {} {} invoked", methodName, pjp.getArgs());
                if(readList.contains(methodName)){
                    if(configService.isReadTaskUser()){
                        result = pjp.proceed();
                    } else if(configService.isReadTaskUserData()){
                        result = invokeTaskUserDaoMapper(pjp);
                    }
                } else if(writeList.contains(methodName)){
    
                    if(configService.isWriteTaskUser()){
                        result = pjp.proceed();
                    }
                    if(configService.isWriteTaskUserData()){
                        result = invokeTaskUserDaoMapper(pjp);
                    }
                } else {
                    logger.error("unknown TaskUserMapper method {}", methodName);
                    result = pjp.proceed();
                }
            } catch (OctopusException e) {
                throw e;
            } catch (Throwable e) {
                logger.error("failed@AroundDaoAspect.around", e);
                throw new DalException("DAL ERROR", e);
            }
            return result;
        }
    
        private Object invokeTaskUserDaoMapper(ProceedingJoinPoint pjp) throws NoSuchMethodException, IllegalAccessException, InvocationTargetException {
            String methodName = pjp.getSignature().getName();
            Class[] parameterTypes = ((MethodSignature)pjp.getSignature()).getMethod().getParameterTypes();
            Method method = TaskUserDataMapper.class.getMethod(methodName, parameterTypes);
            Object result = method.invoke(taskUserDataMapper, pjp.getArgs());
            return result;
        }
    }
  • 相关阅读:
    nginx安装
    win7 mount到Linux下无法分配内存的问题(Cannot allocate memory)
    [转]linux时间同步
    关于文件缓冲的问题
    【转】VNC配置
    yum代理设置
    mysql开启日志
    [译]rabbitmq 2.5 Where’s my message? Durability and you
    [译]rabbitmq 2.4 Multiple tenants: virtual hosts and separation
    [译]rabbitmq 2.2 Building from the bottom: queues
  • 原文地址:https://www.cnblogs.com/exmyth/p/10811474.html
Copyright © 2011-2022 走看看