首页 / 数据库 / MySQL / Redis主从复制和主从切换

Redis的主从复制功能可以实现读写分离，一个主可以挂载多个从．从服务器只能实现读不可写．当主服务器挂掉之后，无法切换到从服务器写． 通过Redis的Sentinel可以实现主从切换：当主服务器挂掉之后，自动将其中一个从服务器升级为主服务器。

• 配置主从复制

1. 建立从文件夹，譬如 /usr/local/slaves/下建立 6380 6381 两个文件夹（两个从服务器）
2. 复制redis.conf到刚建立的两个文件夹中
3. 修改redis.conf 中的
1. port 6380
2. slaveof 127.0.0.1 6379  ------ip表示主服务器的ｉｐ 端口表示主服务器端口
3. 保存退出，另一个从服务器做同样修改，如果端口不是6380，修改断开即可，此处修改为6381
4. 启动主服务器 redis-server redis.conf
5. 进入从服务器文件夹，启动从服务器
6. 查看主服务器信息：redis-cli -p 6379 info Replication,可以看到有两个从服务器
7. redis-cli -p 6379 进去主服务器，存储数据 set key val
8. 进入从服务器，redis-cli -p 6380 查看数据 get key 查看是否能取出数据

• 配置主从切换

1. 新建三个文件 6379-sentinel.conf 6380-sentinel.conf 6381-sentinel.conf
2. 编辑文件
3.  

   1234567891011121314151617

   ####master  sentinel.conf##sentinel实例之间的通讯端口port 26379####sentinel需要监控的master信息：<mastername> <masterIP> <masterPort> <quorum>.####<quorum>应该小于集群中slave的个数,只有当至少<quorum>个sentinel实例提交"master失效" 才会认为master为ODWON（"客观"失效） .sentinel monitor mymaster 127.0.0.1 6381 2####授权密码，在安全的环境中可以不设置##sentinel auth-pass mymaster luyx30####master被当前sentinel实例认定为“失效”（SDOWN）的间隔时间sentinel failover-timeout mymaster 900000####当新master产生时，同时进行“slaveof”到新master并进行同步复制的slave个数。##在salve执行salveof与同步时，将会终止客户端请求。##此值较大，意味着“集群”终止客户端请求的时间总和和较大。##此值较小,意味着“集群”在故障转移期间，多个salve向客户端提供服务时仍然使用旧数据。sentinel config-epoch mymaster 4####failover过期时间，当failover开始后，在此时间内仍然没有触发任何failover操作，当前sentinel将会认为此次failoer失败。sentinel leader-epoch mymaster 4

4. 其他两个文件只需要修改端口即可
5. 分别启动文件:redis-sentinel 6379-sentinel

• 通过java读写主从服务器

1. 需要添加Spring配置和其他两个ｊａｒ包

2. 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495

   <properties>    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>    <springVersion>3.2.9.RELEASE</springVersion></properties> <dependencies>    <dependency>        <groupId>org.apache.commons</groupId>        <artifactId>commons-pool2</artifactId>        <version>2.4.2</version>    </dependency>      <dependency>        <groupId>org.springframework.data</groupId>        <artifactId>spring-data-redis</artifactId>        <version>1.6.0.RELEASE</version>    </dependency>     <dependency>        <groupId>org.springframework</groupId>        <artifactId>spring-context</artifactId>        <version>${springVersion}</version>    </dependency>    <dependency>        <groupId>org.springframework</groupId>        <artifactId>spring-tx</artifactId>        <version>${springVersion}</version>    </dependency>    <dependency>        <groupId>org.springframework</groupId>        <artifactId>spring-context-support</artifactId>        <version>${springVersion}</version>    </dependency>    <dependency>        <groupId>cglib</groupId>        <artifactId>cglib-nodep</artifactId>        <version>3.1</version>    </dependency>      <dependency>        <groupId>org.apache.commons</groupId>        <artifactId>commons-lang3</artifactId>        <version>3.1</version>    </dependency>    <dependency>        <groupId>com.alibaba</groupId>        <artifactId>fastjson</artifactId>        <version>1.2.5</version>    </dependency>    <dependency>        <groupId>org.aspectj</groupId>        <artifactId>aspectjweaver</artifactId>        <version>1.8.2</version>    </dependency>     <dependency>        <groupId>junit</groupId>        <artifactId>junit</artifactId>        <version>4.8</version>        <scope>test</scope>    </dependency>    <dependency>        <groupId>net.sf.ehcache</groupId>        <artifactId>ehcache</artifactId>        <version>2.7.5</version>    </dependency>    <dependency>        <groupId>org.slf4j</groupId>        <artifactId>slf4j-api</artifactId>        <version>1.6.6</version>    </dependency>    <dependency>        <groupId>redis.clients</groupId>        <artifactId>jedis</artifactId>        <version>2.4.2</version>    </dependency>    <dependency>        <groupId>commons-pool</groupId>        <artifactId>commons-pool</artifactId>        <version>1.6</version>    </dependency>    <dependency>        <groupId>commons-logging</groupId>        <artifactId>commons-logging</artifactId>        <version>1.1.1</version>    </dependency>    <dependency>        <groupId>org.slf4j</groupId>        <artifactId>slf4j-log4j12</artifactId>        <version>1.7.10</version>        <scope>test</scope>    </dependency></dependencies>

3. Spring配置

1. 12345678910111213141516171819202122232425262728293031323334

   <bean id="redisSentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">    <property name="master">        <bean class="org.springframework.data.redis.connection.RedisNode">            <property name="name" value="mymaster"/>        </bean>    </property>    <property name="sentinels">        <set>            <bean class="org.springframework.data.redis.connection.RedisNode">                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>                 <constructor-arg name="port" value="26479"></constructor-arg>            </bean>            <bean class="org.springframework.data.redis.connection.RedisNode">                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>                 <constructor-arg name="port" value="26579"></constructor-arg>            </bean>        </set>    </property></bean> <bean id="jeidsConnectionFactory"       class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">     <constructor-arg ref="redisSentinelConfiguration"/> </bean>  <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">    <property name="connectionFactory" ref="jeidsConnectionFactory"/></bean>

4. java测试

1. 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849

   import org.junit.Before;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate; /** * Created by vincent on 15-10-13. */public class CommonTest {     private ApplicationContext context ;     private RedisTemplate redisTemplate;    final String key ="key7";     @Before    public void init（）{        context = new ClassPathXmlApplicationContext（"applicationContext.xml"）;        redisTemplate= context.getBean（"redisTemplate",RedisTemplate.class）;    }     @Test    public void test1（）{        redisTemplate.execute（new RedisCallback（） {            @Override            public Long doInRedis（RedisConnection redisConnection） throws DataAccessException {                 redisConnection.set（key.getBytes（）,（System.currentTimeMillis（）+""）.getBytes（））;                return 1L;            }        }）;    }     @Test    public void  test2（）{        Object execute = redisTemplate.execute（new RedisCallback（） {            @Override            public Object doInRedis（RedisConnection redisConnection） throws DataAccessException {                return redisConnection.get（key.getBytes（））;            }        }）;         System.out.println（new String（（byte[]）execute））;     }}

下面关于Redis的文章您也可能喜欢，不妨参考下：Ubuntu 14.04下Redis安装及简单测试 http://www.linuxidc.com/Linux/2014-05/101544.htmRedis主从复制基本配置 http://www.linuxidc.com/Linux/2015-03/115610.htmRedis集群明细文档 http://www.linuxidc.com/Linux/2013-09/90118.htmUbuntu 12.10下安装Redis（图文详解）+ Jedis连接Redis http://www.linuxidc.com/Linux/2013-06/85816.htmRedis系列-安装部署维护篇 http://www.linuxidc.com/Linux/2012-12/75627.htmCentOS 6.3安装Redis http://www.linuxidc.com/Linux/2012-12/75314.htmRedis安装部署学习笔记 http://www.linuxidc.com/Linux/2014-07/104306.htmRedis配置文件redis.conf 详解 http://www.linuxidc.com/Linux/2013-11/92524.htmRedis 的详细介绍：请点这里
Redis 的下载地址：请点这里本文永久更新链接地址