Estoy tratando de usar Redis Cache para mejorar el rendimiento de nuestra aplicación. Me refiero a este artículo para mi implementación. Estoy recibiendo esta excepción:

 class com.entity.UserEntity cannot be cast to class com.entity.UserEntity

RedisConfig:

 @Configuration @EnableCaching public class RedisConfig { @Value("${spring.redis.port}") int redisPort; @Value("${spring.redis.host}") String redisHost; @Bean public LettuceConnectionFactory redisLettuceConnectionFactory() { RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(redisHost,redisPort); return new LettuceConnectionFactory(redisStandaloneConfiguration); } @Bean public RedisTemplate<String, Object> redisTemplate() { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisLettuceConnectionFactory()); redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); redisTemplate.setHashKeySerializer(new JdkSerializationRedisSerializer()); redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer()); redisTemplate.setEnableTransactionSupport(true); redisTemplate.afterPropertiesSet(); return redisTemplate; } }

Entidad usuaria:

 @Entity @Getter @Setter @EqualsAndHashCode(callSuper=false) @Slf4j @Table(name="user") public class UserEntity extends BaseEntity implements Serializable { private static final long serialVersionUID = 1L; @Id @Column(name = "user_id") @Type(type = "uuid-char") private UUID userId;//Binary in DB and UUID here @OneToMany(fetch = FetchType.EAGER, mappedBy = "user", orphanRemoval = true, cascade= CascadeType.ALL) @JsonIgnore @ToStringExclude @Fetch(value = FetchMode.SUBSELECT) private List<EmailAddress> emailAddresses = new ArrayList<>(); . . . }

UserDaoImpl

 @Repository public class UserDaoImpl implements UserDao { private UserRepository userRepository; private HashOperations hashOperations; //to access Redis cache private static final String KEY = "User"; public UserDaoImpl(@Autowired RedisTemplate<String, Object> redisTemplate, @Autowired UserRepository userRepository) { this.userRepository = userRepository; hashOperations = redisTemplate.opsForHash(); } @Override public Optional<UserEntity> fetchUserById(String userId) throws Exception { // Getting Exception here (UserEntity) hashOperations.get(KEY,userId) UserEntity userEntity = (UserEntity) hashOperations.get(KEY,userId); Optional<UserEntity> userOptional = Optional.ofNullable(userEntity); if(!userOptional.isPresent()) { userOptional = userRepository.findByUserId(userId); if (userOptional.isPresent()) { System.out.println("Cache Miss User id:" + userOptional.get().getUserId()); hashOperations.put(KEY, userOptional.get().getUserId().toString(), userOptional.get()); } else { throw new Exception("User not present"); } } return userOptional; } }

Puedo colocar correctamente UserEntity en el caché, pero luego, al recuperarlo, obtengo la excepción mencionada anteriormente. Lo más probable es que el problema se deba a Hibernate. Cuando almacenamos en caché la entidad por primera vez, coloca Proxy/PersistentBag en lugar de Colecciones, por lo que la próxima vez (en alguna otra sesión) cuando recuperemos el Objeto de Caché, no podremos enviarlo a la entidad requerida. ¿Alguien puede confirmar que este es el problema, en caso afirmativo, cómo resolverlo?