轉：

【精】搭建redis cluster集群，JedisCluster帶密碼訪問【解決當中各種坑】！

2017年05月09日 00:13:18 冉椿林博客 閱讀數：18208

 版權聲明：本文為博主原創文章，轉載請看官大人注明出處： https://blog.csdn.net/localhost01/article/details/71436801

一.搭建redis單機

本文搭建redis3.0版本，3.0主要增加了redis cluster集群功能。

 

1.下載地址：http://download.redis.io/releases/redis-3.0.0.tar.gz，將下載文件拷貝到/usr/local

 

2.解壓源碼：tar -zxvf redis-3.0.0.tar.gz

 

3.編譯源碼：cd /usr/local/redis-3.0.0

make

 

4.安裝到指定目錄： cd /usr/local/redis-3.0.0 

make PREFIX=/usr/local/redis install

 

5.進入源碼目錄，將redis.conf拷貝到安裝路徑：cd /usr/local/redis

mkdir conf

cp /usr/local/redis-3.0.0/redis.conf  /usr/local/redis/bin

 

6.修改redis.conf配置文件，以后端模式啟動：daemonize yes

 

7.啟動redis：cd /usr/local/redis ./bin/redis-server ./redis.conf  //在何處啟動的server，一些配置文件就默認在該處生成（如果配置的相對路徑）

 

8.redis.conf配置文件主要配置：

port 7001  //監聽的端口

# bind 127.0.0.1  //綁定ip，只允許該ip訪問，不填默認為*，表示允許所有ip訪問

requirepass "你的密碼"  //開啟密碼

loglevel debug   //日志級別，開發模式盡量選用debug

logfile "redis.log"   //日志文件路徑，此處使用相對路徑，將生成到/usr/local/redis下

maxmemory 100000000  //允許最大內存占用100m

appendonly yes  //啟用aof

auto-aof-rewrite-percentage 80  //部署在同一機器的多個redis實例，建議把auto-aof-rewrite錯開（可分別寫80-100不等），防止瞬間fork，所有redis進程做rewrite,占用大量內存

 

9.jedis連接redis單機：

1. <dependency>
2. <groupId>redis.clients</groupId>
3. <artifactId>jedis</artifactId>
4. <version> 2.7.0</version>
5. </dependency>

1. 連接池整合spring：
2. <!-- redis連接池(單例) -->
3. <bean id= "jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="close">
4. <constructor-arg name= "poolConfig" ref="jedisPoolConfig"/>
5. <constructor-arg name= "host" value="${redis.host}"/>
6. <constructor-arg name= "port" value="${redis.port}"/>
7. <constructor-arg name= "timeout" value="${redis.timeout}"/>
8. <constructor-arg name= "password" value="${redis.pass}"/>
9. </bean>

1. <!-- 連接池配置 -->
2. <bean id= "jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
3. <!-- 最大連接數 -->
4. <property name= "maxTotal" value="150" />
5. <!-- 最大空閑連接數 -->
6. <property name= "maxIdle" value="30" />
7. <!-- 最小空閑連接數 -->
8. <property name= "minIdle" value="10" />
9. <!-- 獲取連接時的最大等待毫秒數,小於零:阻塞不確定的時間,默認- 1 -->
10. <property name= "maxWaitMillis" value="3000" />
11. <!-- 每次釋放連接的最大數目 -->
12. <property name= "numTestsPerEvictionRun" value="100" />
13. <!-- 釋放連接的掃描間隔（毫秒） -->
14. <property name= "timeBetweenEvictionRunsMillis" value="3000" />
15. <!-- 連接最小空閑時間 -->
16. <property name= "minEvictableIdleTimeMillis" value="1800000" />
17. <!-- 連接空閑多久后釋放, 當空閑時間>該值 且 空閑連接>最大空閑連接數 時直接釋放 -->
18. <property name= "softMinEvictableIdleTimeMillis" value="10000" />
19. <!-- 在獲取連接的時候檢查有效性, 默認 false -->
20. <property name= "testOnBorrow" value="true" />
21. <!-- 在空閑時檢查有效性, 默認 false -->
22. <property name= "testWhileIdle" value="true" />
23. <!-- 在歸還給pool時，是否提前進行validate操作 -->
24. <property name= "testOnReturn" value="true" />
25. <!-- 連接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 默認true -->
26. <property name= "blockWhenExhausted" value="false" />
27. </bean>

1. @RunWith(SpringJUnit4ClassRunner.class) // 指定測試用例的運行器 這里是指定了Junit4
2. @ContextConfiguration("classpath:spring/application*.xml")
3. public class RedisTest {
4. @Autowired
5. private JedisPool pool;
6. @Test
7. public void testJedisPool() {
8. Jedis jedis = null;
9. String name = null;
10. try {
11. jedis = pool.getResource();
12. jedis.set( "testName", "RCL");
13. name = jedis.get( "testName");
14. } catch (Exception ex) {
15. ex.printStackTrace();
16. } finally {
17. if (jedis != null) {
18. // 返回給池
19. jedis.close();
20. }
21. Assert.assertEquals( "RCL", name);
22. }
23. }

10.如果連接不上，可查看是否防火牆沒有將redis端口開放：/etc/sysconfig/iptables添加：

-A INPUT -p tcp -m state --state NEW -m tcp --dport 7001 -j ACCEPT //7001即redis端口

重啟防火牆

 

 

二、搭建redis集群

1.安裝ruby環境

集群管理工具redis-trib.rb依賴ruby環境

（1）安裝ruby：

yum install ruby yum install rubygems

（2）安裝ruby和redis的接口程序：

拷貝redis-3.0.0.gem至/usr/local。執行：gem install /usr/local/redis-3.0.0.gem

 

2.建立redis實例

（1）建立存放redis群的文件夾及子文件夾（用於存放每個redis實例）：

cd /usr/local    

mkdir redis-cluster 

mkdir redis-cluster/7001

mkdir redis-cluster/7002

……

（2）將剛剛安裝的單機redis的/usr/local/redis文件夾拷貝到每個700X文件夾下，（這里我們建立六個實例，三主三從）

（3）修改每個700X目錄下的redis.conf配置文件：

port 700X   //各自監聽的端口

#bind 127.0.0.1  //這里不綁定，默認允許所有ip訪問，或者bind 0.0.0.0

cluster-enabled yes   //開啟集群

cluster-node-timeout 15000   //15時間內沒有收到對方的回復,則單方面認為端節點掛掉

另外，由於下面我們需要配置集群密碼，故之前配置的 requirepass 先刪掉，集群成功后再進行配置。

 

3.啟動各個redis：分別進入7001、7002、...7006目錄，執行./redis-server ./redis.conf

 

4.創建集群：/usr/local/redis-cluster/redis-trib.rb create --replicas 1 123.123.123.123:7001 123.123.123.123:7002 123.123.123.123:7003 123.123.123.123:7004 123.123.123.123:7005 123.123.123.123:7006

注意：

（1）為保證遠程可訪問，這里的ip盡量使用公網ip，且創建集群時可先關閉防火牆，否則可以出現一直join……的現象。

（2）redis集群至少需要3個主節點，每個主節點有一個從節點總共6個節點

（3）replicas指定為1表示每個主節點有一個從節點

（4）如果出現[ERR] Sorry, can't connect to node錯誤：

1.ruby 和rubygem 版本太低，安裝新版本。查看gem版本和redis版本（redis-cli -v可查看redis版本）

2.查看reids配置文件，bind綁定的允許連接的ip是否正確。

3.是否redis配置文件還是使用了密碼，使用了密碼也可能導致這個錯誤。

（5）如果出現[ERR] Node 127.0.0.1:7005 is not empty. Either the node already knows other nodes (check with CLUSTER NODES) or contains some key in database 0：

表示集群時，之前的redis已有數據，那么登錄到7005的redis中，執行FLUSHALL即可

（6）如果出現ERR Slot 0 is already busy (Redis::CommandError)：

用redis-cli登錄到每個節點執行flushall和cluster reset即可2.6進入集群：./redis-cli -c  -p 7001 -h 123.123.123.123（-c即-cluster 表示進入集群模式，不加表示進入單機redis）

 

5.檢查集群是否成功：進入集群后，鍵入cluster info，顯示cluster_state:ok，表示成功

 

6.設置密碼：

（1）登錄到每個節點，執行 config set masterauth 你的密碼 config set requirepass 你的密碼

（2）隨后登入 7001/bin/redis-cli -c -h 112.74.55.239 -p 7004 -a 你的密碼，執行： config rewrite

（3）防火牆開放7001到7006端口，以及redis總線：17001到17006：

-A INPUT -p tcp -m state --state NEW -m tcp --dport 7001:7006 -j ACCEPT

-A INPUT -p tcp -m state --state NEW -m tcp --dport 17001:17006 -j ACCEPT

 

7.JedisCluster連接redis集群

1. <dependency>
2. <groupId>redis.clients</groupId>
3. <artifactId>jedis</artifactId>
4. <version> 2.9.0</version> //2.9.0才支持cluster密碼認證，之前版本的jedisCluster.auth("密碼")方法里面什么都沒有實現，僅僅拋一個JedisClusterException("No way to dispatch this command to Redis Cluster.")
5. </dependency>

1. 整合spring：
2. <!-- redis集群 -->
3. <bean id= "jedisCluster" class="redis.clients.jedis.JedisCluster">
4. <constructor-arg index= "0">
5. <set>
6. <bean class="redis.clients.jedis.HostAndPort">
7. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
8. <constructor-arg index= "1" value="${redis.port1}"></constructor-arg>
9. </bean>
10. <bean class="redis.clients.jedis.HostAndPort">
11. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
12. <constructor-arg index= "1" value="${redis.port2}"></constructor-arg>
13. </bean>
14. <bean class="redis.clients.jedis.HostAndPort">
15. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
16. <constructor-arg index= "1" value="${redis.port3}"></constructor-arg>
17. </bean>
18. <bean class="redis.clients.jedis.HostAndPort">
19. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
20. <constructor-arg index= "1" value="${redis.port4}"></constructor-arg>
21. </bean>
22. <bean class="redis.clients.jedis.HostAndPort">
23. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
24. <constructor-arg index= "1" value="${redis.port5}"></constructor-arg>
25. </bean>
26. <bean class="redis.clients.jedis.HostAndPort">
27. <constructor-arg index= "0" value="${redis.host}"></constructor-arg>
28. <constructor-arg index= "1" value="${redis.port6}"></constructor-arg>
29. </bean>
30. </set>
31. </constructor-arg>
32. <constructor-arg index= "1" value="${redis.timeout}"></constructor-arg>
33. <constructor-arg index= "2" value="${redis.sockettimeout}"></constructor-arg>
34. <constructor-arg index= "3" value="${redis.maxAttempts}"></constructor-arg>
35. <constructor-arg index= "4" value="${redis.pass}"></constructor-arg>
36. <constructor-arg index= "5" ref="jedisPoolConfig"></constructor-arg>
37. </bean>

1. @RunWith(SpringJUnit4ClassRunner.class)
2. @ContextConfiguration("classpath:spring/application*.xml")
3. public class RedisTest {
4. @Autowired
5. private JedisCluster jCluster;
6. @Test
7. public void testJCluster() {
8. jCluster.set( "name", "RCL");
9. String name = jCluster.get( "testName");
10. Assert.assertEquals( "RCL", name);
11. }