springboot項目 報錯: org.influxdb.InfluxDBIOException: java.net.SocketTimeoutException: timeout

項目版本

springboot: 2.1.3

問題描述

查詢Influxdb時因為網絡等原因查詢超時

解決方案

實現接口org.springframework.boot.autoconfigure.influx.InfluxDbOkHttpClientBuilderProvider
自定義OkHttpClient.Builder手動設置超時時間
代碼如下

package com.kstsixeam.config;

import okhttp3.OkHttpClient;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.TimeUnit;

@Configuration
public class InfluxDbOkHttpClientBuilderProvider implements org.springframework.boot.autoconfigure.influx.InfluxDbOkHttpClientBuilderProvider {

    @Override
    public OkHttpClient.Builder get() {
    	// 設置超時時間為100秒
        return new OkHttpClient.Builder()
                .connectTimeout(100, TimeUnit.SECONDS)
                .readTimeout(100, TimeUnit.SECONDS)
                .writeTimeout(100, TimeUnit.SECONDS);
    }
}

解決思路

1. 查看報錯信息

org.influxdb.InfluxDBIOException: java.net.SocketTimeoutException: timeout
	at org.influxdb.impl.InfluxDBImpl.execute(InfluxDBImpl.java:514)
	at org.influxdb.impl.InfluxDBImpl.query(InfluxDBImpl.java:390)
    ...

2. 查看org.influxdb.impl.InfluxDBImpl.execute(InfluxDBImpl.java:514)代碼
   
   這里發現是這行代碼出錯，查看代碼發現call由influxDBService生成
   
   繼續查找，找到influxDBService的實例化代碼
   
   可以看到它的超時時長由這個構造方法傳入的clicent來決定的。
3. 查看springboot實例化該類的代碼
   點擊Endpoints=>Beans=>myModule
   搜索influxdb，點擊，即可跳轉到springboot實例化該bean的代碼
   貼一下源碼

/*
* Copyright 2012-2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
*      http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.springframework.boot.autoconfigure.influx;

import okhttp3.OkHttpClient;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.influxdb.InfluxDB;
import org.influxdb.impl.InfluxDBImpl;

import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
* {@link EnableAutoConfiguration Auto-configuration} for InfluxDB.
*
* @author Sergey Kuptsov
* @author Stephane Nicoll
* @author Eddú Meléndez
* @since 2.0.0
*/
@Configuration
@ConditionalOnClass(InfluxDB.class)
@EnableConfigurationProperties(InfluxDbProperties.class)
public class InfluxDbAutoConfiguration {

   private static final Log logger = LogFactory.getLog(InfluxDbAutoConfiguration.class);

   private final InfluxDbProperties properties;

   private final OkHttpClient.Builder builder;

   public InfluxDbAutoConfiguration(InfluxDbProperties properties,
   		ObjectProvider<InfluxDbOkHttpClientBuilderProvider> builder,
   		ObjectProvider<OkHttpClient.Builder> deprecatedBuilder) {
   	this.properties = properties;
   	this.builder = determineBuilder(builder.getIfAvailable(),
   			deprecatedBuilder.getIfAvailable());
   }

   @Deprecated
   private static OkHttpClient.Builder determineBuilder(
   		InfluxDbOkHttpClientBuilderProvider builder,
   		OkHttpClient.Builder deprecatedBuilder) {
   	if (builder != null) {
   		return builder.get();
   	}
   	else if (deprecatedBuilder != null) {
   		logger.warn(
   				"InfluxDB client customizations using a OkHttpClient.Builder is deprecated, register a "
   						+ InfluxDbOkHttpClientBuilderProvider.class.getSimpleName()
   						+ " bean instead");
   		return deprecatedBuilder;
   	}
   	return new OkHttpClient.Builder();
   }

   @Bean
   @ConditionalOnMissingBean
   @ConditionalOnProperty("spring.influx.url")
   public InfluxDB influxDb() {
   	return new InfluxDBImpl(this.properties.getUrl(), this.properties.getUser(),
   			this.properties.getPassword(), this.builder);
   }

}

查看這部分代碼，發現springboot會先去找InfluxDbOkHttpClientBuilderProvider的實例化對象，如果沒有，就使用OkHttpClient.Builder的實例化對象。
換言之，如果我們只想自定義InfluxDb的OkHttpClient.Builder的屬性，那么我們就可以實現InfluxDbOkHttpClientBuilderProvider接口就可以了
5. 實現InfluxDbOkHttpClientBuilderProvider。

• InfluxDbOkHttpClientBuilderProvider的代碼
  
• 實現
  見解決方案

最后

其實關於此解決方案springboot早有提示

WARN [main] org.springframework.boot.autoconfigure.influx.InfluxDbAutoConfiguration

InfluxDB client customizations using a OkHttpClient.Builder is deprecated, 
register a InfluxDbOkHttpClientBuilderProvider bean instead