SpringContext中的循环任务优化,添加业务监控

admin

2020-07-29 c338aa60df58bee9f4c25afedf94fe6930a119c1

 fanli/src/main/java/com/yeshi/fanli/aspect/RequestSerializableServiceAspect.java

@@ -4,6 +4,7 @@


import javax.annotation.Resource;



import com.yeshi.fanli.util.RedisManager;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.Signature;

import org.aspectj.lang.annotation.Around;

@@ -17,7 +18,6 @@
import org.springframework.expression.spel.support.StandardEvaluationContext;

import org.springframework.stereotype.Component;



import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;

@@ -31,7 +31,7 @@
public class RequestSerializableServiceAspect {



   @Resource

   private JedisPool jedisPool;

   private RedisManager redisManager;



   private ExpressionParser parser = new SpelExpressionParser();



@@ -68,7 +68,7 @@
                        + cacheKey;

                  cacheKey = "service-" + StringUtil.Md5(cacheKey);

                  // jiedis原子性做拦截

                  Jedis jedis = jedisPool.getResource();

                  Jedis jedis = redisManager.getJedis();

                  try {

                     Constant.waitingThreadSet.add(Thread.currentThread().getId());

                     String result = null;

@@ -92,9 +92,6 @@
                     if (!StringUtil.isNullOrEmpty(result)) {

                        try {

                           return joinPoint.proceed();

                        } catch (Throwable e) {

                           e.printStackTrace();

                           LogHelper.errorDetailInfo(e);

                        } finally {

                           jedis.del(cacheKey);

                           Constant.waitingThreadSet.remove(Thread.currentThread().getId());

@@ -105,12 +102,7 @@
                  }

               }

            } catch (Exception e) {// 原子性保护出错

               try {

                  return joinPoint.proceed();

               } catch (Throwable e1) {

                  e.printStackTrace();

                  LogHelper.errorDetailInfo(e1);

               }

            }

         }

      } catch (NoSuchMethodException e) {