专栏首页强仔仔Redis Sentinel高可用集群Java客户端

Redis Sentinel高可用集群Java客户端

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

今天给大家介绍一下如何通过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 条评论
登录 后参与评论

推荐阅读

  • 远程办公经验为0,如何将日常工作平滑过度到线上?

    我是一名创业者,我的公司(深圳市友浩达科技有限公司)在2018年8月8日开始运营,现在还属于微型公司。这个春节假期,我一直十分关注疫情动向,也非常关心其对公司带来的影响。

    TVP官方团队
    TAPD 敏捷项目管理腾讯乐享企业邮箱企业编程算法
  • 数据中台,概念炒作还是另有奇效? | TVP思享

    作者简介:史凯,花名凯哥,腾讯云最具价值专家TVP,ThoughtWorks数据智能业务总经理。投身于企业数字化转型工作近20年。2000年初,在IBM 研发企业级中间件,接着加入埃森哲,为大型企业提供信息化架构规划,设计,ERP,云平台,数据仓库构建等技术咨询实施服务,随后在EMC负责企业应用转型业务,为企业提供云迁移,应用现代化服务。现在专注于企业智能化转型领域,是数据驱动的数字化转型的行业布道者,数据中台的推广者,精益数据创新体系的创始人,2019年荣获全球Data IQ 100人的数据赋能者称号,创业邦卓越生态聚合赋能官TOP 5。2019年度数字化转型专家奖。打造了行业第一个数据创新的数字化转型卡牌和工作坊。创建了精益数据创新方法论体系构建数据驱动的智能企业,并在多个企业验证成功,正在向国内外推广。

    TVP官方团队
    大数据数据分析企业
  • 扩展 Kubernetes 之 CRI

    使用 cri-containerd 的调用流程更为简洁, 省去了上面的调用流程的 1,2 两步

    王磊-AI基础
    Kubernetes
  • 扩展 Kubernetes 之 Kubectl Plugin

    kubectl 功能非常强大, 常见的命令使用方式可以参考 kubectl --help,或者这篇文章

    王磊-AI基础
    Kubernetes
  • 多种登录方式定量性能测试方案

    最近接到到一个测试任务,某服务提供了两种登录方式:1、账号密码登录;2、手机号+验证码登录。要对这两种登录按照一定的比例进行压测。

    八音弦
    测试服务 WeTest
  • 线程安全类在性能测试中应用

    首先验证接口参数签名是否正确,然后加锁去判断订单信息和状态,处理用户增添VIP时间事务,成功之后释放锁。锁是针对用户和订单的分布式锁,使用方案是用的redis。

    八音弦
    安全编程算法
  • 使用CDN(jsdelivr) 优化博客访问速度

    PS: 此篇文章适用于 使用 Github pages 或者 coding pages 的朋友,其他博客也类似.

    IFONLY@CUIT
    CDNGitGitHub开源
  • 扩展 Kubernetes 之 CNI

    Network Configuration 是 CNI 输入参数中最重要当部分, 可以存储在磁盘上

    王磊-AI基础
    Kubernetes
  • 聚焦【技术应变力】云加社区沙龙online重磅上线!

    云加社区结合特殊时期热点,挑选备受关注的音视频流量暴增、线下业务快速转线上、紧急上线防疫IoT应用等话题,邀请众多业界专家,为大家提供连续十一天的干货分享。从视野、预判、应对等多角度,帮助大家全面提升「技术应变力」!

    腾小云
  • 京东购物小程序购物车性能优化实践

    它是小程序开发工具内置的一个可视化监控工具,能够在 OS 级别上实时记录系统资源的使用情况。

    WecTeam
    渲染JavaScripthttps网络安全缓存

扫码关注云+社区

领取腾讯云代金券