Jedis工具类、适配单个redis以及redis集群

真正的大师永远怀着一颗学徒的心
哈喽！大家好，我是小奇，一位程序员界的学徒

文章目录

• ​​一、Jedis工具类​​

• ​​1、定义接口​​
• ​​2、单例jedis实现类​​
• ​​3、Cluster集群jedis实现类​​
• ​​4、配置文件配置单例jedis​​
• ​​5、配置文件配置Cluster集群jedis​​

• ​​二、总结​​

一、Jedis工具类

1、定义接口

public interface JedisClient {

    String get(String key);
    String set(String key, String value);
    String hget(String hkey,String key);
    long hset(String hkey,String key,String value);
    long incr(String key);
    long expir(String key,int seconde);
    long ttl(String key);
}

2、单例jedis实现类

package com.taotao.rest.dao.impl;

import org.springframework.beans.factory.annotation.Autowired;

import com.taotao.rest.dao.JedisClient;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

public class JedisClientSingle implements JedisClient{

    @Autowired
    private JedisPool jedisPool;
    
    @Override
    public String get(String key) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.get(key);
        jedis.close();
        return string;
    }

    @Override
    public String set(String key, String value) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.set(key, value);
        jedis.close();
        return string;
    }

    @Override
    public String hget(String hkey, String key) {
        Jedis jedis = jedisPool.getResource();
        String string = jedis.hget(hkey, key);
        jedis.close();
        return string;
    }

    @Override
    public long hset(String hkey, String key, String value) {
        Jedis jedis = jedisPool.getResource();
        Long hset = jedis.hset(hkey, key, value);
        jedis.close();
        return hset;
    }

    @Override
    public long incr(String key) {
        Jedis jedis = jedisPool.getResource();
        Long incr = jedis.incr(key);
        jedis.close();
        return incr;
    }

    @Override
    public long expir(String key, int seconde) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.expire(key, seconde);
        jedis.close();
        return result;
    }

    @Override
    public long ttl(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.ttl(key);
        jedis.close();
        return result;
    }

}

3、Cluster集群jedis实现类

package com.taotao.rest.dao.impl;

import org.springframework.beans.factory.annotation.Autowired;

import com.taotao.rest.dao.JedisClient;

import redis.clients.jedis.JedisCluster;

public class JedisClientCluster implements JedisClient{

    @Autowired
    private JedisCluster jedisCluster;
    
    @Override
    public String get(String key) {
        return jedisCluster.get(key);
    }

    @Override
    public String set(String key, String value) {
        return jedisCluster.set(key, value);
    }

    @Override
    public String hget(String hkey, String key) {
        return jedisCluster.hget(hkey, key);
    }

    @Override
    public long hset(String hkey, String key, String value) {
        return jedisCluster.hset(hkey, key, value);
    }

    @Override
    public long incr(String key) {
        return jedisCluster.incr(key);
    }

    @Override
    public long expir(String key, int seconde) {
        return jedisCluster.expire(key, seconde);
    }

    @Override
    public long ttl(String key) {
        return jedisCluster.ttl(key);
    }

}

4、配置文件配置单例jedis

<bean id="jedisClient" class="com.taotao.rest.dao.impl.JedisClientSingle"/>

5、配置文件配置Cluster集群jedis

<bean id="jedisClientCluster" class="com.taotao.rest.dao.impl.JedisClientCluster"/>

二、总结

这里的相关内容还没有整理完毕，文章后面持续更新，建议收藏。

文章中涉及到的命令大家一定要像我一样每个都敲几遍，只有在敲的过程中才能发现自己对命令是否真正的掌握了。