使用Java客户端对Redis进行操作

一、背景

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

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

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

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.7.2</version>
</dependency>

  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<HostAndPort> 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 config
redis.single.host=192.168.25.153
redis.single.port=6379

#Redis cluster config
redis.cluster.node1.host=192.168.25.153
redis.cluster.node1.port=7001
redis.cluster.node2.host=192.168.25.153
redis.cluster.node2.port=7002
redis.cluster.node3.host=192.168.25.153
redis.cluster.node3.port=7003
redis.cluster.node4.host=192.168.25.153
redis.cluster.node4.port=7004
redis.cluster.node5.host=192.168.25.153
redis.cluster.node5.port=7005
redis.cluster.node6.host=192.168.25.153
redis.cluster.node6.port=7006

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

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
   http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"> <!-- Redis stand-alone config --> <bean id = "jedisPool" class = "redis.clients.jedis.JedisPool"> <constructor-arg name="host" value="${redis.single.host}"/> <constructor-arg name="port" value="${redis.single.port}"/> </bean> <bean id = "singleJedisClient" class = "com.taotao.rest.component.impl.SingleJedisClient"/> <!-- Redis cluster config --> <!-- <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster"> <constructor-arg name="nodes"> <set> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node1.host}"/> <constructor-arg name="port" value="${redis.cluster.node1.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node2.host}"/> <constructor-arg name="port" value="${redis.cluster.node2.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node3.host}"/> <constructor-arg name="port" value="${redis.cluster.node3.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node4.host}"/> <constructor-arg name="port" value="${redis.cluster.node4.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node5.host}"/> <constructor-arg name="port" value="${redis.cluster.node5.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node6.host}"/> <constructor-arg name="port" value="${redis.cluster.node6.port}"/> </bean> </set> </constructor-arg> </bean> <bean id="clusterJedisClient" class="com.hafiz.rest.component.impl.ClusterJedisClient"/> --> </beans>

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

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做了单机以及集群的实现。很有成就感,未来走向架构师的路还有很远,继续努力吧!

上一篇:Redis桌面客户端 Redis Studio


下一篇:redis进阶之路-手把手带你写redis客户端