一、背景

　　上篇文章我们介绍了如何在centos7下面进行安装单机版redis以及redis集群。这篇文章，我们来聊一聊如何使用java客户端来进行操作redis。我们知道redis的java客户端有很多,如：jedis、redission等。这篇文章着重介绍我们平常使用最多的redis的java客户端jedis。

二、通过单元测试来小试牛刀

　　1.首先在maven的pom.xml中引入jedis-client的依赖

         
      
       redis.clients
          
      
       jedis
          
      
       2.7.2
      
     

　　2.使用junit进行单元测试

package com.hafiz.redis.test;import java.util.HashSet;import java.util.Set;import org.junit.Test;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisCluster;import redis.clients.jedis.JedisPool;public class JedisTest {    @Test    public void testJedisSingle() {        // 创建一个jedis连接        Jedis client = new Jedis("192.168.25.153", 6379);        client.set("name", "zhangsan");        String name = client.get("name");        System.out.println(name);        // 关闭连接        client.close();    }        @Test    public void testJedisPoolSingle() {        // 创建一个连接池对象，系统中应该是单例的        JedisPool pool = new JedisPool("192.168.25.153", 6379);        // 从连接池中获取一个连接        Jedis client = pool.getResource();        client.set("age", "100");        String name = client.get("name");        String age = client.get("age");        System.out.println(name);        System.out.println(age);        // jedis必须关闭连接        client.close();                // 关闭连接池        pool.close();    }        @Test    public void testJedisCluster() {        // 创建一个jedisCluster对象的节点集合        Set
     
       nodes = new HashSet<>();        // 在nodes中指定每个节点的地址        nodes.add(new HostAndPort("192.168.25.153", 7001));        nodes.add(new HostAndPort("192.168.25.153", 7002));        nodes.add(new HostAndPort("192.168.25.153", 7003));        nodes.add(new HostAndPort("192.168.25.153", 7004));        nodes.add(new HostAndPort("192.168.25.153", 7005));        nodes.add(new HostAndPort("192.168.25.153", 7006));        // 创建一个jedisCluster对象，该对象在系统中应该是单例的        JedisCluster cluster = new JedisCluster(nodes);        cluster.set("id", "100");        cluster.set("value", "Hello Jedis");        System.out.println(cluster.get("id"));        System.out.println(cluster.get("value"));                // 系统关闭时，关闭集群        cluster.close();    }}
     

三、在项目中，使用Spring集成Redis

1.redis.properties文件如下：

#Redis stand-alone configredis.single.host=192.168.25.153redis.single.port=6379#Redis cluster configredis.cluster.node1.host=192.168.25.153redis.cluster.node1.port=7001redis.cluster.node2.host=192.168.25.153redis.cluster.node2.port=7002redis.cluster.node3.host=192.168.25.153redis.cluster.node3.port=7003redis.cluster.node4.host=192.168.25.153redis.cluster.node4.port=7004redis.cluster.node5.host=192.168.25.153redis.cluster.node5.port=7005redis.cluster.node6.host=192.168.25.153redis.cluster.node6.port=7006

2.spring-redis配置文件如下：

默认放开的是单机版配置，如需使用集群版请注释上面单机版配置，并打开下面集群版配置。

3.接着我们编写一个JedisClient接口类

package com.hafiz.component;public interface JedisClient {        String set(String key, String value);    String get(String key);    Long del(String key);    Long hset(String key, String item, String value);    String hget(String key, String item);    Long hdel(String key, String... item);    Long incr(String key);    Long decr(String key);    Long expire(String key, int seconds);    Long ttl(String key);}

4.然后我们给出单机版的实现类：SingleJedisClient.java 

package com.hafiz.component.impl;import org.springframework.beans.factory.annotation.Autowired;import com.taotao.rest.component.JedisClient;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;/** * Redis单机客户端工具类 * @author Administrator */public class SingleJedisClient implements JedisClient {        @Autowired    private JedisPool jedisPool;    @Override    public String set(String key, String value) {        Jedis client = jedisPool.getResource();        String result = client.set(key, value);        client.close();        return result;    }    @Override    public String get(String key) {        Jedis client = jedisPool.getResource();        String result = client.get(key);        client.close();        return result;    }    @Override    public Long del(String key) {        Jedis client = jedisPool.getResource();        Long result = client.del(key);        client.close();        return result;    }    @Override    public Long hset(String key, String item, String value) {        Jedis client = jedisPool.getResource();        Long result = client.hset(key, item, value);        client.close();        return result;    }    @Override    public String hget(String key, String item) {        Jedis client = jedisPool.getResource();        String result = client.hget(key, item);        client.close();        return result;    }    @Override    public Long hdel(String key, String... item) {        Jedis client = jedisPool.getResource();        Long result = client.hdel(key, item);        client.close();        return result;    }    @Override    public Long incr(String key) {        Jedis client = jedisPool.getResource();        Long result = client.incr(key);        client.close();        return result;    }    @Override    public Long decr(String key) {        Jedis client = jedisPool.getResource();        Long result = client.decr(key);        client.close();        return result;    }    @Override    public Long expire(String key, int seconds) {        Jedis client = jedisPool.getResource();        Long result = client.expire(key, seconds);        client.close();        return result;    }    @Override    public Long ttl(String key) {        Jedis client = jedisPool.getResource();        Long result = client.ttl(key);        client.close();        return result;    }}

5.我们再提供集群版的实现类:ClusterJedisClient.java 

package com.hafiz.component.impl;import org.springframework.beans.factory.annotation.Autowired;import com.taotao.rest.component.JedisClient;import redis.clients.jedis.JedisCluster;/** * Redis集群客户端工具类 * @author Administrator */public class ClusterJedisClient 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 del(String key) {        return jedisCluster.del(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 hdel(String key, String... item) {        return jedisCluster.hdel(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 seconds) {        return jedisCluster.expire(key, seconds);    }    @Override    public Long ttl(String key) {        return jedisCluster.ttl(key);    }}

6.spring集成redis单元测试

package com.taotao.rest.test;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.taotao.rest.component.JedisClient;public class SpringJedisTest {        @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("cliet1", "1000");        String string = jedisClient.get("cliet1");        System.out.println(string);    }}

四、总结

　　通过本文我们对jedis的使用有了进一步的了解，知道了如何使用spring对redis进行集成，也对jedisClient做了单机以及集群的实现。很有成就感，未来走向架构师的路还有很远，继续努力吧！