Jedis的多种使用方式

﹏ヽ暗。殇╰゛Y 2022-06-13 10:54 212阅读 0赞

**Jedis是Redis的Java版本的客户端实现。**  
通过一段时间的使用，jedis基本实现Redis的所有功能，并且Jedis在客户端实现Redis数据分片功能，jedis也实现了Redis本身的数据集群分片功能。  
1. 下载jedis 代码  
2. 项目中如何使用Jedis使用  
3. 建立一个简单的连接  
4. 建立Jedis连接池  
5. Jedis 客户端实现分片  
6. Jedis实现Redis Cluster集群使用

**1. 下载jedis 代码**  
jedis 开源代码地址：[https://github.com/xetorthio/jedis][https_github.com_xetorthio_jedis]

**2. 项目中如何使用Jedis使用**  
一般都使用maven作为项目管理工具，Maven下配置只需要添加以下依赖就可以

<dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
        <type>jar</type>
        <scope>compile</scope>
    </dependency>

**3. 建立一个简单的连接**  
创建一个简单Jedis对象，只需要告诉它的IP地址和端口号就可以，如果redis有密码，那需要在建立连接时，需要调用auth方法设置密码。  
生产环境使用一般都有连接池支持。

public class JedisUtil {
    
        public static Jedis createJedis() {
            Jedis jedis = new Jedis("127.0.0.1");
            return jedis;
        }
    
        public static Jedis createJedis(String host, int port) {
            Jedis jedis = new Jedis(host, port);
            return jedis;
        }
    
        public static Jedis createJedis(String host, int port, String passwrod) {
            Jedis jedis = new Jedis(host, port);
            if (!StringUtils.isNotBlank(passwrod))
                jedis.auth(passwrod);
            return jedis;
        }

**4. 建立Jedis连接池**  
创建连接jedis 连接池，jedis 提供JedisPool对象，使用比较方便。jedis pool 是基于apache common pool 实现。

import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class JedisPoolUtils { 
    
        private static JedisPool pool;
    
     /** * 建立连接池，一般把配置参数缺抽取出来。 * */
        private static void createJedisPool() {
    
            // 建立连接池配置参数
            JedisPoolConfig config = new JedisPoolConfig();
    
            // 设置最大连接数
            config.setMaxActive(100);
    
            // 设置最大阻塞时间，记住是毫秒数milliseconds
            config.setMaxWait(1000);
    
            // 设置空间连接
            config.setMaxIdle(10);
    
            // 创建连接池
            pool = new JedisPool(config, "127.0.0.1", 6379);
    
        }
    
     /** * 在多线程环境同步初始化 */
        private static synchronized void poolInit() {
            if (pool == null)
                createJedisPool();
        }
    
     /** * 获取一个jedis 对象 * * @return */
        public static Jedis getJedis() {
    
            if (pool == null)
                poolInit();
            return pool.getResource();
        }
    
     /** * 归还一个连接 * * @param jedis */
        public static void returnRes(Jedis jedis) {
            pool.returnResource(jedis);
        }
    
    }

**5. Jedis 客户端实现分片**  
Jedis分片采用Hash算法和基于的Key模式匹配。Jedis定义一个Hash接口，如果觉得自带的不爽，可以自己实现一个Hash算法。Jedis自带的Hash的算法是MurmurHash 2.0 。  
MurmurHash算法：高运算性能，低碰撞率，由Austin Appleby创建于2008年，现已应用到Hadoop、libstdc++、nginx、libmemcached等开源系统。2011年Appleby被Google雇佣，随后Google推出其变种的CityHash算法。  
官方网站：[https://sites.google.com/site/murmurhash/][https_sites.google.com_site_murmurhash]  
MurmurHash算法，自称超级快的hash算法，是FNV的4-5倍。

/** * 创建分片对象 * @return */
        public static ShardedJedis createShardJedis() {
    
            //建立服务器列表
            List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
    
            //添加第一台服务器信息
            JedisShardInfo si = new JedisShardInfo("localhost", 6379);
            si.setPassword("123");
            shards.add(si);
    
            //添加第二台服务器信息
            si = new JedisShardInfo("localhost", 6399);
            si.setPassword("123");
            shards.add(si);
            //建立分片连接对象
            ShardedJedis jedis = new ShardedJedis(shards);        
    
            //建立分片连接对象,并指定Hash算法
            //ShardedJedis jedis = new ShardedJedis(shards,selfHash);
            return jedis;
        }

分片也可以支持连接池，具体如下：

private static void createPool() {
            List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
            JedisShardInfo si = new JedisShardInfo("localhost", 6379);
            si.setPassword("123");
            shards.add(si);
            si = new JedisShardInfo("localhost", 6399);
            si.setPassword("123");
            shards.add(si);
            pool = new ShardedJedisPool(new JedisPoolConfig(), shards);
        }

**6. Jedis实现Redis Cluster集群使用**

Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
    //Jedis Cluster will attempt to discover cluster nodes automatically
    jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7379));
    JedisCluster jc = new JedisCluster(jedisClusterNodes);
    jc.set("foo", "bar");
    String value = jc.get("foo");

[https_github.com_xetorthio_jedis]: https://github.com/xetorthio/jedis
[https_sites.google.com_site_murmurhash]: https://sites.google.com/site/murmurhash/