码迷,mamicode.com
首页 > 其他好文 > 详细

剑指架构师系列-Redis集群部署

时间:2017-09-09 22:40:12      阅读:311      评论:0      收藏:0      [点我收藏+]

标签:--   报告   pat   war   ddt   搭建集群   daemon   param   通知   

 

初步搭建Redis集群

 

克隆已经安装Redis的虚拟机,我们使用这两个虚拟机中的Redis来搭建集群。 

master:192.168.2.129 端口:7001

slave:192.168.2.132 端口:7002

sentinel:192.168.2.129 端口:26379

来说一下这个sentinel,sentinel是一个管理redis实例的工具,它可以实现对redis的监控、通知、自动故障转移。sentinel不断的检测redis实例是否可以正常工作,通过API向其他程序报告redis的状态,如果redis master不能工作,则会自动启动故障转移进程,将其中的一个slave提升为master,其他的slave重新设置新的master服务器。

来配置一下sentinel.conf,内容如下:

port 26379  
daemonize yes  
logfile "/var/log/redis/sentinel.log"  
sentinel monitor master1 192.168.1.129 7001 1  
sentinel down-after-milliseconds master1 1000  
sentinel failover-timeout master1 5000  

做为master的redis不需要修改redis.conf配置,但需要修改一下slave的redis配置,将端口修改为7002,并且添加如下的配置:

slaveof 192.168.1.129 7001 
 
配完了master, slave和sentinel后,必须按照如下顺序来启动redis集群:
 
master->slave->sentinel

 执行如下的命令所在的目录为:redis-stable/src 

 ./redis-server ../redis.conf   // 启动master与slave

./redis-sentinel ../sentinel.conf  // 启动sentinel

 使用客户端来查看:

./redis-cli -p 26379 -h 192.168.2.129 

内容如下图:

技术分享

 

 

 2、Spring Session Date Redis访问Redis Sentinel

 

使用上次新建的模块mazhi-redis进行测试。pom.xml文件不需要改变。但是redis.properties的配置需要改变,如下:

spring.redis.database=0
spring.redis.host=192.168.2.129
# Login password of the redis server.
spring.redis.password= 
spring.redis.pool.max-active=8
spring.redis.pool.max-idle=8
spring.redis.pool.max-wait=-1
spring.redis.pool.min-idle=0
spring.redis.port=7001
# Name of Redis server.
spring.redis.sentinel.master=master1
# Comma-separated list of host:port pairs.
spring.redis.sentinel.nodes=192.168.2.129:26379
spring.redis.timeout=0

注意必须是redis.properties这个名称,而且必须要放到src/main/resources目录下,这是一种约定。

spring.redis.sentinel.master必须与sentinel.conf文件中指定的值一致,如下:

 

sentinel monitor master1 192.168.1.129 7001 1

 

spring.redis.sentinel.nodes值为sentinel的ip:端口,可以有多个。

 

在org.mazhi.redis.config目录下新建RedisSentinalConfig.java文件,内容如下:

@Configuration
@PropertySource(value = "classpath:/redis.properties")
@EnableCaching
public class RedisSentinalConfig extends CachingConfigurerSupport{

    @Bean
    public KeyGenerator wiselyKeyGenerator(){  // 配置key的生成规则
        return new KeyGenerator() {
            public Object generate(Object target, Method method, Object... params) {
                StringBuilder sb = new StringBuilder();
                sb.append(target.getClass().getName());
                sb.append(method.getName());
                for (Object obj : params) {
                    sb.append(obj.toString());
                }
                return sb.toString();
            }
        };

    }

    @Bean
    public CacheManager cacheManager(@SuppressWarnings("rawtypes") RedisTemplate redisTemplate) {
        return new RedisCacheManager(redisTemplate);
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
        StringRedisTemplate template = new StringRedisTemplate(factory);
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
}

 

新建一个User的实体对象,如下:

package org.mazhi.redis.bean;

public class User {  
    private Long id;  
    private String name;  
    private String address;  
  
    public User(Long id,String name, String address) {  
        this.id = id ;  
        this.name = name;  
        this.address = address;  
    }  
  
    public User() {  
    }
   ...
  
}  

在org.mazhi.redis.service目录下新建DemoService.java文件,内容如下:

@Service  
public class DemoService {  
    @Cacheable(value = "usercache",keyGenerator = "wiselyKeyGenerator")  
    public User findUser(Long id,String firstName,String lastName){  
        System.out.println("======当Redis中不存在这条数据时会执行这里=========");  
        return new User(id,firstName,lastName);  
    }  
}  

在org.mazhi.redis.web目录下新建RedisSentinelController.java文件,内容如下:

	@Autowired
	DemoService demoService;

	@RequestMapping("/addToRedis")
	@ResponseBody
	public void putCache() {
		demoService.findUser(1l, "mazhi", "ordos");
		System.out.println("添加成功!");
	}

	@RequestMapping("/findFromRedis")
	@ResponseBody
	public void testCache() {
		User user = demoService.findUser(1l, "mazhi", "ordos");
		System.out.println("user:" + "/" + user.getName() + "/" + user.getAddress());
	}
}

启动Spring Boot后,在浏览器中输入如下地址:

http://localhost:8081/redis-sentinel/addToRedis

Eclipse的控制台打印如下信息:

======当Redis中不存在这条数据时会执行这里=========
添加成功!
添加成功!

接着输入如下地址进行访问: 

http://localhost:8081/redis-sentinel/getFromRedis

打印结果如下:

user:/mazhi/ordos
user:/mazhi/ordos

来看一下Redis的数据库,如下图所示。

技术分享

 看Key的生成形式,这就是调用我们在RedisSentinalConfig.java文件中指定的方法wiselyKeyGenerator()生成的。

看一下192.168.2.132上的redis,可以看到两个Redis的信息是同步的。

 

使用如下的命令来封闭192.168.2.129上的7001端口到达任何地方的路由,即人为造成了一次master服务的“宕机”。

/sbin/iptables -I INPUT -p tcp --dport 7001 -j DROP

Eclipse的控制台输出如下信息:

2016-04-01 09:02:35.188  INFO 6980 --- [       Thread-2] redis.clients.jedis.JedisSentinelPool    : Created JedisPool to master at 192.168.2.132:7002

master变为了192.168.2.132机器。或者我们可以在sentinel客户端查看,如下:

技术分享

address已经变成了192.168.2.132了。

恢复192.168.2.129上的7001端口,输入如下的命令:

/sbin/iptables -I  INPUT -p tcp --dport 7001 -j ACCEPT

在192.168.2.129上输入如下命令查看:

./redis-cli -h 192.168.2.129 -p 7001

可以看到如下信息:

技术分享

 

角色由以前的master变为slave了,而现在的master是192.168.2.132主机。

 

 

 

 

 

 

 

 

 

 

 

 

 



剑指架构师系列-Redis集群部署

标签:--   报告   pat   war   ddt   搭建集群   daemon   param   通知   

原文地址:http://www.cnblogs.com/mazhimazhi/p/7499346.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!