SpringAOP与Redis搭建缓存

public class TestDao {
    
    //查询
    public RiskNote getByApplId(Integer applId) throws Exception{
        
        Class.forName("oracle.jdbc.driver.OracleDriver");    
        Connection cOnnection= DriverManager.getConnection("jdbc:oracle:thin:@192.168.11.215:1521:MFTEST01", "datacenter", "datacenter");
        PreparedStatement statement = connection.prepareStatement("select * from  TEMP_RISK_NOTE where appl_id=?");
        
        //执行
        statement.setInt(1, applId);
        ResultSet resultSet = statement.executeQuery();
        
        RiskNote riskNote = new RiskNote();
        //解析
        while (resultSet.next()) {
            riskNote.setApplId(resultSet.getInt("APPL_ID"));
            riskNote.setAllqyorg3monNum(resultSet.getInt("ALLQYORG3MON_NUM"));
            riskNote.setLoanF6endAmt(resultSet.getDouble("LOAN_F6END_AMT"));
            riskNote.setIsHighRisk1(resultSet.getString("IS_HIGH_RISK_1"));
            riskNote.setCreateDate(resultSet.getDate("CREATE_DATE"));
            riskNote.setRisk1Detail(resultSet.getString("RISK1_DETAIL"));
            riskNote.setRisk2(resultSet.getInt("RISK2"));
            riskNote.setRisk3(resultSet.getString("RISK3"));
            riskNote.setCreditpaymonth(resultSet.getString("CREDITPAYMONTH"));
            
        }
        
        return riskNote;
    }
}

@Service
public class TestService {
    
    @Autowired
    private TestDao testDao;
    
    public Object get(Integer applId) throws Exception{
        
        RiskNote riskNote = testDao.getByApplId(applId);
        
        return riskNote;
        
    }
}

public class TestQueryRiskNote {
    
    
    @Test
    public void testQuery() throws Exception{
        ApplicationContext ac = new FileSystemXmlApplicationContext("src/main/resources/spring/applicationContext_redis.xml");
        TestService testService = (TestService) ac.getBean("testService");
        RiskNote riskNote = (RiskNote)testService.get(91193);
        System.out.println(riskNote);
    }
}

/**
 * 
 * @Description: 序列化反序列化工具
 */
public class SerializeUtil {
    /**
     * 
     * 序列化
     */
    public static byte[] serialize(Object obj){
        
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        
        try {
            //序列化
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            
            oos.writeObject(obj);
            byte[] byteArray = baos.toByteArray();
            return byteArray;
            
        } catch (IOException e) {
            e.printStackTrace();
        }    
        return null;
    }
    
    /**
     * 
     * 反序列化
     * @param bytes
     * @return
     */
    public static Object unSerialize(byte[] bytes){
        
        ByteArrayInputStream bais = null;
        
        try {
            //反序列化为对象
            bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
}

/**
 * @Description: 切面：查询前先查询redis，如果查询不到穿透到数据库，从数据库查询到数据后，保存到redis，然后下次查询可直接命中缓存
 */
@Component
@Aspect
public class RedisAspect {

    @Autowired
    @Qualifier("redisCache")
    private RedisCache redisCache;
    
    //设置切点：使用xml，在xml中配置
    @Pointcut("execution(* com.club.common.redis.service.TestService.get(java.lang.Integer)) and args(applId)")    //测试用，这里还额外指定了方法名称，方法参数类型，方法形参等，比较完整的切点表达式
　　 public void myPointCut(){
        
    }
    
    @Around("myPointCut()")
    public Object around(ProceedingJoinPoint joinPoint){
        //前置：到redis中查询缓存
        System.out.println("调用从redis中查询的方法...");
        
        //先获取目标方法参数
        String applId = null;
        Object[] args = joinPoint.getArgs();
        if (args != null && args.length > 0) {
           applId = String.valueOf(args[0]);
        }
        
        //redis中key格式：    applId
        String redisKey = applId;
        
        //获取从redis中查询到的对象
        Object objectFromRedis = redisCache.getDataFromRedis(redisKey);
        
        //如果查询到了
        if(null != objectFromRedis){
            System.out.println("从redis中查询到了数据...不需要查询数据库");
            return objectFromRedis;
        }
        
        System.out.println("没有从redis中查到数据...");
        
        //没有查到，那么查询数据库
        Object object = null;
        try {
            object = joinPoint.proceed();
        } catch (Throwable e) {
            
            e.printStackTrace();
        }
        
        System.out.println("从数据库中查询的数据...");
        
        //后置：将数据库中查询的数据放到redis中
        System.out.println("调用把数据库查询的数据存储到redis中的方法...");
        
        redisCache.setDataToRedis(redisKey, object);
        
        //将查询到的数据返回
        return object;
        
    }
}

/**
 * 
 * @Description:Redis缓存
 */
public class RedisCache {
    
    @Resource
    private JedisPool jedisPool;
    public JedisPool getJedisPool() {
        return jedisPool;
    }
    public void setJedisPool(JedisPool jedisPool) {
        this.jedisPool = jedisPool;
    }

    //从redis缓存中查询，反序列化
    public Object getDataFromRedis(String redisKey){
        //查询
        Jedis jedis = jedisPool.getResource();
        byte[] result = jedis.get(redisKey.getBytes());
        
        //如果查询没有为空
        if(null == result){
            return null;
        }
        
        //查询到了，反序列化
        return SerializeUtil.unSerialize(result);
    }
    
    //将数据库中查询到的数据放入redis
    public void setDataToRedis(String redisKey, Object obj){
        
        //序列化
        byte[] bytes = SerializeUtil.serialize(obj);
        
        //存入redis
        Jedis jedis = jedisPool.getResource();
        String success = jedis.set(redisKey.getBytes(), bytes);
        
        if("OK".equals(success)){
            System.out.println("数据成功保存到redis...");
        }
    }
}

　　　　//先获取目标方法参数
        String applId = null;
        Object[] args = joinPoint.getArgs();
        if (args != null && args.length > 0) {
           applId = String.valueOf(args[0]);
        }
        
        //获取目标方法所在类
        String target = joinPoint.getTarget().toString();
        String className = target.split("@")[0];
        
        //获取目标方法的方法名称
        String methodName = joinPoint.getSignature().getName();
        
        //redis中key格式：    applId:方法名称
        String redisKey = applId + ":" + className + "." + methodName;