第Java實現(xiàn)Redis哨兵的示例代碼*如若發(fā)生異常,則主節(jié)點掛掉,需要做如下兩步:

*1)如果捕獲到了異常證明:

redis節(jié)點掛掉,我們需要將當(dāng)前主節(jié)點address保存到badRedisServers集合中

*2)調(diào)用changeMaster()方法，選舉從節(jié)點作為新的主

*/

privatestaticvoidcheckMaster(){

//主從切換

//檢查狀態(tài)

System.out.println("檢查master狀態(tài):"+masterAddress);

StringmasterHost=masterAddress.split(":")[0];

intmasterPort=Integer.parseInt(masterAddress.split(":")[1]);

try{

Jedisjedis=newJedis(masterHost,masterPort);

jedis.ping();

jedis.close();

}catch(Exceptione){

//master掛掉啦

badRedisServers.add(masterAddress);

//切換master

changeMaster();

}

}

/**

*切換master

*

*1)從slaveRedisServers集合中,獲取一個從節(jié)點地址

*2）通過地址創(chuàng)建jedis對象嘗試ping動作，驗證器是否在線

*3）沒發(fā)生異常，證明在線，我們需要禁用它從死掉master繼續(xù)同步數(shù)據(jù)

*4）修改屬性masterAddress為新選舉出來的slave地址

*5）如果發(fā)生異常，則將當(dāng)前slave存放在badRedisServers集合中,進(jìn)入下一次循環(huán)重試1-4動作

*6）選舉成功后，將當(dāng)前slave從slaveRedisServers集合中移除掉

*

*7）遍歷slaveRedisServers集合，將其他從節(jié)點主從復(fù)制配置更新到剛剛選舉出來的新主節(jié)點身上

*/

privatestaticvoidchangeMaster(){

IteratorStringiterator=slaveRedisServers.iterator();

while(iterator.hasNext()){

StringslaveAddress=iterator.next();

try{

StringslaveHost=slaveAddress.split(":")[0];

intslavePort=Integer.parseInt(slaveAddress.split(":")[1]);

Jedisjedis=newJedis(slaveHost,slavePort);

/*確保當(dāng)前從節(jié)點在線*/

jedis.ping();

/*禁用當(dāng)前從節(jié)點同步復(fù)制*/

jedis.slaveofNoOne();

jedis.close();

masterAddress=slaveAddress;

System.out.println("產(chǎn)生新的master:"+masterAddress);

break;

}catch(Exceptione){

badRedisServers.add(slaveAddress);

}finally{

iterator.remove();

}

}

//所有slave切到新的master

for(Stringslave:slaveRedisServers){

StringslaveHost=slave.split(":")[0];

intslavePort=Integer.parseInt(slave.split(":")[1]);

Jedisjedis=newJedis(slaveHost,slavePort);

jedis.slaveof(masterAddress.split(":")[0],Integer.parseInt(masterAddress.split(":")[1]));

jedis.close();

}

}

/**

*更新當(dāng)前所有從節(jié)點到slaveRedisServers中

*

*1）根據(jù)masterAddress創(chuàng)建主節(jié)點Jedis對象

*2）獲取主節(jié)點replication配置信息("replication");

*3）根據(jù)配置信息,獲取到當(dāng)前主節(jié)點從節(jié)點個數(shù)

*4）循環(huán)遍歷從節(jié)點個數(shù),如果個數(shù)大于0,則清空當(dāng)前slaveRedisServers集合

*5）從配置信息中截取出所有從節(jié)點的ip:端口后，放入到slaveRedisServers集合中

*

*/

privatestaticvoidupdateSlaves(){

//獲取所有slave

try{

StringmasterHost=masterAddress.split(":")[0];

intmasterPort=Integer.parseInt(masterAddress.split(":")[1]);

Jedisjedis=newJedis(masterHost,masterPort);

Stringinfo_replication=("replication");

//解析inforeplication

String[]lines=info_replication.split("\r\n");

intslaveCount=Integer.parseInt(lines[2].split(":")[1]);

if(slaveCount0){

slaveRedisServers.clear();

for(inti=0;islaveCount;i++){

Stringhost=lines[3+i].split(",")[0].split("=")[1];

Stringport=lines[3+i].split(",")[1].split("=")[1];

slaveRedisServers.add(host+":"+port);

}

}

System.out.println("更新slave列表:"+Arrays.toString(slaveRedisServers.toArra