千家信息网

请输入关键字词

热门搜索排行

最新搜索排行

导航： 首页 > 互联网科技 >

SpringBoot整合redis客户端超时怎么解决

发表于：2025-02-05 作者：千家信息网编辑
千家信息网最后更新 2025年02月05日，本文小编为大家详细介绍"SpringBoot整合redis客户端超时怎么解决"，内容详细，步骤清晰，细节处理妥当，希望这篇"SpringBoot整合redis客户端超时怎么解决"文章能帮助大家解决疑惑
千家信息网最后更新 2025年02月05日SpringBoot整合redis客户端超时怎么解决

本文小编为大家详细介绍"SpringBoot整合redis客户端超时怎么解决"，内容详细，步骤清晰，细节处理妥当，希望这篇"SpringBoot整合redis客户端超时怎么解决"文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。

问题

在开发的时候，使用到Lettuce连接redis，一段时间后不操作，再去操作redis，会报连接超时错误，在其重连后又可使用。

原因是：Lettuce 自适应拓扑刷新（Adaptive updates）与定时拓扑刷新（Periodic updates） 是默认关闭的导致问题的出现

解决的方案

方法一：

1、重写连接工厂实例，更改其LettuceClientConfiguration 为开启拓扑更新

@Configurationpublic class RedisConfig {      @Autowired    private RedisProperties redisProperties;     //这是固定的模板    //自己定义了一个RedisTemplate    @Bean    @SuppressWarnings("all")    public RedisTemplate redisTemplate(@Qualifier("lettuceConnectionFactoryUvPv") RedisConnectionFactory factory) {        RedisTemplate template = new RedisTemplate<>();        template.setConnectionFactory(factory);         //Json序列化配置        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);        ObjectMapper om = new ObjectMapper();        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);        om.activateDefaultTyping(om.getPolymorphicTypeValidator());        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);        //解决序列化问题        om.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);        jackson2JsonRedisSerializer.setObjectMapper(om);         //String的序列化        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();         //key采用String的序列化方式        template.setKeySerializer(stringRedisSerializer);        //hash的key也采用String的序列化方式        template.setHashKeySerializer(stringRedisSerializer);         //value序列化方式采用jackson        template.setValueSerializer(jackson2JsonRedisSerializer);         //hash的value序列化方式采用jackson        template.setHashValueSerializer(jackson2JsonRedisSerializer);        template.afterPropertiesSet();         return template;    }     /**     * 为RedisTemplate配置Redis连接工厂实现     * LettuceConnectionFactory实现了RedisConnectionFactory接口     * UVPV用Redis     *     * @return 返回LettuceConnectionFactory     */    @Bean(destroyMethod = "destroy")    //这里要注意的是，在构建LettuceConnectionFactory 时，如果不使用内置的destroyMethod，可能会导致Redis连接早于其它Bean被销毁    public LettuceConnectionFactory lettuceConnectionFactoryUvPv() throws Exception { //        List clusterNodes = redisProperties.getCluster().getNodes();//        Set nodes = new HashSet<>();//        clusterNodes.forEach(address -> nodes.add(new RedisNode(address.split(":")[0].trim(), Integer.parseInt(address.split(":")[1]))));//        RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration();//        clusterConfiguration.setClusterNodes(nodes);//        clusterConfiguration.setPassword(RedisPassword.of(redisProperties.getPassword()));//        clusterConfiguration.setMaxRedirects(redisProperties.getCluster().getMaxRedirects());         //我使用的是单机redis，集群使用上面注释的代码        Set nodes = new HashSet<>();        nodes.add(new RedisNode(redisProperties.getHost(), redisProperties.getPort()));          RedisStandaloneConfiguration  redisStandaloneConfiguration=new RedisStandaloneConfiguration();        redisStandaloneConfiguration.setHostName(redisProperties.getHost());        redisStandaloneConfiguration.setPassword(redisProperties.getPassword());        redisStandaloneConfiguration.setDatabase(redisProperties.getDatabase());        redisStandaloneConfiguration.setPort(redisProperties.getPort());         GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();        poolConfig.setMaxIdle(redisProperties.getLettuce().getPool().getMaxIdle());        poolConfig.setMinIdle(redisProperties.getLettuce().getPool().getMinIdle());        poolConfig.setMaxTotal(redisProperties.getLettuce().getPool().getMaxActive());         return new LettuceConnectionFactory(redisStandaloneConfiguration, getLettuceClientConfiguration(poolConfig));    }     /**     * 配置LettuceClientConfiguration 包括线程池配置和安全项配置     *     * @param genericObjectPoolConfig common-pool2线程池     * @return lettuceClientConfiguration     */    private LettuceClientConfiguration getLettuceClientConfiguration(GenericObjectPoolConfig genericObjectPoolConfig) {        /*        ClusterTopologyRefreshOptions配置用于开启自适应刷新和定时刷新。如自适应刷新不开启，Redis集群变更时将会导致连接异常！         */        ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder()                //开启自适应刷新                //.enableAdaptiveRefreshTrigger(ClusterTopologyRefreshOptions.RefreshTrigger.MOVED_REDIRECT, ClusterTopologyRefreshOptions.RefreshTrigger.PERSISTENT_RECONNECTS)                //开启所有自适应刷新，MOVED，ASK，PERSISTENT都会触发                .enableAllAdaptiveRefreshTriggers()                // 自适应刷新超时时间(默认30秒)                .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(25)) //默认关闭开启后时间为30秒                // 开周期刷新                .enablePeriodicRefresh(Duration.ofSeconds(20))  // 默认关闭开启后时间为60秒 ClusterTopologyRefreshOptions.DEFAULT_REFRESH_PERIOD 60  .enablePeriodicRefresh(Duration.ofSeconds(2)) = .enablePeriodicRefresh().refreshPeriod(Duration.ofSeconds(2))                .build();        return LettucePoolingClientConfiguration.builder()                .poolConfig(genericObjectPoolConfig)                .clientOptions(ClusterClientOptions.builder().topologyRefreshOptions(topologyRefreshOptions).build())                //将appID传入连接，方便Redis监控中查看                //.clientName(appName + "_lettuce")                .build();    } }
2、SpringBoot2.3.x后，可使用配置文件中开启lettuce的拓扑刷新
lettuce:    pool:      max-active: 20      max-wait: -1ms      max-idle: 10      min-idle: 2    cluster:      refresh:        adaptive: true        #20秒自动刷新一次        period: 20
方法二：
更改连接redis的连接方式，使用jedis连接
            org.springframework.boot            spring-boot-starter-data-redis                                                io.lettuce                    lettuce-core                                                                 redis.clients            jedis        
配置文件
spring:  redis:    password: xxx    host: 172.16.0.x    port: 6579    timeout: 5000    jedis:      pool:              #最大连接数据库连接数,设 0 为没有限制        max-active: 8              #最大等待连接中的数量,设 0 为没有限制        max-idle: 8              #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。        max-wait: -1ms              #最小等待连接中的数量,设 0 为没有限制        min-idle: 0    #lettuce:      #pool:        #max-active: ${redis.config.maxTotal:1024}        #max-idle: ${redis.config.maxIdle:50}        #min-idle: ${redis.config.minIdle:1}        #max-wait: ${redis.config.maxWaitMillis:5000}
读到这里，这篇"SpringBoot整合redis客户端超时怎么解决"文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注行业资讯频道。


        


        
 很赞哦！ 

        


        



        配置
            序列
            时间
            方式
            拓扑
            客户
            客户端
            整合
            最大
            文章
            问题
            限制
            内容
            工厂
            数量
            文件
            方法
            线程
            集群
            妥当
    
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全

教育技术与数据库的关系是什么
云服务器没有域名能干什么
服务器硬盘有哪几种
广州科技网络安全公司有哪些
上海巡检软件开发怎么样
nba2k17数据库
社保软件开发怎么开发
松江区无线网络技术有哪些
网工和软件开发
saphana用什么数据库
惯性数据库与非惯性数据库
每年9月网络安全周是几号
临沧运河软件开发有限责任公司
搞死服务器
网上企业信用数据库
社会燃烧理论与网络安全
Linux密钥管理服务器
数控软件开发服务
系统提供数据库通用接口的目的是
行政大厅网络安全课程
mongodb数据库路径
打开光盘时服务器运行失败
网络技术学院奖获奖
辽宁互联网软件开发计划
兼顾软件开发和游戏的笔记本
互联网智能科技峰会
软件开发外包公司什么意思
浦东新区上门软件开发代理品牌
网络技术及新媒体
服务器内存r740
        

        


        
        

        

          
        

      
    


    



    

      

        
相关文章

      

      
    






   





  



































0