spring data redis集成jodis的简单实现

项目要使用spring-data-redis的抽象实现，又要通过jodis实现codisproxy的负载和热备，看到前面issue有提示，就花时间研究了一下。 如果要使用RedisTemplate的话，它在jedis上抽象了一层JedisConnection，需要把pool放进去，RedisTemplate释放连接使用RedisConnectionUtils.releaseConnection(conn, factory);这个方法最后使用JedisConnection的close（如果有pool就return连接，如果没有就直接quit+disconnect关闭连接），而不是调用Jedis.close（它会判断Datasource即pool是否为空，有则return连接，没有就close掉）。虽然jodis拿到的jedis里带了pool信息，但是取不出来放到JecisConnection，RedisTemplate使用RedisConnectionUtils.releaseConnection 释放连接时，就直接close掉jedis连接而无法return给pool。解决方法是：RoundRobinJedisPool.getResource时直接返回JedisConnection. 1. 在RoundRobinJedisPool加返回JedisConnection的方法： @Override public JedisConnection getResourceForSpringDataRedis() { ImmutableList<PooledObject> pools = this.pools; if (pools.isEmpty()) { throw new JedisException("Proxy list empty"); } for (;;) { int current = nextIdx.get(); int next = current >= pools.size() - 1 ? 0 : current + 1; if (nextIdx.compareAndSet(current, next)) { Pool<Jedis> pool=pools.get(next).pool; return new JedisConnection(pool.getResource(),pool,0); } }

`}`

2. 实现ConnectionFactory public class JodisConnectionFactory implements InitializingBean, DisposableBean, RedisConnectionFactory { private final static Log log = LogFactory.getLog(JodisConnectionFactory.class); private static final ExceptionTranslationStrategy EXCEPTION_TRANSLATION = new PassThroughExceptionTranslationStrategy( JedisConverters.exceptionConverter());

`JedisResourcePool jodisPool;	`
`public JodisConnectionFactory(JedisResourcePool jodisPool) {`
	`this.jodisPool=jodisPool;`
`}`
`@Override`
`public RedisConnection getConnection() {		`
	`return jodisPool.getResourceForSpringDataRedis();`
`}`
`@Override`
`public void destroy() throws Exception {`
	`if(jodisPool!=null)`
		`jodisPool.close();`

`}`
`@Override`
`public DataAccessException translateExceptionIfPossible(RuntimeException ex) {`
	`return EXCEPTION_TRANSLATION.translate(ex);`
`}	`
`@Override`
`public RedisClusterConnection getClusterConnection() {`
	`// TODO Auto-generated method stub`
	`return null;`
`}`
`@Override`
`public boolean getConvertPipelineAndTxResults() {`
	`// TODO Auto-generated method stub`
	`return false;`
`}`
`@Override`
`public RedisSentinelConnection getSentinelConnection() {`
	`// TODO Auto-generated method stub`
	`return null;`
`}	`
`@Override`
`public void afterPropertiesSet() throws Exception {`
	`// TODO Auto-generated method stub`
`}`

}

3. 在@configuration类里加注解初始化对应的类 @Bean public JedisResourcePool jodisPool() { JedisPoolConfig jedisPoolConfig=new JedisPoolConfig(); jedisPoolConfig.setMaxTotal(20); jedisPoolConfig.setMaxIdle(20); jedisPoolConfig.setMinIdle(5); jedisPoolConfig.setMaxWaitMillis(-1); return RoundRobinJedisPool.create().curatorClient("192.168.11.62:2181", 30000).zkProxyDir("/jodis/codis-demo").build(); }

`@Bean`
`public JodisConnectionFactory redisConnectionFactory(){`
	`return new JodisConnectionFactory(jodisPool());`
`}`

`@Bean`
`public RedisTemplate<Object, Object> redisTemplate(`
		`RedisConnectionFactory redisConnectionFactory)`
				`throws UnknownHostException {`
	`RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();`
	`template.setConnectionFactory(redisConnectionFactory());`
	`return template;`
`}`

4. @Autowired注入RedisTemplate就能使用了