Redis（五）之整合Jedis与Spring

女爷i 2022-05-21 05:52 201阅读 0赞

思路：创建一个redis操作的接口。分别创建两个实现类对应redis 的单机版和集群版。当使用单机版redis时，配置单机版的实现类，当使用集群版本的时候，配置集群版的实现类。

# JedisClient接口 #

/** * redis客户端接口，在这里添加常用方法 */
    public interface JedisClient { 
        public String set(String key, String value);
        public String get(String key);
        public Long hset(String key, String item, String value);
        public String hget(String key, String item);
        public Long incr(String key);
        public Long decr(String key);
        public Long expire(String key, int second);
        public Long ttl(String key);
    }

# JedisClient单机版实现类 #

/** * redis客户端单机版实现类 */
    public class JedisClientSingle implements JedisClient{ 
    
        @Autowired
        private JedisPool jedisPool;
    
        @Override
        public String set(String key, String value) {
            Jedis jedis = jedisPool.getResource();
            String result = jedis.set(key, value);
            jedis.close();
            return result;
        }
    
        @Override
        public String get(String key) {
            Jedis jedis = jedisPool.getResource();
            String result = jedis.get(key);
            jedis.close();
            return result;
        }
    
        @Override
        public Long hset(String key, String item, String value) {
            Jedis jedis = jedisPool.getResource();
            Long result = jedis.hset(key, item, value);
            jedis.close();
            return result;
        }
    
        @Override
        public String hget(String key, String item) {
            Jedis jedis = jedisPool.getResource();
            String result = jedis.hget(key, item);
            jedis.close();
            return result;
        }
    
        @Override
        public Long incr(String key) {
            Jedis jedis = jedisPool.getResource();
            Long result = jedis.incr(key);
            jedis.close();
            return result;
        }
    
        @Override
        public Long decr(String key) {
            Jedis jedis = jedisPool.getResource();
            Long result = jedis.decr(key);
            jedis.close();
            return result;
        }
    
        @Override
        public Long expire(String key, int second) {
            Jedis jedis = jedisPool.getResource();
            Long result = jedis.expire(key, second);
            jedis.close();
            return result;
        }
    
        @Override
        public Long ttl(String key) {
            Jedis jedis = jedisPool.getResource();
            Long result = jedis.ttl(key);
            jedis.close();
            return result;
        }
    }

# JedisClient集群版实现类 #

/** * redis客户端集群版实现类 */
    public class JedisClientCluster implements JedisClient { 
    
        @Autowired
        private JedisCluster jedisCluster;
    
        @Override
        public String set(String key, String value) {
            return jedisCluster.set(key, value);
        }
    
        @Override
        public String get(String key) {
            return jedisCluster.get(key);
        }
    
        @Override
        public Long hset(String key, String item, String value) {
            return jedisCluster.hset(key, item, value);
        }
    
        @Override
        public String hget(String key, String item) {
            return jedisCluster.hget(key, item);
        }
    
        @Override
        public Long incr(String key) {
            return jedisCluster.incr(key);
        }
    
        @Override
        public Long decr(String key) {
            return jedisCluster.decr(key);
        }
    
        @Override
        public Long expire(String key, int second) {
            return jedisCluster.expire(key, second);
        }
    
        @Override
        public Long ttl(String key) {
            return jedisCluster.ttl(key);
        }
    }

# Spring中的配置 #

<context:component-scan base-package="com.taotao.rest.component"></context:component-scan>
    
    
    
    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="host" value="192.168.25.153"></constructor-arg>
        <constructor-arg name="port" value="6379"></constructor-arg>
    </bean>
    
    <bean id="jedisClientSingle" class="com.taotao.rest.component.impl.JedisClientSingle"/>

# 测试 #

@Test
    public void testJedisClientSpring() throws Exception {
        //创建一个spring容器
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml");
        //从容器中获得JedisClient对象
        JedisClient jedisClient = applicationContext.getBean(JedisClient.class);
        //jedisClient操作redis
        jedisClient.set("client", "1024");
        String string = jedisClient.get("client");
        System.out.println(string);
    }