锐客网

  1. 首页 > 睿知 > it技术 > >

解决spring|解决spring data redis的那些坑

目录

  • spring data redis的那些坑
    • 1. 使用lua脚本，返回类型解析错误
    • 2. spring redis基于lettuce配置Client必须显示调用
  • spring data redis 的优缺点

    spring data redis的那些坑 spring 的IOC很少有bug，AOPbug开始多起来，到了它的一些“玩具”一样的组件，bug无处不在。而且跟一般的开源框架不同，在github上你报告issue，会被“这不是一个bug”强行关闭。开一博文记录，给遇到同样问题而苦恼的人歇歇脚。

    1. 使用lua脚本，返回类型解析错误
    背景：一般来讲，就算脚本里没有return语句，redis也是会返回执行结果，看起来就像：{“Ok” = “ok”}，或者{“ok”:”ok”}。然而对于一些操作redis没有返回，或者return语句后面返回一个值，spring包了的那一层壳就会出问题。影响的包：spring封装了jedis的所有版本，包括：spring-data-redis 2.0以下的所有版本，以及使用了jedis的2.0以上版本：
    org.springframework.bootspring-boot-starter-data-redis2.0.0.RELEASEio.lettucelettuce-core

    这种情况下就会遇到
    XXX cannot be cast to XXX
    原因：DefaultScriptExecutor.java类中：
    public T execute(final RedisScript script, final RedisSerializer argsSerializer,final RedisSerializer resultSerializer, final List keys, final Object... args) {return template.execute((RedisCallback) connection -> {final ReturnType returnType = ReturnType.fromJavaType(script.getResultType()); // return type is wrong.final byte[][] keysAndArgs = keysAndArgs(argsSerializer, keys, args); final int keySize = keys != null ? keys.size() : 0; if (connection.isPipelined() || connection.isQueueing()) {// We could script load first and then do evalsha to ensure sha is present,// but this adds a sha1 to exec/closePipeline results. Instead, just evalconnection.eval(scriptBytes(script), returnType, keySize, keysAndArgs); return null; }return eval(connection, script, returnType, keySize, keysAndArgs, resultSerializer); }); }

    而作为消费者，一般会将返回值设置为Object，因为同一个脚本里有若干的逻辑，不同情况下返回值可能是布尔型，字符串型，Number型等。
    ScriptSource scriptSource = new ResourceScriptSource(new ClassPathResource("META-INF/scripts/redis.lua")); DefaultRedisScript redisScript = new DefaultRedisScript(); redisScript.setScriptSource(scriptSource); redisScript.setResultType(Object.class);
    而DefaultScriptExecutor的execute方法，会把Object类型解析为List类型，进而设置returnType为Multi。
    public Object convert(Object result) {if (result instanceof String) {// evalsha converts byte[] to String. Convert back for consistencyreturn SafeEncoder.encode((String) result); }if (returnType == ReturnType.STATUS) {return JedisConverters.toString((byte[]) result); }if (returnType == ReturnType.BOOLEAN) {// Lua false comes back as a null bulk replyif (result == null) {return Boolean.FALSE; }return ((Long) result == 1); }if (returnType == ReturnType.MULTI) {List resultList = (List) result; List convertedResults = new ArrayList<>(); for (Object res : resultList) {if (res instanceof String) {// evalsha converts byte[] to String. Convert back for// consistencyconvertedResults.add(SafeEncoder.encode((String) res)); } else {convertedResults.add(res); }}return convertedResults; }return result; }
    会因为result（原本只是一个Object），被解析为List，转换出了问题。此外，这里居然没有设置null的转换，难道null就不是List了。。。好在spring redis基于lettuce的实现不存在这个问题。

    2. spring redis基于lettuce配置Client必须显示调用
    从官方的reference看，spring的lettuce的配置只需要简单使用一个包含host、port、database、password等链接必须信息构造的RedisStandaloneConfiguration对象作为参数传递给LettuceConnectionFactory 的构造函数，同理连接池，然而实际使用中发现，ConnectionFactory用于建立连接的是从它的client属性获取的服务器地址等，因此必须调用afterPropertiesSet方法。
    现在client信息有了，可以连接，但是连接池又未开启，尽管已经在构造器参数中指定过。受限于时间，还没有调这个点。
    LettucePoolingClientConfiguration poolingClientConfiguration = LettucePoolingClientConfiguration.builder().poolConfig(new GenericObjectPoolConfig()).build(); RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(redisProperty.getHost(),redisProperty.getPort()); redisStandaloneConfiguration.setDatabase(redisProperty.getDatabase()); LettuceConnectionFactory cf = new LettuceConnectionFactory(redisStandaloneConfiguration, poolingClientConfiguration); cf.afterPropertiesSet(); // mustStringRedisTemplate stringRedisTemplate = new StringRedisTemplate(); stringRedisTemplate.setConnectionFactory(cf); setSerializer(stringRedisTemplate);


    spring data redis 的优缺点 spring-data-redis是由spring的 cache api 整合 redis 而来，它的命名规则由spring cache 的规则来定义key和对key的管理，进一步弱化redis的API。
    事实上redis提供的功能已经足够强大，并且可以直接使用，同时支持灵活的分库。
    spring 的 cache 功能主要由 @Cacheable @CacheEvict @CachePut 实现
    • @Cacheable 主要针对方法配置，能够根据方法的请求参数对其结果进行缓存
    • @CachePut 主要针对方法配置，能够根据方法的请求参数对其结果进行缓存，和 @Cacheable 不同的是，它每次都会触发真实方法的调用
    • @CachEvict 主要针对方法配置，能够根据一定的条件对缓存进行清空
    默认情况下Spring使用CacheManagerBean 来实现，其实现有3种：EHCache，Redis，ConcurrentHashMap，默认的ConcurrentHashMap 是没有过期的。
    Redis 的使用也是要自己手动调 expire ，所以暂时使用原生的 jedis ，直接调用 redis 的api
    【解决spring|解决spring data redis的那些坑】以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

      推荐阅读


      上一篇：腾讯安全威胁情报中心TIX产品发布 助力企业掌握安全防御主动权

      下一篇：Go 语言入门很简单（net/http 包）