一、spring-redis配置
如上,在shardedJedisPool中增加多个redis分片
二、代码实现
import javax.inject.Inject;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.stereotype.Component;import com.iflashbuy.base.util.JsonUtil;import com.iflashbuy.base.util.StringUtil;import redis.clients.jedis.ShardedJedis;import redis.clients.jedis.ShardedJedisPool;@Componentpublic class RedisOperator { private static final Logger log = LoggerFactory.getLogger(RedisOperator.class); @Inject public ShardedJedisPool shardedJedisPool; public void set(String key, Object obj) { String jsonStr = ""; if (obj instanceof String) { jsonStr = (String) obj; } else { jsonStr = JsonUtil.objectToJsonStr(obj); } ShardedJedis jedis = shardedJedisPool.getResource(); jedis.set(key, jsonStr); } publicT get(String key, Class clazz) { ShardedJedis jedis = shardedJedisPool.getResource(); String jsonStr = jedis.get(key); if (StringUtil.isNotEmpty(jsonStr)) { try { return (T) JsonUtil.formJson(jsonStr, clazz); } catch (Exception e) { log.error("joson转为对象失败:" + e); return null; } } else { return null; } } }