redis 使用lettuce 啟動內(nèi)存泄漏錯誤的解決方案

更新時間：2021年04月08日 10:43:36 作者：AugustWhite

這篇文章主要介紹了redis 使用lettuce 啟動內(nèi)存泄漏錯誤的解決方案，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

redis 使用 lettuce 出現(xiàn)

LEAK: hashedwheelTimer.release() was not called before it's garbage-collected. Enable advanced leak

內(nèi)存泄漏。其實是內(nèi)存不夠大導(dǎo)致。

找到eclispe 中window->preferences->Java->Installed JRE ，點擊右側(cè)的Edit 按鈕，在編輯界面中的 “Default VM Arguments ”選項中，填入如下值即可。

-Xms64m -Xmx128m

內(nèi)存調(diào)的足夠大可解決。

另一種方法無法解決。不知道是不是方法設(shè)置不對的問題

1、打開eclipse配置文件eclipse.ini，更改把-Xmx（其數(shù)值代表jvm可以使用的最大內(nèi)存數(shù)）

2. 運行java程序時，選擇run->run configuration->arguments,輸入-Xms100M -Xmx800M（-Xms代表jvm啟動時分配的內(nèi)存大小，-Xmx代表可最大分配多少內(nèi)存）。

補充：Redis連接池Lettuce踩坑記錄

一、引言

近期項目頻繁部署不同測試環(huán)境，在搭建運行環(huán)境與部署項目過程中踩到了不少Redis的坑。項目是基于SpringBoot2.1.12，SpringBoot2.1.X集成jar包Spring-data-redis-start 使用Lettuce作為Redis連接池。

SpringBoot1.x默認采用Jedis作為redis客戶端連接池。

SpringBoot2.x，spring-data-redis 默認采用Lettuce作為redis客戶端驅(qū)動連接池。

二、踩坑場景

運行環(huán)境Redis集群中某個master節(jié)點不穩(wěn)定連接不上，導(dǎo)致SpringBoot應(yīng)用連接Redis報錯，報錯連接timeout。

三、解決方案

基于Spring-data-redis重寫RedisConnectionFactory Bean。需要設(shè)置“取消校驗集群節(jié)點的成員關(guān)系”：.validateClusterNodeMembership(false)。

1、redis配置

spring:
 redis:
   cluster:
     nodes:
     - ${redis.host.cluster} #redis集群ip-port
   password: ${redis.password}
   timeout: 5000 #連接超時時間
   lettuce:
     pool:
       max-active: 10 #連接池最大連接數(shù)
       max-wait: -1 #連接池最大阻塞時間
       max-idle: 5 #連接池中最大空閑連接
       min-idle: 1 #連接池中最小空閑連接
redis:
 cluster:
   enabled: true

2、Config配置類

@Data
@Component
@ConditionalOnProperty(name = "redis.cluster.enabled", havingValue = "true", matchIfMissing = false)
public class RedisConfig {
    @Autowired
    RedisProperties redisProperties;
    // 在構(gòu)建LettuceConnectionFactory時，如果不使用內(nèi)置的destroyMethod，可能會導(dǎo)致Redis連接早于其它Bean被銷毀
    @Bean(destroyMethod = "destroy")
    public RedisConnectionFactory newLettuceConnectionFactory() {
        // 配置用于開啟自適應(yīng)刷新和定時刷新。如自適應(yīng)刷新不開啟，Redis集群變更時將會導(dǎo)致連接異常
        ClusterTopologyRefreshOptions clusterTopologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
                .enablePeriodicRefresh(Duration.ofSeconds(60))// 開啟周期刷新(默認60秒)
                .enableAdaptiveRefreshTriggers(RefreshTrigger.ASK_REDIRECT,RefreshTrigger.UNKNOWN_NODE)// 開啟自適應(yīng)刷新
                .build();
        ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder()
                                 .topologyRefreshOptions(clusterTopologyRefreshOptions)//拓撲刷新
                                 .disconnectedBehavior(ClientOptions.DisconnectedBehavior.REJECT_COMMANDS)
                                 .autoReconnect(true)
                                 .socketOptions(SocketOptions.builder().keepAlive(true).build())
　　　　　　　　　　　　　　　　       .validateClusterNodeMembership(false)// 取消校驗集群節(jié)點的成員關(guān)系
                                 .build();
        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                .clientOptions(clusterClientOptions)
                                .readFrom(ReadFrom.SLAVE_PREFERRED)
                                .build();
        return new LettuceConnectionFactory(getClusterConfiguration(), clientConfig);
    }
    
    private  RedisClusterConfiguration getClusterConfiguration() {
        RedisProperties.Cluster clusterProperties = redisProperties.getCluster();
        RedisClusterConfiguration config = new RedisClusterConfiguration(clusterProperties.getNodes());
        if (clusterProperties.getMaxRedirects() != null) {
            config.setMaxRedirects(clusterProperties.getMaxRedirects());
        }
        if (redisProperties.getPassword() != null) {
            config.setPassword(RedisPassword.of(redisProperties.getPassword()));
        }
        return config;
    }
}

注意：

RedisClusterConfiguration getClusterConfiguration()需要設(shè)置Password，不然SpringBoot啟動報認證錯誤：