RestTemplate设置超时时间及返回状态码非200处理

目录
  • 1.调试postForEntity请求
  • 2.设置超时时间

默认情况下使用RestTemplate如果返回结果的状态码是200的话就正常处理,否则都会抛出异常;

1.调试postForEntity请求

调试postForEntity请求的方法找到判断响应结果状态码的方法是org.springframework.web.client.DefaultResponseErrorHandler类中的hasError方法

	@Override
	public boolean hasError(ClientHttpResponse response) throws IOException {
		int rawStatusCode = response.getRawStatusCode();
		HttpStatus statusCode = HttpStatus.resolve(rawStatusCode);
		return (statusCode != null ? hasError(statusCode) : hasError(rawStatusCode));
	}

代码再往上跟踪一级,如下:

	protected void handleResponse(URI url, HttpMethod method, ClientHttpResponse response) throws IOException {
		ResponseErrorHandler errorHandler = getErrorHandler();
		boolean hasError = errorHandler.hasError(response);
		if (logger.isDebugEnabled()) {
			try {
				int code = response.getRawStatusCode();
				HttpStatus status = HttpStatus.resolve(code);
				logger.debug("Response " + (status != null ? status : code));
			}
			catch (IOException ex) {
				// ignore
			}
		}
		if (hasError) {
			errorHandler.handleError(url, method, response);
		}
	}

从上面的代码可以看到是使用了RestTemplate的错误处理器,所以我们就可以想办法自定义错误处理器;

    @Bean
    public RestTemplate restTemplate(ClientHttpRequestFactory factory){
        RestTemplate restTemplate = new RestTemplate(factory);
        ResponseErrorHandler responseErrorHandler = new ResponseErrorHandler() {
            @Override
            public boolean hasError(ClientHttpResponse response) throws IOException {
                return true;
            }
            @Override
            public void handleError(ClientHttpResponse response) throws IOException {
            }
        };
        restTemplate.setErrorHandler(responseErrorHandler);
        return restTemplate;
    }zhi

只需要将hasError方法的返回值更改为true就可以了,以后不管状态码是200还是其它的都会返回结果;

2.设置超时时间

RestTemplate默认使用的是SimpleClientHttpRequestFactory工厂方法,看下它的超时时间是:

	private int connectTimeout = -1;

	private int readTimeout = -1;

默认值都是-1,也就是没有超时时间;

其底层是使用URLConnection,而URLConnection实际上时封装了Socket,Socket我们知道是没有超时时间限制的,所以我们必须设置超时时间,否则如果请求的URL一直卡死程序将会不可以运行下去;

    @Bean
    public ClientHttpRequestFactory simpleClientHttpRequestFactory(){
        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        //读取超时5秒,默认无限限制,单位:毫秒
        factory.setReadTimeout(5000);
        //连接超时10秒,默认无限制,单位:毫秒
        factory.setConnectTimeout(10000);
        return factory;
    }

以上就是RestTemplate设置超时时间及返回状态码非200处理的详细内容,更多关于RestTemplate超时设置非200处理的资料请关注我们其它相关文章!

(0)

相关推荐

  • restTemplate超时处理的策略方案

    目录 htmledit_views-163de54645.css"> 简单定制restTemplate(超时处理) 基于上个例子–===> 简单的RestTemplate示例:(暂时理解URL请求示例)pom.xml添加commons-lang3的支持需要里面的StringUtils方法,比较String字符( StringUtils.equalsAnyIgnoreCase)以及 是否是数字(StringUtils.isNumeric), 添加httpclient作为底层http库.

  • RestTemplate的URL请求示例

    目录 简单的RestTemplate示例 首先pom.xml的配置: Model类: main设置: 简单的RestTemplate示例 暂时理解URL请求示例 (一切的开始是先启动一个web的服务,并且url有效,数据库里当然也要要相应的数据) 首先pom.xml的配置: lombok辅助建立model类和log.info依赖@Slf4j输出日志. 添加web:RestTemplate的依赖 Model类: @Data包含getter和setter等的方法, @Builder创建一个链式的数据

  • 解决RestTemplate 请求接收自定义400+ 或500+错误

    目录 RestTemplate 请求接收自定义400+ 或500+错误 场景 原因 解决办法 自定义RestTemplate的ResponseErrorHandler Spring框架中的RestTemplate处理ClientHttpResponse的方式 并不想让它抛异常 无法使用IOC注入的场景下 RestTemplate 请求接收自定义400+ 或500+错误 场景 当服务端自定义400错误返回体时,使用restTemplate 请求接收不到消息体.而我正想根据不同的错误信息做不同的操作

  • java分布式基于RestTemplate的使用方法

    目录 1.前言 2.RestTemplateget请求及传参 2.1正常get请求不带参 2.2get请求带参使用 2.3编写在线目录扫描脚本 3.RestTemplatepost请求 3.1post请求玩法 3.2mongo-express远程代码执行漏洞脚本编写 4.结尾 1.前言 最近在接触到分布式方面知识的时候,学习了RestTemplate的一些使用.RestTemplate比较常见的就是用来进行一些http请求.本人在使用之后,在语法简洁的同时,感觉非常的方便. 于是乎在后面就想到了

  • RestTemplate设置超时时间及返回状态码非200处理

    目录 1.调试postForEntity请求 2.设置超时时间 默认情况下使用RestTemplate如果返回结果的状态码是200的话就正常处理,否则都会抛出异常: 1.调试postForEntity请求 调试postForEntity请求的方法找到判断响应结果状态码的方法是org.springframework.web.client.DefaultResponseErrorHandler类中的hasError方法 @Override public boolean hasError(Client

  • Springboot RestTemplate设置超时时间的简单方法

    目录 排查: Java Config配置 配置文件指定 RestTemplate 设置超时时间注意点 总结 RestTemplate未设置超时时间,导致RabbitMQ队列大量堆积,消费者假死,不进行消费,类似线程堵塞. 排查: 从日志排查问题,在从进入消费者到结束期间,会调用业务服务,然而通过开始时间至结束时间,花费的时间竟然高达100多秒,查看业务服务未发现异常.出现这种问题的原因也有可能在消费期间网络波动导致HTTP连接出现问题,一直处于等待状态.由此判断可能是HTTP超时时间未设置导致的

  • springcloud之Feign、ribbon如何设置超时时间和重试机制

    Feign.ribbon设置超时时间和重试机制 前言 我们在微服务调用服务的时候,会使用feign和ribbon,比如有一个实例发生了故障而该情况还没有被服务治理机制及时的发现和摘除,这时候客户端访问该节点的时候自然会失败. 所以,为了构建更为健壮的应用系统,我们希望当请求失败的时候能够有一定策略的重试机制,而不是直接返回失败. 先看一个配置: #预加载配置,默认为懒加载 ribbon: eager-load: enabled: true clients: zoo-plus-email zoo-

  • 客户端设置超时时间真的很重要

    概述 在一条慢SQL导致购物车服务无法使用的解决方案一文中,提到了客户端调用购物车服务的时候,超时了.如果当时客户端没有设置超时时间的话,会在客户端中产生级联故障.先用一张图来说明一下. 聚合层除了调用购物车微服务,还调用了营销系统微服务.如果购物车服务的接口响应时间很慢,而客户端聚合层调用购物车服务时,又没有设置超时时间,那么将占有大量的连接,如果请求购物车服务的请求量比较大,瞬间就会把连接占用完,直接导致聚合层调用营销系统时,需要阻塞住等待获取连接,这样的话,整个小程序的很多功能就都用不了了

  • java httpclient设置超时时间和代理的方法

    设置超时时间 设置HttpClient的超时时间,非常有必要性,因为httpclient 默认超时时间很长,自己可以测试一下是多久,设置超时时间否则会影响自己系统的业务逻辑,例如阻塞系统,影响系统的吞吐量,占用线程数. httpclient 4.4版本之后将这些设置封装到 RequestConfig 对象里,其中 setConnectTimeout 是设置连接到目标 URL 的等待时长,超过这个时间还没连上就抛出连接超时: setConnectionRequestTimeout 是从connec

  • 一次.net core异步线程设置超时时间的实战记录

    目录 前言: 需求背景: 需求提炼: .net里设置超时的 Task 测试代码 测试截图 搞定收工 总结 前言: 刷帖子看到一篇 Go 记录一次groutine通信与context控制 看了一下需求背景,挺有意思的,琢磨了下.net core下的实现 需求背景: 项目中需要定期执行任务A来做一些辅助的工作,A的执行需要在超时时间内完成,如果本次执行超时了,那就不对本次的执行结果进行处理(即放弃这次执行).同时A又依赖B,C两个子任务的执行结果.B, C之间相互独立,可以并行的执行.但无论B,C哪

  • PHP请求远程地址设置超时时间的解决方法

    php请求远程地址设置超时时间,主要讲解file_get_contents.fopen.curl这三个简单常用函数设置超时时间的方法,一般情况下建议使用curl,性能最好,效率也最高. 1.file_get_contents 请求超时设置 $timeout = array( 'http'=> array( 'timeout'=>5//设置一个超时时间,单位为秒 ) ); $ctx = stream_context_create($timeout); $text = file_get_conte

  • C++设置超时时间的简单实现方法

    本文实例讲述了C++设置超时时间的简单实现方法,代码简单易懂,功能实用.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: BOOL SetTimeOut(SOCKET s, int nTime, BOOL bRecv)  {      int ret = ::setsockopt(s, SOL_SOCKET, bRecv?SO_RCVTIMEO:SO_SNDTIMEO, (char*)nTime, sizeof(nTime));      return ret!=SOCKET_ER

  • 如何基于java或js获取URL返回状态码

    这篇文章主要介绍了如何基于java或js获取URL返回状态码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 描述:使用java或者js访问某个网站,返回状态码 1.java实现 // 用getResponseCode可以获取URL返回状态码 String surl = ""; try { surl="你的url"; URL url = new URL(surl); URLConnection rulConnecti

  • feign客户端设置超时时间操作

    我就废话不多说了,大家还是直接看代码吧~ /** * feign调用客户端 */ @FeignClient(name = "user", url = "${user.url}", configuration = MyFeignDecoder.class) public interface UserClient { @GetMapping("/rest/user/get/detail/{loginName}") JSONObject getUser

随机推荐