环境搭建

1.下载redis3.2.8压缩包，使用SFTP上传到linux服务器

2.解压文件

tar-zxf redis-3.2.8.tar.gz

3.安装c语言环境（安装ubnutu之后，自带c语言环境）

4.编译源码

 root@wang-virtual-machine:/home/wang# cd redis-3.2.8
 root@wang-virtual-machine:/home/wang/redis-3.2.8#  make

5.安装redis

root@wang-virtual-machine:/home/wang/redis-3.2.8# make install PEREFIX=/usr/local/myredis

6.检查是否安装成功

root@wang-virtual-machine:/home/wang/redis-3.2.8# cd /usr/local/myredis
root@wang-virtual-machine:/usr/local/myredis# ll

有bin目录证明安装成功

7.使用后端启动方式启动redis

7.1 将redis源码包中的redis.conf配置文件复制到/usr/local/redis/bin/下

root@wang-virtual-machine:/usr/local/myredis/bin#  cp /home/wang/redis-3.2.8/redis.conf ./

7.2 修改配置文件

root@wang-virtual-machine:/usr/local/myredis/bin# vim redis.conf

7.2.1 将daemonize 由no改为yes
7.2.2 将bind localhost(127.0.0.1) 注释掉 否则其他主机不能连接
7.2.3 将protected-mode 设置为no 默认为yes需要使用密码

8.执行启动命令

root@wang-virtual-machine:/usr/local/myredis/bin#  ./redis-server redis.conf

9.查看是否启动

root@wang-virtual-machine:/usr/local/myredis# ps -aux | grep redis

（*）表示所有此时是允许所有的ip连接登录到这台redis服务上，如果是localhost在windows下使用jedis无法连接到redis服务
10.关闭

root@wang-virtual-machine:/usr/local/myredis/bin#  ./redis-cli shutdown

jedis客户端

spring 配置文件中

<!--jedis配置 -->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大连接数 -->
        <property name="maxTotal" value="30" />
        <!-- 最大空闲数 -->
        <property name="maxIdle" value="10" />
        <!-- 每次释放连接的最大数目 -->
        <property name="numTestsPerEvictionRun" value="1024" />
        <!-- 释放连接的扫描间隔（毫秒） -->
        <property name="timeBetweenEvictionRunsMillis" value="30000" />
        <!-- 连接最小空闲时间 -->
        <property name="minEvictableIdleTimeMillis" value="1800000" />
        <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
        <property name="softMinEvictableIdleTimeMillis" value="10000" />
        <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
        <property name="maxWaitMillis" value="1500" />
        <!-- 在获取连接的时候检查有效性, 默认false -->
        <property name="testOnBorrow" value="false" />
        <!-- 在空闲时检查有效性, 默认false -->
        <property name="testWhileIdle" value="true" />
        <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
        <property name="blockWhenExhausted" value="false" />
    </bean>
    <!-- redis配置 -->
    <bean id="jedisPool" class="redis.clients.jedis.JedisPool"
        destroy-method="close">
        <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
        <constructor-arg name="host" value="192.168.140.128" />
        <constructor-arg name="port" value="6379" />
    </bean>

测试

public class JedisTest {

    @Test
    public void test() {
        String xmlPath = "classpath:spring/applicationContext.xml";
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(xmlPath);
        JedisPool pool = (JedisPool) context.getBean("jedisPool");

        Jedis jedis = null;

        try {
            jedis = pool.getResource();
            System.out.println(jedis);
            jedis.set("name", "lisi");
            String name = jedis.get("name");
            System.out.println(name);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {

            if (jedis != null)
                jedis.close();
        }

    }

}

集群搭建

redis-cluster架构图

架构细节:
(1)所有的redis节点彼此互联(PING-PONG机制),内部使用二进制协议优化传输速度和带宽.
(2)节点的fail是通过集群中超过半数的节点检测失效时才生效.
(3)客户端与redis节点直连,不需要中间proxy层.客户端不需要连接集群所有节点,连接集群中任何一个可用节点即可
(4)redis-cluster把所有的物理节点映射到[0-16383]slot上,cluster 负责维护node<->slot<->value
Redis 集群中内置了 16384 个哈希槽，当需要在 Redis 集群中放置一个 key-value 时，redis 先对 key 使用 crc16 算法算出一个结果，然后把结果对 16384 求余数，这样每个 key 都会对应一个编号在 0-16383 之间的哈希槽，redis 会根据节点数量大致均等的将哈希槽映射到不同的节点

redis-cluster投票:容错

(1)集群中所有master参与投票,如果半数以上master节点与其中一个master节点通信超过cluster-node-timeout（redis.conf中）,认为该master节点挂掉.
(2):什么时候整个集群不可用(cluster_state:fail)?

• 如果集群任意master挂掉,且当前master没有slave，则集群进入fail状态。也可以理解成集群的[0-16383]slot映射不完全时进入fail状态。（主从复制发生错误）
• 如果集群超过半数以上master挂掉，无论是否有slave，集群进入fail状态。

redis 集群环境搭建

集群管理工具（redis-trib.rb）是使用ruby脚本语言编写的。
1 . 安装ruby环境

apt-get update
apt-get install ruby
apt-get install rubygems

2.安装ruby和redis接口
将以redis-3.0.0.gem文件上传到linux系统

root@wang-virtual-machine:/home/wang# gem install redis-3.0.0.gem
Successfully installed redis-3.0.0
1 gem installed

3 . 在myredis下创建redis-cluster目录

root@wang-virtual-machine:/usr/local/myredis# mkdir redis-cluster

4 .将redis-3.2.8包下src目录中的集群管理工具文件文件拷贝到myredis/redis-cluster/

root@wang-virtual-machine:/home/wang/redis-3.2.8/src# ll *.rb
-rwxrwxr-x 1 wang wang 60852  2月 12 23:14 redis-trib.rb
root@wang-virtual-machine:/home/wang/redis-3.2.8/src#  cp redis-trib.rb /usr/local/myredis/redis-cluster

5 .查看是否拷贝成功

root@wang-virtual-machine:/usr/local/myredis/redis-cluster# ll
总用量 68
drwxr-xr-x 2 root root  4096  5月  9 17:52 ./
drwxr-xr-x 4 root root  4096  5月  9 17:43 ../
-rwxr-xr-x 1 root root 60852  5月  9 17:52 redis-trib.rb*

在主机上模拟搭建集群的过程

搭建集群最少也得需要3台主机，如果每台主机再配置一台从机的话，则最少需要6台机器。

1 .创建6个redis实例，需要端口号7001~7006复制一台主机

 root@wang-virtual-machine:/usr/local/myredis# cp bin ./redis-cluster/7001 -R

2 .存在持久化文件则删除

 rm -rf appendonly.aof dump.rdb

3 .设置集群参数

  root@wang-virtual-machine:/usr/local/myredis/redis-cluster# vim 7001/redis.conf
   cluster-enabled yes //开启集群
   port 7001           //端口

4 .复制出7002-7006的机器

 root@wang-virtual-machine:/usr/local/myredis/redis-cluster# cp 7001 ./7002 -R

5 .修改其他主机端口

6 .创建脚本启动所有主机

 root@wang-virtual-machine:/usr/local/myredis/redis-cluster# vim start-all.sh
cd 7001
./redis-server redis.conf
cd ..
cd 7002
./redis-server redis.conf
cd ..
cd 7003
./redis-server redis.conf
cd ..
cd 7004
./redis-server redis.conf
cd ..
cd 7005
./redis-server redis.conf
cd ..
cd 7006
./redis-server redis.conf
cd ..

7 . 修改start-all.sh文件的权限

  chmod u+x start-all.sh

8 .查看主机是否全部启动

     ps -aux | grep redis

9 . 创建集群

/redis-trib.rb create --replicas 1 192.168.140.129:7001 192.168.140.129:7002 192.168.140.129:7003 192.168.140.129:7004 192.168.140.129:7005  192.168.140.129:7006

10 .连接集群

root@wang-virtual-machine:/usr/local/myredis/redis-cluster/7001# ./redis-cli -h 192.168.140.129 -p 7001 -c

11 .查看集群信息

cluster info

12 .查看集群节点

cluster nodes

jedis连接

<!-- redis集群设置 -->
    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
        <constructor-arg index="0">
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7001"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7002"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7003"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7004"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7005"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.140.129"></constructor-arg>
                    <constructor-arg index="1" value="7006"></constructor-arg>
                </bean>

            </set>
        </constructor-arg>
        <constructor-arg index="1" ref="jedisPoolConfig">
        </constructor-arg>

    </bean>

测试

@Test
    public void test1() {
        JedisCluster cluster = (JedisCluster) context.getBean("jedisCluster");
        cluster.set("name", "zhangsan");
        String name = cluster.get("name");
        System.out.println(name);

    }