Java Config配置
@Configuration
public class RestTemplateConfig {
@Bean
public RestTemplate getRestTemplate（） {
//配置HTTP超时时间
HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory（）;
httpRequestFactory.setConnectionRequestTimeout（6000）;
httpRequestFactory.setConnectTimeout（6000）;
httpRequestFactory.setReadTimeout（6000）;
return new RestTemplate（httpRequestFactory）;
}
}
配置文件指定
custom.rest.connection.connection-request-timeout=3000
custom.rest.connection.connect-timeout=3000
custom.rest.connection.read-timeout=3000
@Configuration
public class AppConfig{
@Bean
@ConfigurationProperties（prefix = "custom.rest.connection"）
public HttpComponentsClientHttpRequestFactory customHttpRequestFactory（） {
return new HttpComponentsClientHttpRequestFactory（）;
}
@Bean
public RestTemplate customRestTemplate（）{
return new RestTemplate（customHttpRequestFactory（））;
}
}
重新部署后消费者迅速开始消费，堆积的消息已经消费完。
|
