序言

前段時間項目需要把memcache 更換成redis，花了兩天研究了一下redis的集群防泵，網(wǎng)上的資料很多已經(jīng)過期了脱盲，參差不齊，在這里整理了一下做個記錄

一每界、開發(fā)環(huán)境

• 1.win7
• 2.redis 3.0 64位
• 3.ruby 環(huán)境
  **測試用到的所有安裝包及我的測試配置 **http://pan.baidu.com/s/1qXmO3fQ

redis 安裝

    Redis對于Linux是官方支持的,安裝和使用沒有什么好說的,普通使用按照官方指導(dǎo)捅僵，5分鐘以內(nèi)就能搞定。詳情請參考:[http://redis.io/download](http://redis.io/download) 

   Redis官方是不支持windows的眨层，只是 Microsoft Open Tech group 在 GitHub上開發(fā)了一個Win64的版本,官方說明：  

Win64 Unofficial The Redis project does not directly support
Windows, however the Microsoft Open Tech group develops and maintains an Windows port targeting Win64.

 項目地址：https://github.com/MSOpenTech/redis 

打開以后庙楚，可以直接使用瀏覽器下載，或者git克隆趴樱。在release頁面可以下載需要的redis包

Image.png

下載解壓馒闷，沒什么好說的，在解壓后的bin目錄下有以下這些文件：

redis-benchmark.exe #基準(zhǔn)測試
redis-check-aof.exe # aof
redis-check-dump.exe # dump
redis-cli.exe # 客戶端
redis-server.exe # 服務(wù)器
redis.windows.conf # 配置文件

ruby環(huán)境準(zhǔn)備

下載 64位的 RubyInstaller并安裝 地址http://rubyinstaller.org/downloads/
勾選下面三個不用配置環(huán)境變量

Image.png

安裝RubyGems

下載下來是一個壓縮包叁征，解壓運(yùn)行里面的 setup.rb 安裝 rubyGems
由于墻的原因ruby自帶的源有時候很慢纳账，我們換成淘寶的源，不然下面安裝redis依賴會失斵嗵邸＼（－－）／

在cmd下運(yùn)行

gem sources --remove https://rubygems.org/ 刪掉原來的源
gem sources -a http://ruby.taobao.org 添加淘寶源
gem sources -l 查看現(xiàn)有的源
gem install redis 安裝redis依賴

二 疏虫、使用redis cluster

按照文檔的說明步驟來做就行了，詳情在這 http://doc.redisfans.com/topic/cluster-tutorial.html#id5

要讓集群正常運(yùn)作至少需要三個主節(jié)點啤呼，因此我們創(chuàng)建6個節(jié)點卧秘，三個主節(jié)點三個從節(jié)點，詳細(xì)請查看文檔官扣，我簡化一下文檔的步驟即：

1.創(chuàng)建 6個文件夾分別為 7000-7005
這里就是做集群時各個機(jī)器所安裝的redis翅敌，在每個文件夾放一份下載下來的redis，例如

Image.png

2.創(chuàng)建配置文件 redis.conf
其他幾個7000-7004文件夾以此類推惕蹄，注意修改對應(yīng)的端口號

port 7005
cluster-enabled yes
cluster-config-file nodes.conf
cluster-node-timeout 5000
appendonly yes

文件中的
cluster-enabled 選項用于開實例的集群模式哼御，
cluster-conf-file 選項則設(shè)定了保存節(jié)點配置文件的路徑坯临， 默認(rèn)值為nodes.conf 。
nodes.conf 節(jié)點配置文件無須人為修改恋昼， 它由 Redis 集群在啟動時創(chuàng)建看靠， 并在有需要時自動進(jìn)行更新。

3.創(chuàng)建啟動腳本7005.bat
這樣不用總是敲命令 ,名字隨意改液肌，其他幾個文件夾同理

@echo off
redis-server.exe redis.conf
@pause

4.創(chuàng)建集群

• 1.按照上面所說的配置好各個實例挟炬，主要是改端口號，運(yùn)行 7000.bat- 7005.bat腳本啟動六個redis實例

• 2.cd到 redis-trib.rb 所在的目錄下運(yùn)行命令
  redis-trib.rb create --replicas 1 127.0.0.1:7000 127.0.0.1:7001 127.0.0.1:7002 127.0.0.1:7003 127.0.0.1:7004 127.0.0.1:7005

Image.png

打印出配置信息嗦哆，現(xiàn)在的master是 7000 7001 7002這三臺機(jī)谤祖，redis會對key 做 CRC16 校驗和后分別存儲這三臺機(jī)上。沒問題就輸入 yes

例如 7000 這臺機(jī) slots:0-5460 的意思是：

對key 做 CRC16 校驗和后 值在 0-5460范圍內(nèi)都會存到這臺機(jī)器里
例如 key=288 對應(yīng)的CRC16校驗和 為 4258老速，應(yīng)該存在7000這臺機(jī)里

PS：使用前應(yīng)該對業(yè)務(wù)做梳理粥喜，根據(jù)系統(tǒng)中key的特點來調(diào)整各個機(jī)器的slots范圍，
不然系統(tǒng)的key基本集中在一兩臺機(jī)器上集群的效果就不大了

redis-trib.rb文件在下載下來的redis包里可能是沒有的橘券，可以到
https://github.com/antirez/redis/tree/unstable/src 目錄下下載
之前的ruby環(huán)境就是為運(yùn)行這個文件做準(zhǔn)備的

命令的意義如下：

redis-trib.rb
create额湘， 這表示我們希望創(chuàng)建一個新的集群。
選項 --replicas 1 表示我們希望為集群中的每個主節(jié)點創(chuàng)建一個從節(jié)點旁舰。
之后跟著的其他參數(shù)則是實例的地址列表锋华， 我們希望程序使用這些地址所指示的實例來創(chuàng)建新集群。

簡單來說箭窜， 以上命令的意思就是讓 redis-trib 程序創(chuàng)建一個包含三個主節(jié)點和三個從節(jié)點的集群毯焕。

看看node.conf文件里生成了什么

Paste_Image.png

里面記錄了master 和 slave的對應(yīng)關(guān)系，例如圖片里的 7000是master 而對應(yīng)的 slave是7003這臺機(jī)磺樱，綠色的一長串?dāng)?shù)字是對應(yīng)機(jī)器的Id纳猫，redis以此來標(biāo)記一臺機(jī)器。

三竹捉、Jedis編程使用集群

github地址 https://github.com/xetorthio/jedis
按上面兩步配置好续担，創(chuàng)建并啟動集群。測試代碼如下：

添加Jedis依賴

  <dependency>
          <groupId>org.apache.commons</groupId>
          <artifactId>commons-pool2</artifactId>
          <version>2.4.2</version>
    </dependency>

    <dependency>
         <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
          <version>2.7.3</version>
    </dependency>

測試代碼：

@Test
public  void cluster(){
    String key = "1417";
    Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
    jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7000));   
    JedisCluster jc = new JedisCluster(jedisClusterNodes);

    jc.setnx(key, "bar");
    String value = jc.get(key);
    System.out.println("key-"+key+" slot-"+JedisClusterCRC16.getSlot(key)+" value-"+value);

    String key2 = "288";
    jc.setnx(key2, "bar2");
    String value2 = jc.get(key);
    System.out.println("key-"+key2+" slot-"+JedisClusterCRC16.getSlot(key2)+" value-"+value2);
}

Image.png

github上有這一句活孩，Jedis Cluster 會自動去發(fā)現(xiàn)集群中的節(jié)點物遇，所以JedisClusterNodes只需要 add一個實例

運(yùn)行得到結(jié)果

Image.png

接下來用redis客戶端看看這兩個key=1417 、key=288的值存到哪個節(jié)點下
看回最初的配置

Image.png

key=288算出來的 CRC16校驗和是 4258憾儒，根據(jù)配置 應(yīng)該存在 7000這臺機(jī)上
key=1417 算出來的 CRC16校驗和是 13096询兴，根據(jù)配置 應(yīng)該存在 7002 這臺機(jī)上

用redis 客戶端查看數(shù)據(jù)存到哪臺機(jī)器上

Image.png

進(jìn)去7000這臺機(jī)上
get 288拿到了value bar2
get 1417 得到提示讓去 7002這臺機(jī)查

從redis客戶端看到的結(jié)果與配置一致

四、簡單集成Spring

JedisFactory類
傳入host 起趾、port 和JedisPoolConfig 類

package your path;
import java.util.HashSet;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

/**
 * <p>Title: JedisClusterFactory.java<／p>
 * <p>Description: <／p>
 * @author qiaowei liu
 * @date 2016-1-14
 * @version 1.0
 */
public class JedisClusterFactory {

/** 
 * @Description 
 * @author qiaowei liu
 * @date 2016-1-14 上午11:00:18 
 * @param args
 */

private JedisCluster jedisCluster;

public JedisCluster getJedisCluster() {
    return jedisCluster;
}

public JedisClusterFactory(JedisPoolConfig jedisPoolConfig,String host,int port){   
    Set<HostAndPort> jedisClusterNodes= new HashSet<HostAndPort>();
    //Jedis Cluster will attempt to discover cluster nodes automatically
    jedisClusterNodes.add(new HostAndPort(host,port));
    jedisCluster=new JedisCluster(jedisClusterNodes,jedisPoolConfig);
}
}

JedisProvide.java工具類诗舰，主要是封裝些常用的操作

package your path;
import your path.CacheSecondLevel;
import redis.clients.jedis.JedisCluster;

/**
 * <p>Title: RedisProvide.java<／p>
 * <p>Description: <／p>
 * @author qiaowei liu
 * @date 2016-1-8
 * @version 1.0
 */
public class RedisProvide implements CacheSecondLevel {

private JedisCluster jedisCluster;

public RedisProvide(JedisClusterFactory jedisClusterFactory){
       jedisCluster=jedisClusterFactory.getJedisCluster();
}

@Override
public Object get(String key){
    return jedisCluster.get(key);       
}

@Override
public Object[] gets(String[] keys) {
    // TODO Auto-generated method stub
    return null;
}

@Override
public void set(String key, Object obj) {
    // TODO Auto-generated method stub
    jedisCluster.set(key, obj.toString());
}

@Override
public void delete(String key) {
    // TODO Auto-generated method stub
    jedisCluster.del(key);
}
}

applicationContext.xml配置

     <!--==================== redis配置 start ====================-->         
 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">    
    <property name="maxTotal"  value="${redis.maxTotal}" /> 
    <property name="maxIdle" value="${redis.maxIdle}" /> 
    <property name="timeBetweenEvictionRunsMillis" value="${redis.timeBetweenEvictionRunsMillis}" />
    <property name="minEvictableIdleTimeMillis" value="${redis.minEvictableIdleTimeMillis}" />
    <property name="testOnBorrow" value="${redis.testOnBorrow}" />
 </bean>

 <bean id="jedisClusterFactory" class="xxx.xxx.JedisClusterFactory" > 
    <constructor-arg  ref ="jedisPoolConfig"/>
    <constructor-arg  name="host" value="${redis.host}"/>
    <constructor-arg  name="port" value="${redis.port}"/>           
 </bean>
            
 <bean id="redisProvide" class="xxx.xxx.RedisProvide">
    <constructor-arg  ref ="jedisClusterFactory" />
 </bean>
       
<!--==================== redis配置 end ====================-->

conf/perproties

#redis config
redis.host=127.0.0.1
redis.port=7000
redis.timeout=100000
redis.maxIdle=300
redis.maxTotal=600 
redis.timeBetweenEvictionRunsMillis=30000  
redis.minEvictableIdleTimeMillis=30000 
redis.testOnBorrow=true

參考資料

redis安裝
參考 http://blog.csdn.net/renfufei/article/details/38474435

redis集群
http://doc.redisfans.com/topic/cluster-tutorial.html#id5

redis命令參考
http://doc.redisfans.com/