聊聊HttpClient的RedirectStrategy

序

本文主要研究一下HttpClient的RedirectStrategy

RedirectStrategy

org/apache/http/client/RedirectStrategy.java

public interface RedirectStrategy {/*** Determines if a request should be redirected to a new location* given the response from the target server.** @param request the executed request* @param response the response received from the target server* @param context the context for the request execution** @return {@code true} if the request should be redirected, {@code false}* otherwise*/boolean isRedirected(HttpRequest request,HttpResponse response,HttpContext context) throws ProtocolException;/*** Determines the redirect location given the response from the target* server and the current request execution context and generates a new* request to be sent to the location.** @param request the executed request* @param response the response received from the target server* @param context the context for the request execution** @return redirected request*/HttpUriRequest getRedirect(HttpRequest request,HttpResponse response,HttpContext context) throws ProtocolException;}

RedirectStrategy接口定义了isRedirected方法用于判断是否需要redirect，还定义了getRedirect方法用于返回redirect的目标地址

DefaultRedirectStrategy

org/apache/http/impl/client/DefaultRedirectStrategy.java

@Contract(threading = ThreadingBehavior.IMMUTABLE)
public class DefaultRedirectStrategy implements RedirectStrategy {private final Log log = LogFactory.getLog(getClass());/*** @deprecated (4.3) use {@link org.apache.http.client.protocol.HttpClientContext#REDIRECT_LOCATIONS}.*/@Deprecatedpublic static final String REDIRECT_LOCATIONS = "http.protocol.redirect-locations";public static final DefaultRedirectStrategy INSTANCE = new DefaultRedirectStrategy();private final String[] redirectMethods;public DefaultRedirectStrategy() {this(new String[] {HttpGet.METHOD_NAME,HttpHead.METHOD_NAME});}/*** Constructs a new instance to redirect the given HTTP methods.** @param redirectMethods The methods to redirect.* @since 4.5.10*/public DefaultRedirectStrategy(final String[] redirectMethods) {super();final String[] tmp = redirectMethods.clone();Arrays.sort(tmp);this.redirectMethods = tmp;}@Overridepublic boolean isRedirected(final HttpRequest request,final HttpResponse response,final HttpContext context) throws ProtocolException {Args.notNull(request, "HTTP request");Args.notNull(response, "HTTP response");final int statusCode = response.getStatusLine().getStatusCode();final String method = request.getRequestLine().getMethod();final Header locationHeader = response.getFirstHeader("location");switch (statusCode) {case HttpStatus.SC_MOVED_TEMPORARILY:return isRedirectable(method) && locationHeader != null;case HttpStatus.SC_MOVED_PERMANENTLY:case HttpStatus.SC_TEMPORARY_REDIRECT:return isRedirectable(method);case HttpStatus.SC_SEE_OTHER:return true;default:return false;} //end of switch}/*** @since 4.2*/protected boolean isRedirectable(final String method) {return Arrays.binarySearch(redirectMethods, method) >= 0;}@Overridepublic HttpUriRequest getRedirect(final HttpRequest request,final HttpResponse response,final HttpContext context) throws ProtocolException {final URI uri = getLocationURI(request, response, context);final String method = request.getRequestLine().getMethod();if (method.equalsIgnoreCase(HttpHead.METHOD_NAME)) {return new HttpHead(uri);} else if (method.equalsIgnoreCase(HttpGet.METHOD_NAME)) {return new HttpGet(uri);} else {final int status = response.getStatusLine().getStatusCode();return status == HttpStatus.SC_TEMPORARY_REDIRECT? RequestBuilder.copy(request).setUri(uri).build(): new HttpGet(uri);}}}

DefaultRedirectStrategy实现了RedirectStrategy接口，它定义了redirectMethods，默认是Get和Head；isRedirected方法先获取response的statusCode，对于302需要location的header有值且请求method在redirectMethods中(isRedirectable)，对于301及307仅仅判断isRedirectable，对于303返回true，其余的返回false

getRedirect方法先通过getLocationURI获取目标地址，然后针对get或者head分别构造HttpHead及HttpGet，剩下的根据statusCode判断，是307则拷贝原来的request，否则返回HttpGet

RedirectExec

org/apache/http/impl/execchain/RedirectExec.java

/*** Request executor in the request execution chain that is responsible* for handling of request redirects.* <p>* Further responsibilities such as communication with the opposite* endpoint is delegated to the next executor in the request execution* chain.* </p>** @since 4.3*/
@Contract(threading = ThreadingBehavior.IMMUTABLE_CONDITIONAL)
public class RedirectExec implements ClientExecChain {private final Log log = LogFactory.getLog(getClass());private final ClientExecChain requestExecutor;private final RedirectStrategy redirectStrategy;private final HttpRoutePlanner routePlanner;public RedirectExec(final ClientExecChain requestExecutor,final HttpRoutePlanner routePlanner,final RedirectStrategy redirectStrategy) {super();Args.notNull(requestExecutor, "HTTP client request executor");Args.notNull(routePlanner, "HTTP route planner");Args.notNull(redirectStrategy, "HTTP redirect strategy");this.requestExecutor = requestExecutor;this.routePlanner = routePlanner;this.redirectStrategy = redirectStrategy;}@Overridepublic CloseableHttpResponse execute(final HttpRoute route,final HttpRequestWrapper request,final HttpClientContext context,final HttpExecutionAware execAware) throws IOException, HttpException {Args.notNull(route, "HTTP route");Args.notNull(request, "HTTP request");Args.notNull(context, "HTTP context");final List<URI> redirectLocations = context.getRedirectLocations();if (redirectLocations != null) {redirectLocations.clear();}final RequestConfig config = context.getRequestConfig();final int maxRedirects = config.getMaxRedirects() > 0 ? config.getMaxRedirects() : 50;HttpRoute currentRoute = route;HttpRequestWrapper currentRequest = request;for (int redirectCount = 0;;) {final CloseableHttpResponse response = requestExecutor.execute(currentRoute, currentRequest, context, execAware);try {if (config.isRedirectsEnabled() &&this.redirectStrategy.isRedirected(currentRequest.getOriginal(), response, context)) {if (redirectCount >= maxRedirects) {throw new RedirectException("Maximum redirects ("+ maxRedirects + ") exceeded");}redirectCount++;final HttpRequest redirect = this.redirectStrategy.getRedirect(currentRequest.getOriginal(), response, context);if (!redirect.headerIterator().hasNext()) {final HttpRequest original = request.getOriginal();redirect.setHeaders(original.getAllHeaders());}currentRequest = HttpRequestWrapper.wrap(redirect);if (currentRequest instanceof HttpEntityEnclosingRequest) {RequestEntityProxy.enhance((HttpEntityEnclosingRequest) currentRequest);}final URI uri = currentRequest.getURI();final HttpHost newTarget = URIUtils.extractHost(uri);if (newTarget == null) {throw new ProtocolException("Redirect URI does not specify a valid host name: " +uri);}// Reset virtual host and auth states if redirecting to another hostif (!currentRoute.getTargetHost().equals(newTarget)) {final AuthState targetAuthState = context.getTargetAuthState();if (targetAuthState != null) {this.log.debug("Resetting target auth state");targetAuthState.reset();}final AuthState proxyAuthState = context.getProxyAuthState();if (proxyAuthState != null && proxyAuthState.isConnectionBased()) {this.log.debug("Resetting proxy auth state");proxyAuthState.reset();}}currentRoute = this.routePlanner.determineRoute(newTarget, currentRequest, context);if (this.log.isDebugEnabled()) {this.log.debug("Redirecting to '" + uri + "' via " + currentRoute);}EntityUtils.consume(response.getEntity());response.close();} else {return response;}} catch (final RuntimeException ex) {response.close();throw ex;} catch (final IOException ex) {response.close();throw ex;} catch (final HttpException ex) {// Protocol exception related to a direct.// The underlying connection may still be salvaged.try {EntityUtils.consume(response.getEntity());} catch (final IOException ioex) {this.log.debug("I/O error while releasing connection", ioex);} finally {response.close();}throw ex;}}}}

RedirectExec实现了ClientExecChain接口，其构造器要求传入requestExecutor、redirectStrategy、routePlanner，其execute方法会先获取maxRedirects参数，然后执行requestExecutor.execute，接着在config.isRedirectsEnabled()以及redirectStrategy.isRedirected为true时才进入redirect逻辑，它会先判断是否超出maxRedirects，大于等于则抛出RedirectException，否则通过redirectStrategy.getRedirect获取HttpRequest，更新currentRoute，然后清理entity关闭response继续下次循环，即执行redirect逻辑。

小结

HttpClient的RedirectStrategy定义了两个方法，一个是是否需要redirect，一个是获取redirect的请求，DefaultRedirectStrategy的构造器支持传入redirectMethods，默认是Get和Head，isRedirected方法主要是对302,301,307,303进行了判断，getRedirect方法主要是通过location获取目标地址，然后根据原来的method和statusCode构造HttpUriRequest。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/109120.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Windows运维相关经验技巧

Windows运维相关经验技巧

常用工具 在线PS Photoshop在线 FAQ 电脑能上网&#xff0c;浏览器上不了网 # 错误原因&#xff1a; 设置了网络代理&#xff0c;浏览器无法通过网络代理上网# 解决办法 关闭网络代理 &#xff08;1&#xff09;wini&#xff0c;打开设置 &#xff08;2&#xff09;网络和I…
阅读更多...
【前端学习】—函数防抖（十）

【前端学习】—函数防抖（十）

【前端学习】—函数防抖&#xff08;十&#xff09; 一、什么是函数防抖 函数防抖&#xff1a;事件被触发n秒后再执行回调&#xff0c;如果在这n秒内又被触发&#xff0c;则重新计时。 二、代码实现 <script>const searchElement document.getElementById("searc…
阅读更多...
多语言跨境商城源码搭建（定制代码+源码开源）

多语言跨境商城源码搭建（定制代码+源码开源）

在全球化的背景下&#xff0c;跨境电商发展迅猛&#xff0c;多语言商城成为企业拓展海外市场的首要选择。本文将为大家介绍跨境多语言商城的源码搭建方法&#xff0c;以及相关的定制代码和源码开源信息。 一、什么是跨境多语言商城 跨境多语言商城是一种能够支持多国语言的电子…
阅读更多...
黑马程序员Java Web--14.综合案例--修改功能实现

黑马程序员Java Web--14.综合案例--修改功能实现

一、BrandMapper包 首先&#xff0c;在BrandMapper包中定义用来修改的方法&#xff0c;和使用注解的sql语句。 BrandMapper包所在路径&#xff1a; package com.itheima.mapper; /**** 修改* **/Update("update tb_brand set brand_name #{brandName},company_name #{c…
阅读更多...
XTU-OJ 1339-Interprime

XTU-OJ 1339-Interprime

题目描述 n是两个连续的奇素数的平均值&#xff0c;且n不是素数&#xff0c;那么我们称这样的数是"内部素数"。求区间[a,b]内"内部素数"的个数。比如&#xff0c;前5个"内部素数"是4,6,9,12,15。 输入 第一行是样例数T(1≤T≤1000)。 每个样例一…
阅读更多...
站外引流之道：跨境电商如何吸引更多流量？

站外引流之道：跨境电商如何吸引更多流量？

随着跨境电商行业的蓬勃发展&#xff0c;站外引流成为卖家们必须掌握的关键技能。站外引流不仅有助于扩大产品曝光度&#xff0c;还能吸引更多潜在客户&#xff0c;提高销售额。 然而&#xff0c;站外引流并非易事&#xff0c;需要精心策划和执行。本文将探讨站外引流的策略&a…
阅读更多...
外置告警蜂鸣器使用小坑

外置告警蜂鸣器使用小坑

告警蜂鸣器调试小坑 昨天调试新产品&#xff0c;由于IMO、MSC组织和IEC标准规定&#xff0c;不能使用带红色指示灯的蜂鸣器&#xff0c;于是更换了个不带灯。然而奇怪的现象出现了两次短响的程序在有的页面正常&#xff0c;有的页面就变成一声了。搞了一天&#xff0c;把各种寄…
阅读更多...
服务器数据恢复-linux+raid+VMwave ESX数据恢复案例

服务器数据恢复-linux+raid+VMwave ESX数据恢复案例

服务器数据恢复环境&#xff1a; 一台某品牌x3950 X6型号服务器&#xff0c;linux操作系统&#xff0c;12块硬盘组建了一组raid阵列&#xff0c;上层运行VMwave ESX虚拟化平台。 服务器故障&#xff1a; 在服务器运行过程中&#xff0c;该raid阵列中有硬盘掉线&#xff0c;linu…
阅读更多...
SAP VA02R批量修改销售订单拒绝原因的BAPI：BAPI_SALESORDER_CHANGE

SAP VA02R批量修改销售订单拒绝原因的BAPI：BAPI_SALESORDER_CHANGE

VA02修改销售订单拒绝原因的BAPI&#xff1a;BAPI_SALESORDER_CHANGE *&---------------------------------------------------------------------* *& Form rechazar *&---------------------------------------------------------------------* FORM rech…
阅读更多...
TDengine 签约中石化，支撑八大油田 PCS 系统

TDengine 签约中石化，支撑八大油田 PCS 系统

近日&#xff0c;TDengine 成功签约中国石化 PCS 一级部署时序数据库项目。未来&#xff0c;TDengine 将作为中国石化 PCS 系统的时序数据库&#xff0c;为石化总部、胜利油田、西北油田、中原油田、河南油田、华北油田、江苏油田、华东油田、江汉油田等油田 PCS 系统提供高效、…
阅读更多...
在Spring中，标签管理的Bean中，为什么使用@Autowired自动装配修饰引用类（前提条件该引用类也是标签管理的Bean）

在Spring中，标签管理的Bean中，为什么使用@Autowired自动装配修饰引用类（前提条件该引用类也是标签管理的Bean）

Autowired是Spring框架的一个注解&#xff0c;它可以用来完成自动装配。 自动装配是Spring框架的一个特性&#xff0c;它可以避免手动去注入依赖&#xff0c;而是由框架自动注入。这样可以减少代码的重复性和提高开发效率。 在使用Autowired注解时&#xff0c;Spring会自动搜…
阅读更多...
C# 开发工具包 – 现已正式发布

C# 开发工具包 – 现已正式发布

作者&#xff1a;Wendy Breiding 排版&#xff1a;Alan Wang 今天&#xff0c;我们很高兴地宣布 C# 开发工具包正式发布&#xff0c;C# 开发工具包是一个 Visual Studio Code 扩展&#xff0c;为 Linux、macOS 和 Windows 带来了改进的编辑器优先 C# 开发体验。 谢谢社区的努…
阅读更多...
vscode提示扩展主机在过去5分钟内意外终止了3次，解决方法

vscode提示扩展主机在过去5分钟内意外终止了3次，解决方法

参考链接&#xff1a; https://code.visualstudio.com/blogs/2021/02/16/extension-bisect https://code.visualstudio.com/docs/setup/uninstall#_clean-uninstall 使用vscode打开jupyter notebook记事本时&#xff0c;窗口右下角提示扩展主机在过去5分钟内意外终止了3次 而…
阅读更多...
条款33、避免遮掩继承而来的名称

条款33、避免遮掩继承而来的名称

核心 基类的成员函数和派生类的成员函数不会构成重载&#xff0c;如果派生类有同名函数&#xff0c;那么就会遮蔽基类中的所有(意味着所有重载的都会被遮蔽)同名函数。 解决方案 使用using using Base::func; //会释放出所有的函数名为func的函数
阅读更多...
C++初阶--C++入门（1）

C++初阶--C++入门（1）

文章目录 C语言与C命名空间命名空间的定义和使用 C的输入输出缺省参数函数重载引用赋值与引用引用在参数上的使用以及注意事项函数返回值的引用引用与值的时间效率比较常引用 C语言与C 很多初学者都会把这两门语言进行混淆&#xff0c;但其实这是两种不同的语言&#xff0c;C相…
阅读更多...
HTML5播放 M3U8的hls流地址

HTML5播放 M3U8的hls流地址

在HTML5页面上播放M3U8的hls流地址 <!DOCTYPE html> <html> <head> <meta charset"UTF-8"> <title>视频播放</title> <script src"https://cdn.jsdelivr.net/npm/hls.jslatest"></script> &…
阅读更多...
Apache Doris 2.0.2 版本正式发布！

Apache Doris 2.0.2 版本正式发布！

峰会官网已上线&#xff0c;最新议程请关注&#xff1a;doris-summit.org.cn 点击报名 亲爱的社区小伙伴们&#xff0c;Apache Doris 2.0.2 版本已于 2023 年 10 月 6 日正式发布&#xff0c;该版本对多个功能进行了更新优化&#xff0c;旨在更好地满足用户的需求。有 92 位贡献…
阅读更多...
CSS3 渐变

CSS3 渐变

CSS3 渐变可以让你在两个或多个指定的颜色之间显示平稳的过渡。 CSS3渐变有两种类型&#xff1a;线性渐变&#xff08;Linear Gradients&#xff09;和径向渐变&#xff08;Radial Gradients&#xff09;。 线性渐变&#xff08;Linear Gradients&#xff09;&#xff1a; 线性…
阅读更多...
看了我项目中购物车、订单、支付一整套设计，同事也开始悄悄模仿了...

看了我项目中购物车、订单、支付一整套设计，同事也开始悄悄模仿了...

在我的mall电商实战项目中&#xff0c;有着从商品加入购物车到订单支付成功的一整套功能&#xff0c;这套功能的设计与实现对于有购物需求的网站来说&#xff0c;应该是一套通用设计了。今天给大家介绍下这套功能设计&#xff0c;涵盖购物车、生成确认单、生成订单、取消订单以…
阅读更多...
VScode折叠代码

VScode折叠代码

问题现状 代码看的我很烦&#xff0c; 有大段大段好像没有逻辑意义的部分&#xff0c;像大量的print语句&#xff0c; 想能不能折叠起来 在设置里面找 搜索Folding&#xff0c;找到Show Folding Controls&#xff0c; 换成always吧&#xff0c;一般默认是mouseover&#x…
阅读更多...
最新文章

Copyright @ 2022~2023