专栏首页强仔仔分分钟钟搞定Docker下面的redis sentinel集群

分分钟钟搞定Docker下面的redis sentinel集群

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/linzhiqiang0316/article/details/79176832

今天给大家介绍一下如何通过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来正规的测试一下这种配置下的性能极限是多少。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Redis Sentinel高可用集群Java客户端

    版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/...

    林老师带你学编程
  • 第三方接口超大数据获取方案(下载-解析-入库模式)

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。

    林老师带你学编程
  • jedisLock—redis分布式锁实现

      管理后台的部署架构(多台tomcat服务器+redis【多台tomcat服务器访问一台redis】+mysql【多台tomcat服务器访问一台服务器上的my...

    林老师带你学编程
  • Redis Sentinel高可用集群Java客户端

    版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/...

    林老师带你学编程
  • 你的C#代码是怎么跑起来的(一)

    写了那么多C#代码,大家有没有想过自己写的代码编译后的可执行文件内部是什么样子,是怎样在系统上运行的? 编译成exe,然后双击exe文件运行,这中间到底发生了些...

    用户1147588
  • JavaScript中如何给localStorage设置一个有效期?

    从我们接触前端起,第一个熟悉的存储相关的Cookie或者来分析我们生活中密切相关的淘宝、物流、闹钟等事物来说起吧,

    Javanx
  • 如何给localStorage设置一个有效期

    ​  这个话题其实在上次分享<小程序填坑记里讲过了>已经讲过(大佬可绕过哦~),但后来群里/评论都有些同学,提到了一些疑问,问能否单独整理一篇更为详细的分享,讲...

    苏南
  • 嘘,我已经瞒着开发解锁APP日志文件抓取及分析啦!

    Dalvik Debug Monitor Service ( Dalvik调试监控服务) ,可视化的图形界面调试监控工具。不同等级log信息显示的颜色不同,使用...

    ITester软件测试小栈
  • Appium+python自动化11-adb必知必会

    前言 学android测试,adb是必学的,有几个常用的指令需要熟练掌握 一、检查设备 1.如何检查手机(或模拟器)是连上电脑的,在cmd输入: >adb de...

    上海-悠悠
  • 企业云架构:SaaS、PaaS和IaaS,总有一种适合你!

    导读:对于众多正在积极开展云计算的企业来说,选择一个好的云计算管理平台是一个策略性的决定,因为它涉及到 IT 的基础和将来发展方向。

    华章科技

扫码关注云+社区

领取腾讯云代金券