分散式快取技術redis學習系列（七）——spring整合jediscluster
阿新 • • 發佈：2018-12-25
1、maven依賴
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.7.2</version>
</dependency>2、spring配置JedisCluster
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 3、redis.properties配置
#最大空閒數
redis.maxIdle=100
#最大連線數
redis.maxActive=300
#最大建立連線等待時間
redis.maxWait=1000
#客戶端超時時間單位是毫秒
redis.timeout=100000
redis.maxTotal=1000
redis.minIdle=8
#明是否在從池中取出連線前進行檢驗,如果檢驗失敗,則從池中去除連線並嘗試取出另一個
redis.testOnBorrow=true
#cluster
cluster1.host.port=119.254.166.136:7031
cluster2.host.port=119.254.166.136:7032
cluster3.host.port=119.254.166.136:7033
cluster4.host.port=119.254.166.136:7034
cluster5.host.port=119.254.166.136:7035
cluster6.host.port=119.254.166.136:7036
#cluster 4、JedisClusterFactory
public class JedisClusterFactory implements FactoryBean<JedisCluster>, InitializingBean {
private Resource addressConfig;
private String addressKeyPrefix ;
private JedisCluster jedisCluster;
private Integer timeout;
private Integer maxRedirections;
private GenericObjectPoolConfig genericObjectPoolConfig;
private Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");
@Override
public JedisCluster getObject() throws Exception {
return jedisCluster;
}
@Override
public Class<? extends JedisCluster> getObjectType() {
return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);
}
@Override
public boolean isSingleton() {
return true;
}
private Set<HostAndPort> parseHostAndPort() throws Exception {
try {
Properties prop = new Properties();
prop.load(this.addressConfig.getInputStream());
Set<HostAndPort> haps = new HashSet<HostAndPort>();
for (Object key : prop.keySet()) {
if (!((String) key).startsWith(addressKeyPrefix)) {
continue;
}
String val = (String) prop.get(key);
boolean isIpPort = p.matcher(val).matches();
if (!isIpPort) {
throw new IllegalArgumentException("ip 或 port 不合法");
}
String[] ipAndPort = val.split(":");
HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));
haps.add(hap);
}
return haps;
} catch (IllegalArgumentException ex) {
throw ex;
} catch (Exception ex) {
throw new Exception("解析 jedis 配置檔案失敗", ex);
}
}
@Override
public void afterPropertiesSet() throws Exception {
Set<HostAndPort> haps = this.parseHostAndPort();
jedisCluster = new JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);
}
public void setAddressConfig(Resource addressConfig) {
this.addressConfig = addressConfig;
}
public void setTimeout(int timeout) {
this.timeout = timeout;
}
public void setMaxRedirections(int maxRedirections) {
this.maxRedirections = maxRedirections;
}
public void setAddressKeyPrefix(String addressKeyPrefix) {
this.addressKeyPrefix = addressKeyPrefix;
}
public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {
this.genericObjectPoolConfig = genericObjectPoolConfig;
}
} 5、單元測試
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:spring-config.xml")
public class JedeisClusterTest {
@Autowired
private JedisCluster jedisCluster;
@Test
public void testJedisCluster(){
jedisCluster.set("name", "啊芝");
String val = jedisCluster.get("name");
System.out.println(val);
}
}6、問題總結
1)、redis.clients.jedis.exceptions.JedisClusterMaxRedirectionsException: Too many Cluster redirections?
2)、程式的歸程式，redis服務的歸redis服務
有的時候我們會提出這樣的問題，在單節點主從+哨兵配置或者多節點叢集+哨兵配置中，如果主掛了，哨兵自動進行主從替換，程式如何完成主從替換？
對於這樣的問題，始終要記住【程式的歸程式，redis服務的歸redis服務】
具體的理解是：比如程式連線配置了主伺服器的連線，但是此時主伺服器掛調，哨兵會將從伺服器變成主伺服器，但程式是不知道的，出現無法連線異常；重啟宕掉的服務，將作為從伺服器執行，預設不可寫，程式出現寫異常；雖然redis服務機制比較完善，但是程式並未做到響應變化
對於單節點主從來說，從節點主要作為災備服務來對待，主服務掛掉之後，用從服務同步的資料還原主服務資料。多節點叢集同理。
3)、JedisCluster管理叢集與ShardedJedisPool分片連線池實現分散式的區別
ShardedJedisPool是redis沒有叢集功能之前客戶端實現的一個數據分散式方案，redis3.0提供叢集之後，客戶端則採用JedisCluster實現連線redis叢集環境。
ShardedJedisPool使用的是JedisShardInfo的instance的順序或者name來做的一致性雜湊，JedisCluster使用的是CRC16演算法來做的雜湊槽。
redis cluster配置叢集與使用Jedis的ShardedJedis做Redis叢集的區別
4)、叢集環境，各個服務之間的資料是隔離的
無論是ShardedJedisPool的一致性雜湊演算法還是JedisCluster的CRC16雜湊槽演算法，都是把所有的服務疊加然後進行均勻的分割，分割出來的每一個段或槽都是不重複的，所以導致儲存的資料彼此之間也是處於隔離狀態的。
5)、jediscluster並不能實現客戶端程式高可用
如果叢集環境中，某一個master掛掉，交由jediscluster管理的叢集訪問程式，必然會出現異常，所以jediscluster並未實現叢集環境下的高可用，只是實現了分散式，只有重啟服務重新初始化新的叢集環境，程式方可正常執行。
詳細資訊可以檢視下一篇文章 分散式快取技術redis學習系列（八）——JedisCluster原始碼解讀：叢集初始化、slot(槽)的分配、值的存取