文档章节

总结-HttpClient-RetryHandler重试

夜黑人模糊灬
 夜黑人模糊灬
发布于 2017/08/29 10:04
字数 978
阅读 5
收藏 0

目前的项目接口都是http,因此在Java项目中使用apache httpclient进行数据传输、访问。

目前程序中涉及到需要callback操作,product需要被动的接收consume的处理状态,为了最大程度的能够callback成功因此consume在http调用出现问题(如:服务不可用、异常、超时)情况下需要进行重试(retry request),在这里我列举出我找到的retry方案,有些成功有些不成功。

我是用的httpclient版本是4.5.2。关于retry功能我在网上也找了不少的资料,但是都不是我对应的httpclient版本,大多是过时的。

在httpclient版本4.5.2提供了以下几种retry方案:

StandardHttpRequestRetryHandler

 

这种方案没有测试通过StandardHttpRequestRetryHandler实际上是DefaultHttpRequestRetryHandler的子类,这是官方提供的一个标准的retry方案,为了保证幂等性约定resetful接口必须是GET, HEAD, PUT, DELETE, OPTIONS, and TRACE中的一种,如下,是我定义的httpclient pool

public static CloseableHttpClient getHttpClient() {
    PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
    cm.setMaxTotal(MAX_TOTAL);
    cm.setDefaultMaxPerRoute(MAX_PERROUTE);
    CloseableHttpClient httpClient = HttpClients
        .custom()
        .setRetryHandler(new StandardHttpRequestRetryHandler())
        .setConnectionManager(cm)
        .build();
    return httpClient;
}

如下是我的测试代码

@Test
public void test6(){
    HttpPost httpPost=new HttpPost("http://127.0.0.1:8080/testjobs1");
    try {
        rsp=httpClient.execute(httpPost);
        log.info(">> {}",rsp.getStatusLine().getStatusCode());
    } catch (Exception e) {
        log.error(e.getMessage(),e);
    }finally{
        HttpUtil.close(rsp);
    }
}

运行测试,当url错误、后台报错、后台超时等情况的时候不能进行retry,因此放弃了此方案。

DefaultHttpRequestRetryHandler

这种方案没有测试通过,和上面的StandardHttpRequestRetryHandler类似,它提供了一种默认的retry方案,并没有像StandardHttpRequestRetryHandler一样约定接口必须是冥等的,如下,是我定义的httpclient pool

public static CloseableHttpClient getHttpClient() {
    PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
    cm.setMaxTotal(MAX_TOTAL);
    cm.setDefaultMaxPerRoute(MAX_PERROUTE);
    CloseableHttpClient httpClient = HttpClients
        .custom()
        .setRetryHandler(new DefaultHttpRequestRetryHandler())
        .setConnectionManager(cm)
        .build();
    return httpClient;
}

如下是我的测试代码

@Test
public void test6(){
    HttpPost httpPost=new HttpPost("http://127.0.0.1:8080/testjobs1");
    try {
        rsp=httpClient.execute(httpPost);
        log.info(">> {}",rsp.getStatusLine().getStatusCode());
    } catch (Exception e) {
        log.error(e.getMessage(),e);
    }finally{
        HttpUtil.close(rsp);
    }
}

依然没有达到希望的效果。

HttpRequestRetryHandler

可以实现,但是不够完美。在官方文档有这么一段,如下,

HttpRequestRetryHandler myRetryHandler = new HttpRequestRetryHandler() {
    public boolean retryRequest(
        IOException exception,
        int executionCount,
        HttpContext context) {
        if (executionCount >= 5) {
            // Do not retry if over max retry count
            return false;
        }
        if (exception instanceof InterruptedIOException) {
            // Timeout
            return false;
        }
        if (exception instanceof UnknownHostException) {
            // Unknown host
            return false;
        }
        if (exception instanceof ConnectTimeoutException) {
            // Connection refused
            return false;
        }
        if (exception instanceof SSLException) {
            // SSL handshake exception
            return false;
        }
        HttpClientContext clientContext = HttpClientContext.adapt(context);
        HttpRequest request = clientContext.getRequest();
        boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
        if (idempotent) {
            // Retry if the request is considered idempotent
            return true;
        }
        return false;
    }
};
CloseableHttpClient httpclient = HttpClients.custom().setRetryHandler(myRetryHandler).build();

自定义retry实现,这比较灵活,可以根据异常自定义retry机制以及重试次数,并且可以拿到返回信息,如下,是我定义的httpclient pool

public static CloseableHttpClient getHttpClient() {
    HttpRequestRetryHandler retryHandler = new HttpRequestRetryHandler() {
        public boolean retryRequest(
            IOException exception,
            int executionCount,
            HttpContext context) {
            if (executionCount >= 5) {
                // Do not retry if over max retry count
                return false;
            }
            if (exception instanceof InterruptedIOException) {
                // Timeout
                return false;
            }
            if (exception instanceof UnknownHostException) {
                // Unknown host
                return false;
            }
            if (exception instanceof ConnectTimeoutException) {
                // Connection refused
                return false;
            }
            if (exception instanceof SSLException) {
                // SSL handshake exception
                return false;
            }
            HttpClientContext clientContext = HttpClientContext.adapt(context);
            HttpRequest request = clientContext.getRequest();
            boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
            if (idempotent) {
                // Retry if the request is considered idempotent
                return true;
            }
            return false;
        }
    };
    PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
    cm.setMaxTotal(MAX_TOTAL);
    cm.setDefaultMaxPerRoute(MAX_PERROUTE);
    CloseableHttpClient httpClient = HttpClients
        .custom()
        .setRetryHandler(retryHandler)
        .setConnectionManager(cm)
        .build();
    return httpClient;
}

如下是我的测试代码

@Test
public void test6(){
    HttpPost httpPost=new HttpPost("http://127.0.0.1:8080/testjobs1");
    try {
        rsp=httpClient.execute(httpPost);
        log.info(">> {}",rsp.getStatusLine().getStatusCode());
    } catch (Exception e) {
        log.error(e.getMessage(),e);
    }finally{
        HttpUtil.close(rsp);
    }
}

这种方案,可以实现retry,并且可以根据我的需求进行retry,如:retry count,但是就不能控制retry时间的间隔,也只好放弃了,继续寻找找到了下面这个ServiceUnavailableRetryStrategy

ServiceUnavailableRetryStrategy

可以实现,满足需求,这具有HttpRequestRetryHandler的所有有点,并且可以自定义retry时间的间隔,如下,是我定义的httpclient pool,

public static CloseableHttpClient getHttpClient() {
    ServiceUnavailableRetryStrategy serviceUnavailableRetryStrategy = new ServiceUnavailableRetryStrategy() {
        /**
         * retry逻辑
         */
        @Override
        public boolean retryRequest(HttpResponse response, int executionCount, HttpContext context) {
            if (executionCount <= 3)
                return true;
            else
                return false;
        }
        /**
         * retry间隔时间
         */
        @Override
        public long getRetryInterval() {
            return 2000;
        }
    };
    PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
    cm.setMaxTotal(MAX_TOTAL);
    cm.setDefaultMaxPerRoute(MAX_PERROUTE);
    CloseableHttpClient httpClient = HttpClients.custom().setRetryHandler(new DefaultHttpRequestRetryHandler())
        .setConnectionManager(cm).build();
    return httpClient;
}

如下是我的测试代码

@Test
public void test6(){
    HttpPost httpPost=new HttpPost("http://127.0.0.1:8080/testjobs1");
    try {
        rsp=httpClient.execute(httpPost);
        log.info(">> {}",rsp.getStatusLine().getStatusCode());
    } catch (Exception e) {
        log.error(e.getMessage(),e);
    }finally{
        HttpUtil.close(rsp);
    }
}

© 著作权归作者所有

共有 人打赏支持
夜黑人模糊灬
粉丝 7
博文 69
码字总数 45164
作品 0
程序员
聊聊spring cloud的AbstractLoadBalancingClient

序 本文主要研究一下spring cloud的AbstractLoadBalancingClient AbstractLoadBalancingClient spring-cloud-netflix-ribbon-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/netfli......

go4it
07/18
0
0
关于HttpClient重试策略的研究

原文出处:kingszelda 一、背景 由于工作上的业务本人经常与第三方系统交互,所以经常会使用HttpClient与第三方进行通信。对于交易类的接口,订单状态是至关重要的。 这就牵扯到一系列问题:...

kingszelda
04/25
0
0
httpclient4.4 出现NoHttpResponseException的异常解决

httpclient4.4简单初始化httpclient的方式: 使用连接池初始化httpclient的方式: 但在测试过程中发现,有时候出现如下的异常,但重试一次就没有问题: 网上查了相关的报错信息,找到官网上的...

一路向北的兔斯基
2015/07/30
0
1
Zuul 1.x 重试策略(源码分析)

前言 上一篇文章中阐述了zuul的基本架构组成,并且将核心关键类相应做了标注以及分析,但是并未详细深入到关键性的细节,本篇文章主要是是探索zuul超时重试,服务降级的机制。 重试/服务降级...

世界和平维护者
07/08
0
0
Apache Client使用说明第一章(第二部分)

1.2 HttpClient接口 HttpClient接口代表了HTTP请求执行最重要的约定.它规定了请求执行过程无任何和限制或者特定的细节以及审阅连接管理,状态管理,认证和重定向处理的实现等细节.这使得装饰接...

第五郎
2015/11/05
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

dubbo部分常见的面试题目

1、什么是AMQP协议? AMQP的全称是 Advanced Message Queuing Protocol (高级消息队列协议) 他是应用层协议的一个开放的标准,为面向消息中间件而设计,基于此协议的客户端和消息中间件可以...

DemonsI
10分钟前
0
0
http和https协议

HTTPS全称为Hypertext Transfer Protocol over Secure Socket Layer,中文含义为“超文本传输协议在安全加密字层”,简单来说就是加密数据传输,通俗的说就是安全连接。 HTTPS安全超文本传输...

寰宇01
11分钟前
0
0
vue内引入语音播报功能

在vue项目中引入语音播报,使用的科大讯飞语音接入, 具体思路为每次接收到语音信息后存入一个数组,然后监听这个数组,开始冲第一个索引播放,并且同时根据vuex getter 来动态删减数量 给a...

originDu
20分钟前
0
0
Java创建对象的五种方式

一、使用new关键字,调用构造方法创建对象 Person p1 = new Person(); 运行过程: 1、给新对象分配内存空间,将数据存储到堆。 2、执行显示的初始化。 3、执行构造器。new方法中括号参数传递...

Drathin
20分钟前
0
0
git使用纪要

之前公司一直没用git,于是自己注册了一个账号自己用,因为也没人合作,所以也没太关注协作方面的事情。最近公司终于想通了,开始用git,于是研究了一下,在此做个记录。 git功能非常灵活,因...

propagator
25分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部