首页 / 日志 / 曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7231字，纯文字阅读大概需要11分钟。

内容图文

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志

写在前面的话

概要

本篇是独立的，和前面几篇aop相关分析没有特别关联，但是使用了上一篇提到的工具类。

曹工说Spring Boot源码（19）-- Spring 带给我们的工具利器，创建代理不用愁（ProxyFactory）

之前也使用类似的思路，实现过完整sql日志记录。

曹工杂谈--使用mybatis的同学，进来看看怎么在日志打印完整sql吧，在数据库可执行那种

这两天在搬砖，有个需求，是统计类的。一般来说，统计类的东西，比如要统计：用户总数，用户的新增总数，当天每个小时为维度的新增数量，各个渠道的新增用户数量；这些，可能都得在redis里维护，然后某个用户注册时，去把所有这些redis结构+1。

但这种代码，一般入口很多，修改这些值的地方很多，编码时很容易发生遗漏，或者编码错误，导致最后统计数据不准确。数据不准确，当然是bug，问题是，这种bug还不好排查。

如果能够记录下redis操作日志就好了。

以下，是我已经实现的效果，这是一次请求中的一次redis操作，可以看到，是put方法。

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志 - 文章图片

实现思路

我们用的是spring boot 2.1.7，直接集成的RedisTemplate。当然，只要是使用RedisTemplate即可，和spring boot没多大关系。

我看了下我们平时是怎么去操作redis 的hash结构的，大概代码如下：

@Autowired
@Qualifier("redisTemplate")
private RedisTemplate<String,Object> redisTemplate;

HashOperations<String, HK, HV> ops = redisTemplate.opsForHash();
ops.put(key, hashKey,fieldValue);

一般就是，先通过opsForHash，拿到HashOperations，再去操作hash结构。

我现在的想法就是，在执行类似ops的put的方法之前，把那几个参数记录到日志里。

要想让ops记录我们的日志，我们只能拦截其每个方法，这一步就得使用一个代理对象，去替换掉真实的对象。

但是，怎么才能让redisTemplate.opsForHash()返回的ops，是我们代理过的对象呢？

所以，这一步，还得在生成redisTemplate的地方下功夫，让其生成一个redisTemplate的代理对象，这个代理对象，拦截opsForHash方法。

总结下，需要做两件事：

对redisTemplate做代理，拦截opsForHash方法；
在拿到第一步的原有的ops对象后，对ops对象做代理，拦截其put方法等。

代码实现

原有代码

@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String,Object> template = new RedisTemplate<>();
        template.setValueSerializer(new CustomGenericJackson2JsonRedisSerializer());
        template.setHashKeySerializer(new CustomHashKeyRedisSerializer());
        template.setKeySerializer(RedisSerializer.string());
        template.setHashValueSerializer(new CustomGenericJackson2JsonRedisSerializer());

        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }

代理RedisTemplate

@Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String,Object> template = new RedisTemplate<>();
        template.setValueSerializer(new CustomGenericJackson2JsonRedisSerializer());
        template.setHashKeySerializer(new CustomHashKeyRedisSerializer());
        template.setKeySerializer(RedisSerializer.string());
        template.setHashValueSerializer(new CustomGenericJackson2JsonRedisSerializer());

        template.setConnectionFactory(redisConnectionFactory);

        ProxyFactory proxyFactory = new ProxyFactory();
        proxyFactory.setTarget(template);
        proxyFactory.setProxyTargetClass(true);
        proxyFactory.addAdvice(new MethodInterceptor() {
            @Override
            public Object invoke(MethodInvocation invocation) throws Throwable {
                //拦截opsForHash
                boolean b = invocation.getMethod().getName().equals("opsForHash");
                if (b) {
                    // todo，下一步再完善这里
                }

                return invocation.proceed();
            }
        });
        //这里获取到针对template的代理对象，并返回
        Object proxy = proxyFactory.getProxy();
        return (RedisTemplate<String, Object>) proxy;
    }

大家可以仔细看上面的代码，利用了前一讲我们学习了的ProxyFactory，来生成代理；使用它呢，比较方便，不用管底层它是用jdk动态代理，还是cglib代理，spring已经帮我们处理好了。

总之，上面这段，就是把redisTemplate给换了。我们具体要在拦截了opsForHash里，做什么动作呢？我们再看。

代理opsForHash的返回结果

@Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String,Object> template = new RedisTemplate<>();
        template.setValueSerializer(new CustomGenericJackson2JsonRedisSerializer());
        template.setHashKeySerializer(new CustomHashKeyRedisSerializer());
        template.setKeySerializer(RedisSerializer.string());
        template.setHashValueSerializer(new CustomGenericJackson2JsonRedisSerializer());

        template.setConnectionFactory(redisConnectionFactory);

        ProxyFactory proxyFactory = new ProxyFactory();
        proxyFactory.setTarget(template);
        proxyFactory.setProxyTargetClass(true);
        proxyFactory.addAdvice(new MethodInterceptor() {
            @Override
            public Object invoke(MethodInvocation invocation) throws Throwable {
                boolean b = invocation.getMethod().getName().equals("opsForHash");
                if (b) {
                    // 1. 这一步，拿到原有的opsForHash的返回结果
                    HashOperations hashOperations = (HashOperations) invocation.proceed();
                    
                    //2. 下边，对hashOperations进行代理
                    ProxyFactory proxyFactory = new ProxyFactory();
                    proxyFactory.setTarget(hashOperations);
                    proxyFactory.setProxyTargetClass(false);
                    proxyFactory.setInterfaces(HashOperations.class);
                    //3. 我们这个代理干什么事呢，就是加了一个方法前的拦截器，记录日志
                    proxyFactory.addAdvice(new MethodBeforeAdviceInterceptor(new MethodBeforeAdvice() {
                        // 使用fastjson格式化了参数，并记录到日志
                        @Override
                        public void before(Method method, Object[] args, Object target) {
                            log.info("method:{},args:{}",method.getName(),
                                    JSON.toJSONString(args, SerializerFeature.PrettyFormat));
                        }
                    }));
                   // 这里返回针对hashOperations的代理
                    return proxyFactory.getProxy();
                }

                return invocation.proceed();
            }
        });
        Object proxy = proxyFactory.getProxy();

        return (RedisTemplate<String, Object>) proxy;
    }

总结

我这个拦截比较粗，现在是把get类的日志也打出来了。大家可以判断下method的名称，来自行过滤掉。

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志 - 文章图片

ok，本篇先到这里。下讲继续讲Spring ProxyFactory的内容。

内容总结

以上是互联网集市为您收集整理的曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志全部内容，希望文章能够帮你解决曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/876402.html

来源：【匿名】

首页 / 日志 / 曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志

内容导读

内容图文

写在前面的话

概要

实现思路

代码实现

原有代码

代理RedisTemplate

代理opsForHash的返回结果

总结

内容总结

内容备注

内容手机端

【曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志】教程文章相关的互联网学习教程文章

曹工说Spring Boot源码（20）-- 码网灰灰，疏而不漏，如何记录Spring RedisTemplate每次操作日志【图】

SPRING - 相关标签

BOOT - 相关标签

日志 - 最新教程

日志 - 最热教程