Redis 3.0入门二之集群搭建和使用

上一篇文章讲了redis的主从搭建，主从一般只能解决我们读写分离的问题，可以增加我们的系统的负载能力，但是并不能解决单点问题，大家应该知道在互联网公司各个服务肯定不能出现单点问题，所以这一节就记录一下如果让我们的系统更加高可用。

一、集群搭建

需要先说明的是，集群搭建需要至少6个节点：3主3从(因为没有那么多机器，所以就在一台上搞了)

1. 创建文件夹redis-cluster，然后在其下面分别创建6个文件夹，存放6个实例

mkdir -p /usr/local/redis-cluster
mkdir 7001;mkdir 7002;mkdir 7003;mkdir 7004;mkdir 7005;mkdir 7006

2. 把之前redis.conf配置文件分别copy到700*下，修改各个实例的配置文件的内容，如下：

①. daemonize yes
②. port 700*（一台机器端口号肯定不能相同，就和文件夹一样吧）
③. bind ip（和当前机器的ip地址绑定）
④. dir /usr/local/redis-cluster/700*/（文件存储位置应该不一样吧，原因都知道）
⑤. cluster-enabled yes
⑥. cluster-config-flie nodes-700*.conf（700*就和端口一样吧）
⑦. cluster-node-timeout 5000
⑧. appendonly yes

3. 安装ruby

yum install ruby
yum install rubygems
gem install redis

4. 启动各个实例

/usr/local/redis/bin/redis-server /usr/local/redis-cluster/700*/redis.conf

5. 创建集群

cd /usr/local/redis-3.0.0-rc2/src
./redis-trib.rb create -replicas 1 ip:7001 ip:7002 ip:7003 ip:7004 ip:7005 ip:7006

然后看输出日志，会有一步需要输入yes，然后集群就创建完成了

6. 验证，连接任意一个客户端即可

/usr/local/redis/bin/redis-cli -c -h -p （-c表示集群模式，指定ip和端口）

然后可以输入一些命令

cluster info
cluster nodes

关闭集群时候要逐个进行关闭，命令就不贴了

7. 补充资料

友情提示，如果其群无法启动，可以删除临时的数据文件，再次重启每一个redis服务，然后重新构造集群环境

redis-trib.rb官方操作命令：http://redis.io/topics/cluster-tutorial 推荐博客：http://blog.51yip.com/nosql/1726.html/comment-page-1 redis-cli客户端命令：http://blog.csdn.net/qachenzude/article/details/32098777

二、集群使用

1. pom

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

2. 使用junit测试

package cn.bridgeli.msg.push.jedis;

import java.util.HashSet;
import java.util.Set;

import org.junit.Test;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

public class JedisClusterTest {

  @Test
  public void testJedisCluster() {
    Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
    jedisClusterNodes.add(new HostAndPort("ip", 7001));
    jedisClusterNodes.add(new HostAndPort("ip", 7002));
    jedisClusterNodes.add(new HostAndPort("ip", 7003));
    jedisClusterNodes.add(new HostAndPort("ip", 7004));
    jedisClusterNodes.add(new HostAndPort("ip", 7005));
    jedisClusterNodes.add(new HostAndPort("ip", 7006));

    JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    jedisPoolConfig.setMaxTotal(100);
    jedisPoolConfig.setMaxIdle(20);
    jedisPoolConfig.setMaxWaitMillis(-1);
    jedisPoolConfig.setTestOnBorrow(true);

    JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes, 5000, 1000, jedisPoolConfig);

    System.out.println(jedisCluster.set("name", "bridgeli"));
    System.out.println(jedisCluster.get("name"));
  }
}

3. 和spring整合

...

<context:property-placeholder location="classpath:jedis.properties" />
<context:component-scan base-package="cn.bridgeli" />
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
  <property name="maxTotal" value="${redis.maxTotal}"></property>
  <property name="maxIdle" value="${redis.maxIdle}"></property>
  <property name="maxWaitMillis" value="${redis.maxWaitMillis}"></property>
  <property name="testOnBorrow" value="${redis.testOnBorrow}"></property>
</bean>

<bean id="hostAndPort1" class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="..."></constructor-arg>
<constructor-arg name="port" value="..."></constructor-arg>
</bean>
<bean id="hostAndPort2" class="redis.clients.jedis.HostAndPort">
  <constructor-arg name="host" value="..."></constructor-arg>
  <constructor-arg name="port" value="..."></constructor-arg>
</bean>
<bean id="hostAndPort3" class="redis.clients.jedis.HostAndPort">
  <constructor-arg name="host" value="..."></constructor-arg>
  <constructor-arg name="port" value="..."></constructor-arg>
</bean>
<bean id="hostAndPort4" class="redis.clients.jedis.HostAndPort">
  <constructor-arg name="host" value="..."></constructor-arg>
  <constructor-arg name="port" value="..."></constructor-arg>
</bean>
<bean id="hostAndPort5" class="redis.clients.jedis.HostAndPort">
  <constructor-arg name="host" value="..."></constructor-arg>
  <constructor-arg name="port" value="..."></constructor-arg>
</bean>
<bean id="hostAndPort6" class="redis.clients.jedis.HostAndPort">
  <constructor-arg name="host" value="..."></constructor-arg>
  <constructor-arg name="port" value="..."></constructor-arg>
</bean>

<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
  <constructor-arg name="nodes">
    <set>
      <ref bean="hostAndPort1"/>
      <ref bean="hostAndPort2"/>
      <ref bean="hostAndPort3"/>
      <ref bean="hostAndPort4"/>
      <ref bean="hostAndPort5"/>
      <ref bean="hostAndPort6"/>
    </set>
  </constructor-arg>
  <constructor-arg name="timeout" value="5000"></constructor-arg>
  <constructor-arg name="poolConfig">
    <ref bean="jedisPoolConfig"/>
  </constructor-arg>
</bean>

...

至此，我们如何搭建redis主从、集群以及如何使用都应该可以完成了，最后我们发现这些其实并不难，关键是实践