文档章节

httpClient 封装

 凌晨一点半
发布于 2015/12/21 20:56
字数 1093
阅读 295
收藏 4
点赞 0
评论 0

HttpClient (CloseableHttpclient) 如果通过连接池管理 通过cookie保持状态值JSESSIONID 自行保持会话分别处理同一会话中的请求.如 匿名登录 验证码 验证码校验 登录等。

处理方式完全可以用连接池去管理httpClient 从而省去不少问题。但是最近测试给我的反应是验证码明明输入正确 但却返回验证码不正确 信息。 总结 原因 很可能是因为 会话未保持。由于时间关系 没精力去分析httpClient 连接池的管理机制,只好自己写了 类似的管理器去存储管理。。。当然这里还有优化的地方 比如获取的时候可以通过spring cache 注解的方式去获取httpClient 无序做过多逻辑判断。代码如下:

package com.yuntai.yun.online.util.http;

import org.apache.http.client.HttpClient;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * Created by hurd on 2015/12/20.
 * 获取httpclient 工厂类
 */
public class HttpClientFactory {

    private static final Logger logger = LoggerFactory.getLogger(HttpClientFactory.class);
    Map<String,HttpClientBody> map = new HashMap<>();

    private int expire = 3600;

    public HttpClient create(String unicode) {

        HttpClientBody body = map.get(unicode);
        if(body == null){
            body =  new HttpClientBody(HttpClientBuilder.create().build(),new Date());
            map.put(unicode,body);
        }else{
            Date expireDate = body.getTimestamp();
            if(((new Date().getTime() - expireDate.getTime())/1000 -expire) > 0){
                logger.info("session过期重新创建");
                try {
                    body.getHttpClient().close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                body = new HttpClientBody(HttpClientBuilder.create().build(),new Date());
                map.put(unicode,body);
            }else{
                body.setTimestamp(new Date());
            }
        }
        return body.getHttpClient();
    }


    /**
     * 定时任务执行 清楚无效的httplient
     */
    public void taskInit(){
        for(String key : map.keySet()){
           HttpClientBody body = map.get(key);
            if(body != null){
                CloseableHttpClient httpClient = body.getHttpClient();
                Date expireDate = body.getTimestamp();
                if(new Date().getTime()  - expireDate.getTime() - expire*1000 < 0){
                    continue;
                }

                try {
                    httpClient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            logger.info("待删除无效的httpClient,key:{},HttpClientBody:{}",key,map.get(key));
            //删除过期或者无效的 httpclient
            map.remove(key);
        }
        logger.info("-----------定时任务清理完成------------");
    }

    public void setExpireTimeSeconds(int time){
        expire = time;
    }

    /**
     * 内部类
     */
    private class HttpClientBody {

        private CloseableHttpClient httpClient;

        public void setTimestamp(Date timestamp) {
            this.timestamp = timestamp;
        }

        private Date timestamp;

        public HttpClientBody(CloseableHttpClient httpClient, Date timestamp) {
            this.httpClient = httpClient;
            this.timestamp = timestamp;
        }

        public CloseableHttpClient getHttpClient() {
            return httpClient;
        }

        public Date getTimestamp() {
            return timestamp;
        }
    }
}
package com.yuntai.yun.online.util.http;

import com.alibaba.fastjson.JSON;
import com.yuntai.med.exception.MedRuntimeException;
import org.apache.commons.lang.builder.ToStringBuilder;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.message.BasicHeader;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * Created by hurd on 2015/12/20.
 */
public class RestHttpClient {

    private static final Logger logger = LoggerFactory.getLogger(RestHttpClient.class);

    @Autowired
    private HttpClientFactory clientFactory;

    /**
     * http client get请求封装
     *
     * @param unicode
     * @param URL
     * @param headMap
     * @return
     */
    public Map<String, ?> doGet(String unicode, String URL, Map<String, ?> headMap) {
        HttpClient httpClient = clientFactory.create(unicode);
        //创建httpGet方法
        HttpGet httpGet = new HttpGet(URL);
        logger.info("准备执行httpget请求,uri={}", httpGet.getURI());
        try {
            //设置头参数
            if (null != headMap && !headMap.isEmpty()) {
                int len = headMap.size();
                Header[] headers = new Header[len];
                for (Map.Entry<String, ?> entry : headMap.entrySet()) {
                    headers[--len] = new BasicHeader(entry.getKey(), entry.getValue().toString());
                }
            }
            //执行http请求返回结果
            HttpResponse response = httpClient.execute(httpGet);
            //返回响应状态
            int status = response.getStatusLine().getStatusCode();
            logger.info("返回响应状态:" + status);
            if (200 != status) {
                logger.info("httpGet请求执行失败,响应消息:{}", response);
                throw new RuntimeException("httpGet请求失败,请检查网络或者重试");
            }
            //获取响应消息
            HttpEntity entity = response.getEntity();
            String content = EntityUtils.toString(entity, "UTF-8");
            logger.info("获取的响应消息:" + content);
            return JSON.parseObject(content, Map.class);
        } catch (IOException e) {
            e.printStackTrace();
            throw new RuntimeException("httpGet请求失败,请检查网络或者重试");
        }
    }

    /**
     * http post 请求封装
     *
     * @param unicode
     * @param URL
     * @param headMap
     * @param bodyMap
     * @return
     */
    public <T> T doPost(String unicode, String URL, Map<String, ?> headMap, Map<String, ?> bodyMap, Class<T> clazz) {
        HttpClient httpClient = clientFactory.create(unicode);
        //创建httppost方法
        HttpPost httpPost = new HttpPost(URL);
        boolean isJSON = false;
        logger.info("准备执行httppost请求,uri={},请求参数:{}", httpPost.getURI(), bodyMap);
        try {
            //设置头参数
            if (null != headMap && !headMap.isEmpty()) {
                int len = headMap.size();
                Header[] headers = new Header[len];
                for (Map.Entry<String, ?> entry : headMap.entrySet()) {
                    headers[--len] = new BasicHeader(entry.getKey(), entry.getValue().toString());
                    if ("Content-Type".equals(entry.getKey()) && ContentType.APPLICATION_JSON.getMimeType().equals(entry.getValue())) {
                        isJSON = true;
                    }
                }
                httpPost.setHeaders(headers);
            }
            //设置body参数
            StringEntity stringEntity = null;
            if (isJSON) {
                stringEntity = new StringEntity(JSON.toJSONString(bodyMap));
                stringEntity.setContentType("text/json");
                stringEntity.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType()));
            } else {
                if (null != bodyMap && !bodyMap.isEmpty()) {
                    List<NameValuePair> formparams = new ArrayList<>();
                    for (Map.Entry<String, ?> entry : bodyMap.entrySet()) {
                        formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));
                    }
                    stringEntity = new UrlEncodedFormEntity(formparams, "utf-8");
                }
            }
            if (null != stringEntity) {
                httpPost.setEntity(stringEntity);
            }

           /* HttpClientContext context = HttpClientContext.create();
            if(!StringUtil.isEmpty(jsessionId)){
                logger.info("会话凭证 JSESSIONID=" + jsessionId);
                Registry<CookieSpecProvider> registry = RegistryBuilder.<CookieSpecProvider>create()
                        .register(CookieSpecs.BEST_MATCH, new BestMatchSpecFactory())
                        .register(CookieSpecs.BROWSER_COMPATIBILITY,
                                new BrowserCompatSpecFactory()).build();
                context.setCookieSpecRegistry(registry);
                CookieStore cookieStore = new BasicCookieStore();
                cookieStore.addCookie(new BasicClientCookie("JSESSIONID",jsessionId));
                context.setCookieStore(cookieStore);
            }*/
            //执行http请求返回结果
            HttpResponse response = httpClient.execute(httpPost);
            //返回响应状态
            int status = response.getStatusLine().getStatusCode();
            logger.info("返回响应状态:" + status);
            if (200 != status) {
                logger.info("httpGet请求执行失败,响应消息:{}", response);
                throw new RuntimeException("httpGet请求失败,请检查网络或者重试");
            }

            //设置上下文会话信息
            logger.info("@#$####"+ToStringBuilder.reflectionToString(response.getAllHeaders()));

            //获取响应消息
            HttpEntity entity = response.getEntity();
            //默认返回字节数组byte[]
            if (null != clazz) {
                if (byte[].class.equals(clazz)) {
                    return (T) EntityUtils.toByteArray(entity);
                }
                if (String.class.equals(clazz)) {
                    return (T) EntityUtils.toString(entity);
                }
                return JSON.parseObject(EntityUtils.toString(entity), clazz);
            }
            throw new MedRuntimeException("4001", "返回值不允许为空");
        } catch (IOException e) {
            e.printStackTrace();
            throw new RuntimeException("httpGet请求失败,请检查网络或者重试");
        }
    }
}


© 著作权归作者所有

共有 人打赏支持
粉丝 3
博文 11
码字总数 6819
作品 0
合肥
程序员
聊聊spring cloud gateway的NettyConfiguration

序 本文主要研究下spring cloud gateway的NettyConfiguration NettyConfiguration spring cloud gateway使用的是reactor的httpclient,其通过nettyClientOptions这个bean来进行构造options,......

go4it ⋅ 06/03 ⋅ 0

解决httpclient超时设置不生效的问题

最近公司有项目需要通过http调用第三方服务,且第三方服务偶有超时,故需要设置一定的超时时间防止不响应的情况出现。 初始设置如下: [java] view plain copy //超时设置 RequestConfig re...

Mr_Tea伯奕 ⋅ 昨天 ⋅ 0

大家都用什么工具发起http请求的呢?

我以前喜欢用apache的 httpClient ,公司用jersey。听经理说jersey的性能好,是真的吗?我在网上并没有搜到相关的性能比较,java9也带了一个httpClient,不知性能对比起来又如何?...

暗中观察 ⋅ 04/22 ⋅ 0

关于HttpClient重试策略的研究

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

kingszelda ⋅ 04/25 ⋅ 0

使用httpClient 调起https url接口

遇到的问题* 1、ssl证书信任,解决方式信任所有证书 2、生成请求体调用httpPost.setEntity()时输出的参数格式有误,有多种Entity可以选择(常用 StringEntity、UrlEncodedFormEntity、FileE...

梦魂清风 ⋅ 05/10 ⋅ 0

聊聊spring cloud的PreserveHostHeaderGatewayFilter

序 本文主要研究下spring cloud gateway的PreserveHostHeaderGatewayFilter GatewayAutoConfiguration spring-cloud-gateway-core-2.0.0.RC2-sources.jar!/org/springframework/cloud/gatew......

go4it ⋅ 06/14 ⋅ 0

Httpclient报Timeout waiting for connection from pool 异常

下面这段代码在定时一分钟的任务里面执行: public String remoteJsonUTF8(String url) { HttpGet get = null; CloseableHttpResponse response = null; String json = null; CloseableHttpCl......

小小的小小snake ⋅ 05/17 ⋅ 0

聊聊spring cloud gateway的streaming-media-types属性

序 本文主要研究下spring cloud gateway的streaming-media-types属性 配置 配置说明 GatewayProperties spring-cloud-gateway-core-2.0.0.RC2-sources.jar!/org/springframework/cloud/gatew......

go4it ⋅ 06/07 ⋅ 0

聊聊spring cloud gateway的RemoveHopByHopHeadersFilter

序 本文主要研究一下spring cloud gateway的RemoveHopByHopHeadersFilter GatewayAutoConfiguration spring-cloud-gateway-core-2.0.0.RC1-sources.jar!/org/springframework/cloud/gateway......

go4it ⋅ 05/30 ⋅ 0

用httpclient监控网站系统运行

java httpclient做一个监控网站运行情况的程序,第一次接触,望大牛指导

消褪少年 ⋅ 05/16 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

volatile和synchronized的区别

volatile和synchronized的区别 在讲这个之前需要先了解下JMM(Java memory Model :java内存模型):并发过程中如何处理可见性、原子性、有序性的问题--建立JMM模型 详情请看:https://baike.b...

MarinJ_Shao ⋅ 29分钟前 ⋅ 0

深入分析Kubernetes Critical Pod(一)

Author: xidianwangtao@gmail.com 摘要:大家在部署Kubernetes集群AddOn组件的时候,经常会看到Annotation scheduler.alpha.kubernetes.io/critical-pod"="",以表示这是一个关键服务,那你知...

WaltonWang ⋅ 36分钟前 ⋅ 0

原子性 - synchronized关键词

原子性概念 原子性提供了程序的互斥操作,同一时刻只能有一个线程能对某块代码进行操作。 原子性的实现方式 在jdk中,原子性的实现方式主要分为: synchronized:关键词,它依赖于JVM,保证了同...

dotleo ⋅ 43分钟前 ⋅ 0

【2018.06.22学习笔记】【linux高级知识 14.4-15.3】

14.4 exportfs命令 14.5 NFS客户端问题 15.1 FTP介绍 15.2/15.3 使用vsftpd搭建ftp

lgsxp ⋅ 53分钟前 ⋅ 0

JeeSite 4.0 功能权限管理基础(Shiro)

Shiro是Apache的一个开源框架,是一个权限管理的框架,实现用户认证、用户授权等。 只要有用户参与一般都要有权限管理,权限管理实现对用户访问系统的控制,按照安全规则或者安全策略控制用户...

ThinkGem ⋅ 昨天 ⋅ 0

python f-string 字符串格式化

主要内容 从Python 3.6开始,f-string是格式化字符串的一种很好的新方法。与其他格式化方式相比,它们不仅更易读,更简洁,不易出错,而且速度更快! 在本文的最后,您将了解如何以及为什么今...

阿豪boy ⋅ 昨天 ⋅ 0

Python实现自动登录站点

如果我们想要实现自动登录,那么我们就需要能够驱动浏览器(比如谷歌浏览器)来实现操作,ChromeDriver 刚好能够帮助我们这一点(非谷歌浏览器的驱动有所不同)。 一、确认软件版本 首先我们...

blackfoxya ⋅ 昨天 ⋅ 0

线性回归原理和实现基本认识

一:介绍 定义:线性回归在假设特证满足线性关系,根据给定的训练数据训练一个模型,并用此模型进行预测。为了了解这个定义,我们先举个简单的例子;我们假设一个线性方程 Y=2x+1, x变量为商...

wangxuwei ⋅ 昨天 ⋅ 0

容器之查看minikue的environment——minikube的环境信息

执行如下命令 mjduan@mjduandeMacBook-Pro:~/Docker % minikube docker-envexport DOCKER_TLS_VERIFY="1"export DOCKER_HOST="tcp://192.168.99.100:2376"export DOCKER_CERT_PATH="/U......

汉斯-冯-拉特 ⋅ 昨天 ⋅ 0

mysql远程连接不上

设置了root所有hosts远程登录,可是远程登录还是失败,原因可能如下: 登录本地数据库 mysql -uroot -p123456 查询用户表 mysql> select user,host,password from mysql.user; 删除密码为空的...

冰公子 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部