今天给大家介绍一下如何通过Java来set和get值到Redis Sentinel集群中。
在开始之前我们首先要搭建一个Redis Sentinel集群环境，搭建过程这边我就不多介绍了，不会的可以去看我《Docker下面安装redis sentinel集群》这篇博客，里面已经介绍的很清楚了。
redis集群环境：三个redis服务器，其中6379为master服务器，6380、6381是slave服务器。
Java中我们可以采用ShardedJedis来操作redis集群，这边因为master中既可以存数据也可以取数据，而slave中只能进行读取操作，所以这边我在获取ShardedJedis的时候，会采用两个不同的方法来。一个是masterRedis方法，这个方法中只能用来写操作，一个slaveRedis方法，这个方法只能用来读取操作，下面我们看具体的代码实现。
1.首先需要引入redis相关的依赖，如下所示：
< dependency >
< groupId > redis.clients </ groupId >
< artifactId > jedis </ artifactId >
< version > 2.9.0 </ version >
</ dependency >
< dependency >
< groupId > org.springframework.boot </ groupId >
< artifactId > spring-boot-starter-data-redis </ artifactId >
</ dependency >
< dependency >
< groupId > org.springframework.boot </ groupId >
< artifactId > spring-boot-starter-cache </ artifactId >
</ dependency >
2.配置ShardedJedis来操作redis缓存数据库
@Configuration
public class RedisConfigure {
@Value ( "${redisIp}" )
public String redisIp ;

@Value ( "${masterRedisPort}" )
public int masterRedisPort ;

@Value ( "${slaveRedisPort}" )
public String slaveRedisPortStr ;

@Value ( "${redisMaxWaitMillis}" )
public int redisMaxWaitMillis ;

@Value ( "${redisMaxIdle}" )
public int redisMaxIdle ;

@Value ( "${redisMaxTotal}" )
public int redisMaxTotal ;

/**
* 缓存数据库，可以进行设置key
*
* @return Jedis
*/
@Bean
public ShardedJedis masterRedis() {
List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
shards.add( new JedisShardInfo( redisIp , masterRedisPort ));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxIdle( redisMaxIdle );
config.setMaxTotal( redisMaxTotal );
config.setMaxWaitMillis( redisMaxWaitMillis );
ShardedJedisPool pool = new ShardedJedisPool(config, shards);
return pool.getResource();
}
/**
* slave缓存数据库，只能读取key值
*
* @return
*/
@Bean
public ShardedJedis slaveRedis() {
List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
String[] slaveRedisPorts = slaveRedisPortStr .split( "," );
for (String slaveRedisPort : slaveRedisPorts) {
shards.add( new JedisShardInfo( redisIp , Integer. valueOf (slaveRedisPort)));
}
shards.add( new JedisShardInfo( redisIp , masterRedisPort ));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxIdle( redisMaxIdle );
config.setMaxTotal( redisMaxTotal );
config.setMaxWaitMillis( redisMaxWaitMillis );
ShardedJedisPool pool = new ShardedJedisPool(config, shards);
return pool.getResource();
}
}
这边需要注意的是： 我这边返回的是ShardedJedis对象，而且通过这种方式返回的只有一个实例，不管多个实体类中调用都不会重新执行masterRedis和slaveRedis这两个方法，它只会在启动的时候执行一次。这边如果不小心返回的是ShardedJedisPool对象，在多次执行之后就会报错，这点需要注意。
还有一点需要注意的是 ：我这边的redis地址和端口都是通过配置读取来获取的，因为这样就不会写死在代码中了，灵活性更大。
配置文件内容如下：
redisIp = 211.159.165.227
slaveRedisPort = 6380,6381
masterRedisPort = 6379
redisMaxIdle = 10
redisMaxTotal = 30
redisMaxWaitMillis = 3000
3.controller控制类中进行redis数据存储和读取操作，具体代码如下：
@Controller
@RequestMapping ( "/jedis" )
public class RedisController {
@Autowired
ShardedJedis masterRedis ;
@Autowired
ShardedJedis slaveRedis ;
@RequestMapping ( "set" )
@ResponseBody
public String setKey(String key,String value){
String result= masterRedis .set(key,value);
return "设置的key为：" +key+ "设置的value为：" +value+ "存储执行的结果为：" +result;
}
@RequestMapping ( "get" )
@ResponseBody
public String getKey(String key){
String result= slaveRedis .get(key);
return "读取的key为：" +key+ "读取到的value为：" +result;
}
}
代码解析：masterRedis只能用来set数据到master缓存数据库中，slaveRedis只能用来get缓存中的数据。
这边需要注意的是：RedisConfigure类只能通过@Autowired注释才能获取到配置文件，还有 ShardedJedis masterRedis;中masterRedis名字要和RedisConfigure中的方法一样才可以。
4.浏览器校验是否成功

经过检测：200次set数据请求/s+200次get数据请求/s 毫无压力，服务器性能没有受到任何的影响。后期可以通过loadrunner来正规的测试一下这种配置下的性能极限是多少。

# docker
Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生