当前位置: 首页 > news >正文

redisson参数配置

文章目录

  • pom
  • 配置
  • 链接配置建议


pom

<!-- 引入spring-data-redis组件 -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><exclusions><!-- 因springboot2.x中默认集成了lettuce,因此需要排掉该依赖 --><exclusion><artifactId>lettuce-core</artifactId><groupId>io.lettuce</groupId></exclusion></exclusions>
</dependency>
<!-- 引入redisson对springboot的集成适配包 -->
<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>${redisson.version}</version>
</dependency>

配置

@Configuration
public class RedisConfiguration {@Value("${redis.address}")private String redisAddress;@Value("${redis.password:}")private String redisPassword;@Value("${redis.database:0}")private Integer redisDatabase = 0;@Value("${redis.connect.timeout:3000}")private Integer redisConnectTimeout = 3000;@Value("${redis.cluster.address}")private List<String> redisClusterAddress;@Value("${redis.cluster.scan.interval:5000}")private Integer redisClusterScanInterval = 5000;@Value("${redis.password:}")private String redisPassword;@Value("${redis.connect.timeout:3000}")private Integer redisConnectTimeout = 3000;@Value("${redis.connection.idle.timeout:10000}")private Integer redisConnectionIdleTimeout = 10000;@Value("${redis.connection.ping.interval:1000}")private Integer redisConnectionPingInterval = 1000;@Value("${redis.timeout:2000}")private Integer timeout = 2000;@Value("${redis.retry.attempts:3}")private Integer redisRetryAttempts = 3;@Value("${redis.retry.interval:200}")private Integer redisRetryInterval = 200;@Value("${redis.master.connection.pool.min.size:50}")private Integer redisMasterConnectionPoolMinSize = 50;@Value("${redis.master.connection.pool.max.size:200}")private Integer redisMasterConnectionPoolMaxSize = 200;@Value("${redis.connection.idle.timeout:10000}")private Integer redisConnectionIdleTimeout = 10000;@Value("${redis.connection.ping.interval:1000}")private Integer redisConnectionPingInterval = 1000;@Value("${redis.timeout:2000}")private Integer timeout = 2000;@Value("${redis.connection.pool.min.size:50}")private Integer redisConnectionPoolMinSize;@Value("${redis.connection.pool.max.size:200}")private Integer redisConnectionPoolMaxSize;@Value("${redis.retry.attempts:3}")private Integer redisRetryAttempts = 3;@Value("${redis.retry.interval:200}")private Integer redisRetryInterval = 200;单机
@Beanpublic RedissonConnectionFactory redissonConnectionFactory(Config
redissonSingleServerConfig) {return new RedissonConnectionFactory(redissonSingleServerConfig);}@Beanpublic Config redissonSingleServerConfig() {Config redissonConfig = new Config();SingleServerConfig serverConfig = redissonConfig.useSingleServer();serverConfig.setAddress(redisAddress);serverConfig.setConnectionMinimumIdleSize(redisConnectionPoolMinSize);serverConfig.setConnectionPoolSize(redisConnectionPoolMaxSize);serverConfig.setDatabase(redisDatabase);serverConfig.setPassword(redisPassword);serverConfig.setConnectTimeout(redisConnectTimeout);serverConfig.setIdleConnectionTimeout(redisConnectionIdleTimeout);serverConfig.setPingConnectionInterval(redisConnectionPingInterval);serverConfig.setTimeout(timeout);serverConfig.setRetryAttempts(redisRetryAttempts);serverConfig.setRetryInterval(redisRetryInterval);redissonConfig.setCodec(new JsonJacksonCodec());return redissonConfig;}主备
@Beanpublic RedissonConnectionFactory redissonConnectionFactory(Config
redissonMasterSlaveServersConfig) {return new RedissonConnectionFactory(redissonMasterSlaveServersConfig);}@Beanpublic Config redissonMasterSlaveServersConfig() {Config redissonConfig = new Config();MasterSlaveServersConfig serverConfig = redissonConfig.useMasterSlaveServers();serverConfig.setMasterAddress(redisMasterAddress);serverConfig.setDatabase(redisDatabase);serverConfig.setPassword(redisPassword);serverConfig.setMasterConnectionMinimumIdleSize(redisMasterConnectionPoolMinSize);serverConfig.setMasterConnectionPoolSize(redisMasterConnectionPoolMaxSize);serverConfig.setReadMode(ReadMode.MASTER_SLAVE);serverConfig.setSubscriptionMode(SubscriptionMode.MASTER);serverConfig.setConnectTimeout(redisConnectTimeout);serverConfig.setIdleConnectionTimeout(redisConnectionIdleTimeout);serverConfig.setPingConnectionInterval(redisConnectionPingInterval);serverConfig.setTimeout(timeout);serverConfig.setRetryAttempts(redisRetryAttempts);serverConfig.setRetryInterval(redisRetryInterval);redissonConfig.setCodec(new JsonJacksonCodec());return redissonConfig;}集群
@Beanpublic RedissonConnectionFactory redissonConnectionFactory(Config
redissonClusterServersConfig) {return new RedissonConnectionFactory(redissonClusterServersConfig);}@Beanpublic Config redissonClusterServersConfig() {Config redissonConfig = new Config();ClusterServersConfig serverConfig = redissonConfig.useClusterServers();serverConfig.setNodeAddresses(redisClusterAddress);serverConfig.setScanInterval(redisClusterScanInterval);serverConfig.setPassword(redisPassword);serverConfig.setMasterConnectionMinimumIdleSize(redisMasterConnectionPoolMinSize);serverConfig.setMasterConnectionPoolSize(redisMasterConnectionPoolMaxSize);serverConfig.setReadMode(ReadMode.MASTER);serverConfig.setSubscriptionMode(SubscriptionMode.MASTER);serverConfig.setConnectTimeout(redisConnectTimeout);serverConfig.setIdleConnectionTimeout(redisConnectionIdleTimeout);serverConfig.setPingConnectionInterval(redisConnectionPingInterval);serverConfig.setTimeout(timeout);serverConfig.setRetryAttempts(redisRetryAttempts);serverConfig.setRetryInterval(redisRetryInterval);redissonConfig.setCodec(new JsonJacksonCodec());return redissonConfig;}
}

链接配置建议

读取模式-readMode
建议采⽤ MASTER,即Master节点承担所有的读写流量,⼀⽅⾯避免数据因主从同步时延带来的⼀致性问题;另⼀⽅⾯,
如从节点故障,配置值=SLAVE,所有读请求会触发报错;配置值=MASTER_SLAVE,部分读请求会触发异常。读报错会持
续failedSlaveCheckInterval(默认30S)时间,直⾄从可⽤节点列表中摘除。
如需读写流量分流处理,DCS服务提供了针对读写流量分流的实例类型-读写分离,通过在中间架设代理节点实现读写流
量分发,遇到从节点故障时,⾃动切流⾄主节点,对业务应⽤⽆感知,且故障感知时间窗⼝远⼩于redisson内部的时间
窗⼝。
订阅模式-subscriptionMode
建立采⽤ MASTER,原理同上
连接池配置
连接池的⼤⼩没有绝对的标准,建议根据业务流量进⾏合理配置,⼀般连接池⼤⼩的参数计算公式如下
最⼩连接数 = (单机访问Redis QPS) / (1000ms / 单命令平均耗时)
最⼤连接数 = (单机访问Redis QPS) / (1000ms / 单命令平均耗时) * 150%
举例:某个业务应⽤的QPS为10000左右,每个请求需访问redis10次,也意味着每秒对redis的访问次数为100000次,
同时该业务应⽤有10台机器,计算如下
单机访问Redis QPS = 100000 / 10 = 10000
单命令访问耗时 = 20ms (redis处理单命令耗时为510ms,遇到⽹络抖动按照1520ms来估算)
最⼩连接数 = (10000) / (1000ms / 20ms)= 200
最⼤连接数 = (10000) / (1000ms / 20ms)* 150% = 300
以上计算⽅式只适⽤于⼀般业务场景,建议根据业务情况做适当调整适配
重试配置
redisson中⽀持重试配置,主要是如下两个参数,建议根据业务情况配置合理值,⼀般重试次数为3,重试间隔为200ms
左右
retryAttemps - 配置重试次数
retryInterval - 配置重试时间间隔

http://www.lryc.cn/news/139634.html

相关文章:

  • 【基于Arduino的仿生蚂蚁机器人】
  • angular12里面FormGroup做多个项目的相关check
  • TypeScript 的发展与基本语法
  • macOS - 上编译运行 risc-v (spike)
  • Linux--线程地址空间
  • 华为OD机试 - 最佳植树距离 - 二分查找(Java 2023 B卷 100分)
  • RNN+LSTM正弦sin信号预测 完整代码数据视频教程
  • 如何自己实现一个丝滑的流程图绘制工具(四)bpmn-js开启只读状态
  • 字节跳动 Git 的正确使用姿势与最佳实践
  • 龙迅LT7911UX TYPE-C/DP转MIPI/LVDS,内有HDCP
  • Spearman Footrule距离
  • docker 安装 Wordpress 用lnmp搭建出现的故障
  • 【C++入门到精通】C++入门 —— 继承(基类、派生类和多态性)
  • 【Spring框架】Spring事务的介绍与使用方法
  • 七夕特别篇 | 浪漫的Bug
  • 数据结构双向链表
  • 解决政务审计大数据传输难题!镭速传输为政务行业提供解决方案
  • redis 7高级篇1 redis的单线程与多线程
  • GO语言:Worker Pools线程池、Select语句、Metex互斥锁详细示例教程
  • vue ui 创建项目没有反应
  • go语言中channel类型
  • 基于STM32F1的电子罗盘HMC5883L角度测量
  • Oracle解锁表、包、用户、杀会话、停job
  • 软考高级系统架构设计师系列论文九十九:论软件开发平台的选择和应用
  • Redis Pub/Sub 指南
  • Nest(2):Nest 应用目录结构和脚手架命令介绍
  • 【嵌入式】MKV31F512VLL12 微控制器 (MCU) 、Cyclone® IV E EP4CE10E22I8LN,FPGA-现场可编程门阵列芯片
  • 矢量调制分析基础
  • ensp-Ipv6配置配置
  • java八股文面试[java基础]—— hashCode 与 equals 区别 == 与 equals的区别