Spring Data Redis答案

【问题标题】：Spring Data RedisSpring Data Redis
【发布时间】：2014-12-29 12:34:31
【问题描述】：

我正在使用带有 aspectJ 的 spring data redis 和 jedis 进行日志记录。但得到以下错误。请帮助解决此错误。我花了很多时间解决这个问题。

我正在使用 Spring Data Redis 1.4.1、jedis-2.6.1 和 Redis-2.8

错误详情：-

Caused by: org.springframework.beans.factory.BeanDefinitionStoreException: Illegal arguments to factory method [public org.springframework.data.redis.core.RedisTemplate com.test.RedisSentinelApplicationConfig.redisTemplate()]; args: 
    at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:172)
    at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:586)
    ... 38 more

下面是使用spring data redis配置redis Sentinel的Java配置文件

@Configuration
public class RedisSentinelApplicationConfig {   
    private static final Logger logger = LoggerFactory.getLogger(RedisSentinelApplicationConfig.class);

    @Autowired
    private Environment env;

    @Value("${redis.master}") 
    private String REDIS_MASTER;

    public RedisSentinelConfiguration redisSentinelConfiguration() {
        if(null != env){
            logger.debug("env-->" + env.getProperty("redis.master"));
        }else{
            logger.debug("ENV object is null");
        }

        logger.debug("REDIS_MASTER-->" + REDIS_MASTER);

        final RedisSentinelConfiguration SENTINEL_CONFIG = new RedisSentinelConfiguration()
        .master(env.getProperty("redis.master"))
        .sentinel(env.getProperty("redis.sentinel1.host"), Integer.valueOf(env.getProperty("redis.sentinel1.port")))
        .sentinel(env.getProperty("redis.sentinel2.host"), Integer.valueOf(env.getProperty("redis.sentinel2.port")))
        .sentinel(env.getProperty("redis.sentinel3.host"), Integer.valueOf(env.getProperty("redis.sentinel3.port")));

        return SENTINEL_CONFIG;
    }

    @Bean
    public RedisConnectionFactory jedisConnectionFactory() {
        return new JedisConnectionFactory(sentinelConfig());
    }

    @Bean
    public RedisSentinelConfiguration sentinelConfig() {
        return redisSentinelConfiguration();
    }

    @Bean
    public RedisTemplate<String, ?> redisTemplate() {
       RedisTemplate<String, ?> template = new RedisTemplate();
       template.setConnectionFactory(jedisConnectionFactory());
       template.setValueSerializer(jackson2JsonRedisSerializer());      
       template.setHashValueSerializer(jackson2JsonRedisSerializer());
        return template;
    }

    @SuppressWarnings("rawtypes")
    @Bean(name="cacheService")
    public CacheService CacheService() {
        return new CacheServiceImpl();
    }

    @Bean
    public Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer() {
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(
                Object.class);
        jackson2JsonRedisSerializer.setObjectMapper(objectMapper());
        return jackson2JsonRedisSerializer;
    }

     @Bean
    public ObjectMapper objectMapper() {
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        return objectMapper;
    }
}

以下是日志记录的 Aspectj 配置。如果我评论@Component，除了记录一切都很好但如果 @Component 存在，则同样不起作用。看来 AspectJ 和 spring data redis 冲突了

@Component
@Aspect
public class PerfApplicationLogger {
    private static final Logger log = LoggerFactory.getLogger(PerfApplicationLogger.class); 

    @Around("execution(* *(..))")
    public Object logTimeMethod(ProceedingJoinPoint joinPoint) throws Throwable {

            StopWatch stopWatch = new StopWatch();
            stopWatch.start();

            Object retVal = joinPoint.proceed();

            stopWatch.stop();

            StringBuilder logMessage = new StringBuilder();
            logMessage.append(joinPoint.getTarget().getClass().getName());
            logMessage.append(".");
            logMessage.append(joinPoint.getSignature().getName());
            logMessage.append("(");
            // append args
            Object[] args = joinPoint.getArgs();
            for (int i = 0; i < args.length; i++) {
                logMessage.append(args[i]).append(",");
            }
            if (args.length > 0) {
                logMessage.deleteCharAt(logMessage.length() - 1);
            }

            logMessage.append(")");
            logMessage.append(" execution time: ");
            logMessage.append(stopWatch.getTotalTimeMillis());
            logMessage.append(" ms");
            log.debug(logMessage.toString());
            return retVal;
    }
}

【问题讨论】：

嗯，我已经尝试了代码（对 sentinel-config 进行了一些修改）并且我得到了它的工作。您是否添加了任何其他配置（例如一些 redis-xml-stuff）？
我没有使用任何其他配置。 AOP 日志记录是否适合您？我试图调试，我发现根本原因如下引起：java.lang.IllegalStateException：无法转换类型[com.sun.proxy.$Proxy16实现org.springframework.data.redis.connection.NamedNode的值， org.springframework.aop.SpringProxy,org.springframework.aop.framework.Advised] 到属性“sentinels[0]”所需的类型 [org.springframework.data.redis.connection.RedisNode]：找不到匹配的编辑器或转换策略
我通过 2 次更改使其工作。一是通过强制使用 CGLIB 与此，二更改 AOP 日志记录类的包以仅使用 @Around("execution(* com .myapplication.code..*.*(..))")。有了这个，它停止为 spring 框架类做 AOP 日志记录

标签： spring redis spring-data-redis

【解决方案1】：

请确保 spring-data-redis 版本与 Jedis 版本兼容。

参考链接（http://mvnrepository.com/artifact/org.springframework.data/spring-data-redis/1.4.1.RELEASE），spring-data-redis 兼容 Jedis 2.5.2。您应该将您的 jedis (2.6.1) 版本降级到 2.5.2。

【讨论】：