spring-data-redis redisTemplate Exception

2 回答

• 6

  默认情况下，RedisTemplate使用JdkSerializationRedisSerializer，因此如果你执行了“set”，它会使你的Long在Redis中看起来像这样：

  "\xac\xed\x00\x05sr\x00\x0ejava.lang.Long;\x8b\xe4\x90\xcc\x8f#\xdf\x02\x00\x01J\x00\x05valuexr\x00\x10java.lang.Number\x86\xac\x95\x1d\x0b\x94\xe0\x8b\x02\x00\x00xp\x00\x00\x00\x00\x00\x00\x00\x04"
  

  IncrBy有效，因为Redis总是从该操作返回Long，因此RedisTemplate不会尝试反序列化结果 . 然而，“get”的结果经历了反序列化过程，该过程期望具有如上所述的格式 .

  您可以通过在RedisTemplate上使用不同的值序列化器来解决此问题：

  redisTemplate.setValueSerializer(new GenericToStringSerializer<Long>(Long.class));
  

  或者尝试spring-data-redis附带的RedisAtomicLong类 .

  回复于 2024-06-17T16:21:59+08:00
• 8

  有点令人沮丧 - 感谢RedisAtomicLong上的提示..但这里是使用HashOps与String Key，String字段和Long值的解决方案 - 使用Spring Boot以便于配置

  @SpringBootApplication
  @Configuration
  public class DemoApplication {
  
      public static void main(String[] args) {
          final ConfigurableApplicationContext context = SpringApplication.run(DemoApplication.class, args);
          final DacRepository dacRepository  = context.getBean(DacRepository.class);
          dacRepository.incrKeyExample();
      }
  
  
      @Bean
      public RedisTemplate<String, Long> getLongRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
           final RedisTemplate<String,Long> redisTemplate = new RedisTemplate<String, Long>();
           redisTemplate.setConnectionFactory(redisConnectionFactory);
           redisTemplate.setHashValueSerializer(new GenericToStringSerializer<Long>(Long.class));
           redisTemplate.setKeySerializer(new StringRedisSerializer());
           redisTemplate.setValueSerializer(new GenericToStringSerializer<Long>(Long.class));
           redisTemplate.setHashKeySerializer(new StringRedisSerializer());
           redisTemplate.afterPropertiesSet();
           return redisTemplate;
      }
  }
  
  import java.util.Set;
  
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.data.redis.core.HashOperations;
  import org.springframework.data.redis.core.RedisTemplate;
  import org.springframework.stereotype.Repository;
  
  @Repository
  
  public class DacRepository {
  
      private final HashOperations<String, String, Long> hashOps;
  
      @Autowired
      private final RedisTemplate<String, Long> redisTemplate;
  
      @Autowired
      public DacRepository(RedisTemplate<String, Long> redisTemplate) {
          this.redisTemplate = redisTemplate;
          hashOps = redisTemplate.opsForHash();
  
      }
  
  
      public void incrKeyExample() {
          final Set<String> keys = this.redisTemplate.keys("*");
          for(String key: keys) {
              System.out.println("key: "+ key);
          }
  
          final String key = "deal-1";
          final String field = "view";
          final Long value = 1L;
          hashOps.put(key, field, value);
          final Long delta = 1L;
          hashOps.increment(key, field, delta);
          Long val = hashOps.get("deal-1", "view");
          System.out.println("Value = "+val);
      }
  
  }
  
  
  
  
  server.port=9001
  spring.redis.host=localhost
  spring.redis.port=6379
  spring.redis.pool.max-idle=8
  spring.redis.pool.min-idle=0
  spring.redis.pool.max-active=8
  spring.redis.pool.max-wait=-1
  

  回复于 2024-06-17T16:21:59+08:00