Jedis源码分析（四）-JedisSentinel与ShardedJedis介绍「建议收藏」

全栈程序员-用户IM • 2022年4月3日上午10:00 • 未分类

大家好，又见面了，我是你们的朋友全栈君。

Jedis源码分析共有四个章节，以下为各章链接：

1 JedisSentinel

JedisSentinel常用方式有两种：

1.使用哨兵单节点拿到主节点，从节点的信息

//通过哨兵节点的信息新建Jedis实例，然后拿到Master节点的信息
Jedis j = new Jedis(sentinel);
List<Map<String, String>> masters = j.sentinelMasters();
//拿到master的address，**MASTER_NAME**
List<String> masterHostAndPort = j.sentinelGetMasterAddrByName(**MASTER_NAME**);
HostAndPort masterFromSentinel = new HostAndPort(masterHostAndPort.get(0),Integer.parseInt(masterHostAndPort.get(1)));
assertEquals(master, masterFromSentinel);
//通过哨兵节点，拿到从节点的信息
List<Map<String, String>> slaves = j.sentinelSlaves(**MASTER_NAME**);

2.使用哨兵节点对象池

Set<String> sentinels = new HashSet<String>();
sentinels.add(new HostAndPort("localhost", 65432).toString());
sentinels.add(new HostAndPort("localhost", 65431).toString());
JedisSentinelPool pool = new JedisSentinelPool(MASTER_NAME, sentinels);
pool.destroy();

JedisSentinelPool的结构清晰，内部使用对象池存放一个个sentinel实例。图2-12和2-13分别为JedisSentinelPool的类结构和初始化流程。在使用时，我们先根据，host,port等信息，初始化一个Jedis实例，然后可以通过sentinelMasters()，sentinelGetMasterAddrByName(MASTER_NAME)，sentinelSlaves(MASTER_NAME)等方法拿到这个哨兵节点监听的MASTER节点信息或对应的SLAVE节点信息。

图片描述

图1.1 JedisSentinelPool 的类结构

图片描述

图1.2 JedisSentinelPool 的初始化流程

2 ShardedJedis

下文为构建Jedis分片的方法（单节点与对象池的模式），

单节点模式

List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(2);
//其中一个分片
JedisShardInfo shard1 = new JedisShardInfo(redis1);
shards.add(shard1);
//另一个分片
JedisShardInfo shard2 = new JedisShardInfo(redis2);
shards.add(shard2);
@SuppressWarnings("resource")
//新建ShardedJedis实例
ShardedJedis shardedJedis = new ShardedJedis(shards);
shardedJedis.set("a", "bar");
//通过key可以查看存储在哪个jedis
JedisShardInfo ak = shardedJedis.getShardInfo("a");
assertEquals(shard2, ak);

对象池模式

ShardedJedisPool pool = new ShardedJedisPool(new GenericObjectPoolConfig(), shards);
ShardedJedis jedis = pool.getResource();
jedis.set("foo", "bar");
assertEquals("bar", jedis.get("foo"));

图片描述
图2-1 ShardedJedis的类结构