企业官网建设流程全解析

购物网站推广方案,怎么做盗号网站手机,wordpress收不到邮件,大连做网站哪家好一点Redis热点Key独立集群实现方案 1. 设计背景 在高并发场景下#xff0c;热点Key会导致Redis实例负载过高#xff0c;影响整个系统的稳定性。通过将热点Key分离到独立的Redis集群#xff0c;可以实现资源隔离#xff0c;提高系统的抗风险能力。 2. 实现方案 2.1 核心设计思路…Redis热点Key独立集群实现方案1. 设计背景在高并发场景下热点Key会导致Redis实例负载过高影响整个系统的稳定性。通过将热点Key分离到独立的Redis集群可以实现资源隔离提高系统的抗风险能力。2. 实现方案2.1 核心设计思路多实例配置支持配置多个Redis实例包括普通实例和热点实例Key路由策略根据Key的特征或规则将请求路由到不同的Redis实例统一访问接口对外提供统一的Redis访问接口屏蔽底层实例差异灵活的路由规则支持多种路由规则如前缀匹配、正则匹配、哈希路由等2.2 配置扩展2.2.1 修改配置属性类DataConfigurationProperties(prefixredis.sdk,ignoreInvalidFieldstrue)publicclassRedisClientConfigProperties{// 默认实例配置privateDefaultConfigdefaultConfig;// 多个实例配置privateMapString,InstanceConfiginstancesnewHashMap();// 路由规则配置privateMapString,RouteRulerouteRulesnewHashMap();DatapublicstaticclassDefaultConfig{privateStringhost;privateintport;privateStringpassword;privateintpoolSize64;privateintminIdleSize10;privateintidleTimeout10000;privateintconnectTimeout10000;privateintretryAttempts3;privateintretryInterval1000;privateintpingInterval0;privatebooleankeepAlivetrue;}DatapublicstaticclassInstanceConfig{privateStringhost;privateintport;privateStringpassword;privateintpoolSize64;privateintminIdleSize10;privateintidleTimeout10000;privateintconnectTimeout10000;privateintretryAttempts3;privateintretryInterval1000;privateintpingInterval0;privatebooleankeepAlivetrue;}DatapublicstaticclassRouteRule{// 路由类型prefix前缀匹配、regex正则匹配、hash哈希路由privateStringtype;// 匹配规则privateStringpattern;// 目标实例名称privateStringtargetInstance;}}2.2.2 配置文件示例redis:sdk:# 默认实例配置default-config:host:127.0.0.1port:6379# 多个Redis实例配置instances:# 普通实例normal:host:127.0.0.1port:6379# 热点Key实例hot:host:127.0.0.1port:6380# 活动相关实例activity:host:127.0.0.1port:6381# 路由规则配置route-rules:# 热点Key路由规则以hot_开头的Key路由到hot实例hot-rule:type:prefixpattern:hot_target-instance:hot# 活动Key路由规则以activity_开头的Key路由到activity实例activity-rule:type:prefixpattern:activity_target-instance:activity2.3 Redis客户端配置扩展ConfigurationEnableConfigurationProperties(RedisClientConfigProperties.class)publicclassRedisClientConfig{// Redis实例映射key为实例名称value为RedissonClient实例privatefinalMapString,RedissonClientredisInstancesnewConcurrentHashMap();// 路由规则列表privatefinalListRouteRuleWrapperrouteRulesnewArrayList();PostConstructpublicvoidinit(ConfigurableApplicationContextapplicationContext,RedisClientConfigPropertiesproperties){// 1. 初始化默认实例initDefaultInstance(applicationContext,properties);// 2. 初始化其他实例initOtherInstances(applicationContext,properties);// 3. 初始化路由规则initRouteRules(properties);}privatevoidinitDefaultInstance(ConfigurableApplicationContextapplicationContext,RedisClientConfigPropertiesproperties){RedisClientConfigProperties.DefaultConfigdefaultConfigproperties.getDefaultConfig();RedissonClientredissonClientcreateRedissonClient(defaultConfig);redisInstances.put(default,redissonClient);}privatevoidinitOtherInstances(ConfigurableApplicationContextapplicationContext,RedisClientConfigPropertiesproperties){MapString,RedisClientConfigProperties.InstanceConfiginstancesproperties.getInstances();for(Map.EntryString,RedisClientConfigProperties.InstanceConfigentry:instances.entrySet()){StringinstanceNameentry.getKey();RedisClientConfigProperties.InstanceConfiginstanceConfigentry.getValue();RedissonClientredissonClientcreateRedissonClient(instanceConfig);redisInstances.put(instanceName,redissonClient);}}privatevoidinitRouteRules(RedisClientConfigPropertiesproperties){MapString,RedisClientConfigProperties.RouteRulerouteRulesConfigproperties.getRouteRules();for(Map.EntryString,RedisClientConfigProperties.RouteRuleentry:routeRulesConfig.entrySet()){RedisClientConfigProperties.RouteRuleconfigentry.getValue();RouteRuleWrapperwrappernewRouteRuleWrapper();wrapper.setType(config.getType());wrapper.setPattern(config.getPattern());wrapper.setTargetInstance(config.getTargetInstance());routeRules.add(wrapper);}}privateRedissonClientcreateRedissonClient(ObjectconfigObj){ConfigconfignewConfig();config.setCodec(JsonJacksonCodec.INSTANCE);Stringhost;intport;Stringpassword;intpoolSize;intminIdleSize;intidleTimeout;intconnectTimeout;intretryAttempts;intretryInterval;intpingInterval;booleankeepAlive;// 根据配置对象类型获取配置属性if(configObjinstanceofRedisClientConfigProperties.DefaultConfig){RedisClientConfigProperties.DefaultConfigdefaultConfig(RedisClientConfigProperties.DefaultConfig)configObj;hostdefaultConfig.getHost();portdefaultConfig.getPort();passworddefaultConfig.getPassword();poolSizedefaultConfig.getPoolSize();minIdleSizedefaultConfig.getMinIdleSize();idleTimeoutdefaultConfig.getIdleTimeout();connectTimeoutdefaultConfig.getConnectTimeout();retryAttemptsdefaultConfig.getRetryAttempts();retryIntervaldefaultConfig.getRetryInterval();pingIntervaldefaultConfig.getPingInterval();keepAlivedefaultConfig.isKeepAlive();}else{RedisClientConfigProperties.InstanceConfiginstanceConfig(RedisClientConfigProperties.InstanceConfig)configObj;hostinstanceConfig.getHost();portinstanceConfig.getPort();passwordinstanceConfig.getPassword();poolSizeinstanceConfig.getPoolSize();minIdleSizeinstanceConfig.getMinIdleSize();idleTimeoutinstanceConfig.getIdleTimeout();connectTimeoutinstanceConfig.getConnectTimeout();retryAttemptsinstanceConfig.getRetryAttempts();retryIntervalinstanceConfig.getRetryInterval();pingIntervalinstanceConfig.getPingInterval();keepAliveinstanceConfig.isKeepAlive();}// 配置单节点RedisSingleServerConfigsingleServerConfigconfig.useSingleServer().setAddress(redis://host:port).setConnectionPoolSize(poolSize).setConnectionMinimumIdleSize(minIdleSize).setIdleConnectionTimeout(idleTimeout).setConnectTimeout(connectTimeout).setRetryAttempts(retryAttempts).setRetryInterval(retryInterval).setPingConnectionInterval(pingInterval).setKeepAlive(keepAlive);// 设置密码如果有if(StringUtils.isNotBlank(password)){singleServerConfig.setPassword(password);}returnRedisson.create(config);}/** * 根据Key获取对应的RedissonClient实例 */publicRedissonClientgetRedissonClient(Stringkey){// 遍历路由规则找到匹配的规则for(RouteRuleWrapperrule:routeRules){if(matchRule(key,rule)){StringtargetInstancerule.getTargetInstance();returnredisInstances.get(targetInstance);}}// 没有匹配到规则使用默认实例returnredisInstances.get(default);}/** * 检查Key是否匹配路由规则 */privatebooleanmatchRule(Stringkey,RouteRuleWrapperrule){Stringtyperule.getType();Stringpatternrule.getPattern();switch(type){caseprefix:// 前缀匹配returnkey.startsWith(pattern);caseregex:// 正则匹配returnkey.matches(pattern);casehash:// 哈希路由根据Key的哈希值路由到不同实例// 这里简化实现实际可以根据哈希值和实例数量计算路由inthashkey.hashCode();returnMath.abs(hash)%20;// 示例偶数哈希值匹配default:returnfalse;}}/** * 路由规则包装类 */DataprivatestaticclassRouteRuleWrapper{privateStringtype;privateStringpattern;privateStringtargetInstance;}/** * 注入Redis服务 */Bean(redisService)publicRedisServiceredisService(){returnnewRedisServiceImpl(this);}}2.4 统一Redis服务封装/** * Redis服务接口 */publicinterfaceRedisService{/** * 设置Key-Value */Tvoidset(Stringkey,Tvalue);/** * 设置Key-Value带过期时间 */Tvoidset(Stringkey,Tvalue,longexpireTime,TimeUnittimeUnit);/** * 获取Value */TTget(Stringkey,ClassTclazz);/** * 删除Key */booleandelete(Stringkey);/** * 设置Hash字段 */Tvoidhset(Stringkey,Stringfield,Tvalue);/** * 获取Hash字段 */TThget(Stringkey,Stringfield,ClassTclazz);// 其他Redis操作方法...}/** * Redis服务实现类 */ServicepublicclassRedisServiceImplimplementsRedisService{privatefinalRedisClientConfigredisClientConfig;publicRedisServiceImpl(RedisClientConfigredisClientConfig){this.redisClientConfigredisClientConfig;}OverridepublicTvoidset(Stringkey,Tvalue){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RMapString,TmapredissonClient.getMap(cache);map.put(key,value);}OverridepublicTvoidset(Stringkey,Tvalue,longexpireTime,TimeUnittimeUnit){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RBucketTbucketredissonClient.getBucket(key);bucket.set(value,expireTime,timeUnit);}OverridepublicTTget(Stringkey,ClassTclazz){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RBucketTbucketredissonClient.getBucket(key);returnbucket.get();}Overridepublicbooleandelete(Stringkey){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RBucketObjectbucketredissonClient.getBucket(key);returnbucket.delete();}OverridepublicTvoidhset(Stringkey,Stringfield,Tvalue){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RMapString,TmapredissonClient.getMap(key);map.put(field,value);}OverridepublicTThget(Stringkey,Stringfield,ClassTclazz){RedissonClientredissonClientredisClientConfig.getRedissonClient(key);RMapString,TmapredissonClient.getMap(key);returnmap.get(field);}// 其他Redis操作方法实现...}2.5 使用示例ServicepublicclassActivityService{AutowiredprivateRedisServiceredisService;publicvoidcacheActivityInfo(StringactivityId,Activityactivity){// 活动相关Key会路由到activity实例Stringkeyactivity_activityId;redisService.set(key,activity,1,TimeUnit.HOURS);}publicActivitygetActivityInfo(StringactivityId){Stringkeyactivity_activityId;returnredisService.get(key,Activity.class);}publicvoidcacheHotProduct(StringproductId,Productproduct){// 热点Key会路由到hot实例Stringkeyhot_product_productId;redisService.set(key,product,30,TimeUnit.MINUTES);}publicProductgetHotProduct(StringproductId){Stringkeyhot_product_productId;returnredisService.get(key,Product.class);}publicvoidcacheUserInfo(StringuserId,Useruser){// 普通Key会路由到default实例Stringkeyuser_userId;redisService.set(key,user,24,TimeUnit.HOURS);}}3. 方案优势3.1 资源隔离热点Key单独存储在独立的Redis实例中避免影响其他业务不同业务线的Key可以分离到不同实例实现业务隔离3.2 灵活扩展支持动态添加Redis实例应对业务增长支持多种路由规则适应不同业务场景3.3 高可用性单个Redis实例故障不会影响整个系统可以为热点实例配置更高的资源规格3.4 统一访问接口对外提供统一的Redis访问接口简化开发底层实例变更对业务代码透明3.5 易于维护集中管理Redis实例配置统一监控和管理所有Redis实例4. 部署架构------------------- ------------------- ------------------- | | | | | | | 应用服务 | | Redis普通实例 | | Redis热点实例 | | (RedisService) |---| (Port: 6379) | | (Port: 6380) | | | | | | | ------------------- ------------------- ------------------- | v ------------------- | | | Redis活动实例 | | (Port: 6381) | | | -------------------5. 注意事项路由规则设计路由规则应根据业务特点精心设计避免规则冲突数据迁移已有数据需要考虑迁移策略确保平滑过渡监控告警需要为每个Redis实例配置独立的监控和告警一致性问题不同实例间的数据一致性需要业务层面保证连接管理需要合理配置连接池大小避免连接泄漏性能测试上线前需要进行充分的性能测试验证方案效果6. 扩展建议自动热点识别结合监控数据实现热点Key的自动识别和迁移动态路由调整支持根据实例负载动态调整路由规则Redis集群支持扩展支持Redis集群配置提高可用性多种客户端支持除了Redisson支持其他Redis客户端如Lettuce缓存预热实现热点数据的自动预热提高系统响应速度通过以上方案可以实现热点Key的独立集群部署提高系统的抗风险能力和性能表现同时保持良好的扩展性和维护性。