`
happyqing
  • 浏览: 3204573 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Java用HttpClient4发送http/https协议get/post请求，发送map，json，xml，txt数据

httpclienthttpsgetpostjson 
阅读更多

 

刚写出来的，还未经测试，

HttpUtil.java

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

import net.sf.json.JSONObject;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.ParseException;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URLEncodedUtils;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
  
/**   
* HTTP工具类
* 发送http/https协议get/post请求，发送map，json，xml，txt数据
* @author happyqing
* @since 2017-04-08  
*/    
public final class HttpUtil {  
	
	private static Log log = LogFactory.getLog(HttpUtil.class);
	
	/**
	 * 执行一个http/https get请求，返回请求响应的文本数据
	 * 
	 * @param url		请求的URL地址，可以带参数?param1=a&parma2=b
	 * @param headerMap	请求头参数map，可以为null
	 * @param paramMap	请求参数map，可以为null
	 * @param charset	字符集
	 * @param pretty	是否美化
	 * @return 			返回请求响应的文本数据
	 */
	public static String doGet(String url, Map<String, String> headerMap, Map<String, String> paramMap, String charset, boolean pretty) {
		//StringBuffer contentSb = new StringBuffer();
		String responseContent = "";
		// http客户端
		CloseableHttpClient httpclient = null;
		// Get请求
		HttpGet httpGet = null;
		// http响应
		CloseableHttpResponse response = null;
		try {
			
			if(url.startsWith("https")){
				httpclient = HttpsSSLClient.createSSLInsecureClient();
	        } else {
	        	httpclient = HttpClients.createDefault();
	        }
			
			// 设置参数
			if (paramMap != null) {
				List <NameValuePair> nvps = new ArrayList <NameValuePair>();
				for (Map.Entry<String, String> entry : paramMap.entrySet()) {
					nvps.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
				}
				//EntityUtils.toString(new UrlEncodedFormEntity(nvps, charset));
				url = url + "?" + URLEncodedUtils.format(nvps, charset);
			}

			// Get请求
			httpGet = new HttpGet(url); // HttpUriRequest httpGet
			
			// 设置header
			if (headerMap != null) {
				for (Map.Entry<String, String> entry : headerMap.entrySet()) {
					httpGet.addHeader(entry.getKey(), entry.getValue());
				}
			}

			// 发送请求，返回响应
			response = httpclient.execute(httpGet);
			
			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
				HttpEntity entity = response.getEntity();
//				BufferedReader reader = new BufferedReader(new InputStreamReader(entity.getContent(), charset));
//                String line;
//                while ((line = reader.readLine()) != null) {
//                    if (pretty)
//                    	contentSb.append(line).append(System.getProperty("line.separator"));
//                    else
//                    	contentSb.append(line);
//                }
//				reader.close();
				responseContent = EntityUtils.toString(entity, charset);
			}
			// EntityUtils.consume(entity);
		} catch (ClientProtocolException e) {
			log.error(e.getMessage(), e);
		} catch (IOException e) {
			log.error(e.getMessage(), e);
		} catch (ParseException e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if(response!=null){
					response.close();
				}
				if(httpGet!=null){
					httpGet.releaseConnection();
				}
				if(httpclient!=null){
					httpclient.close();
				}
			} catch (IOException e) {
				log.error(e.getMessage(), e);
			}
		}
		return responseContent;
	}
	
	/**
     * 执行一个http/https post请求，返回请求响应的文本数据
	 * 
	 * @param url		请求的URL地址，可以带参数?param1=a&parma2=b
	 * @param headerMap	请求头参数map，可以为null
	 * @param paramMap	请求参数map，可以为null
	 * @param charset	字符集
	 * @param pretty	是否美化
	 * @return 			返回请求响应的文本数据
	 */
    public static String doPost(String url, Map<String, String> headerMap, Map<String, String> paramMap, String charset, boolean pretty) {
    	//StringBuffer contentSb = new StringBuffer();
		String responseContent = "";
		// http客户端
		CloseableHttpClient httpclient = null;
		// Post请求
		HttpPost httpPost = null;
		// http响应
		CloseableHttpResponse response = null;
        try {
        	
        	if(url.startsWith("https")){
    			httpclient = HttpsSSLClient.createSSLInsecureClient();
    	    } else {
    	    	httpclient = HttpClients.createDefault();
    	    }
        	
        	// Post请求
            httpPost = new HttpPost(url);
            
			// 设置header
			if (headerMap != null) {
				for (Map.Entry<String, String> entry : headerMap.entrySet()) {
					httpPost.addHeader(entry.getKey(), entry.getValue());
				}
			}
			
			// 设置参数
			if (paramMap != null) {
				List <NameValuePair> nvps = new ArrayList <NameValuePair>();
				for (Map.Entry<String, String> entry : paramMap.entrySet()) {
					nvps.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
				}
				httpPost.setEntity(new UrlEncodedFormEntity(nvps, charset));
			}

			// 发送请求，返回响应
            response = httpclient.execute(httpPost);
			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
				HttpEntity entity = response.getEntity();
//				BufferedReader reader = new BufferedReader(new InputStreamReader(entity.getContent(), charset));
//                String line;
//                while ((line = reader.readLine()) != null) {
//                    if (pretty)
//                    	contentSb.append(line).append(System.getProperty("line.separator"));
//                    else
//                    	contentSb.append(line);
//                }
//				reader.close();
				responseContent = EntityUtils.toString(entity, charset);
			}
			// EntityUtils.consume(entity);
		} catch (UnsupportedEncodingException e) {
			log.error(e.getMessage(), e);
		} catch (ClientProtocolException e) {
			log.error(e.getMessage(), e);
		} catch (IOException e) {
			log.error(e.getMessage(), e);
		} catch (ParseException e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if(response!=null){
					response.close();
				}
				if(httpPost!=null){
					httpPost.releaseConnection();
				}
				if(httpclient!=null){
					httpclient.close();
				}
			} catch (IOException e) {
				log.error(e.getMessage(), e);
			}
		}
        return responseContent;
    }
    
    /**
     * 执行一个http/https post请求， 直接写数据 json,xml,txt
     * 
     * @param url		请求的URL地址
     * @param headerMap	请求头参数map，可以为null
     * @param content	json或xml等字符串内容
     * @param charset	字符集
     * @param pretty	是否美化
     * @return			返回请求响应的文本数据
     */
    public static String writePost(String url, Map<String, String> headerMap, String content, String charset, boolean pretty) {
    	//StringBuffer contentSb = new StringBuffer();
		String responseContent = "";
		// http客户端
		CloseableHttpClient httpclient = null;
		// Post请求
		HttpPost httpPost = null;
		// http响应
		CloseableHttpResponse response = null;
        try {
        	
        	if(url.startsWith("https")){
    			httpclient = HttpsSSLClient.createSSLInsecureClient();
    	    } else {
    	    	httpclient = HttpClients.createDefault();
    	    }
        	
        	// Post请求
            httpPost = new HttpPost(url);
            
			// 设置header
			if (headerMap != null) {
				for (Map.Entry<String, String> entry : headerMap.entrySet()) {
					httpPost.addHeader(entry.getKey(), entry.getValue());
				}
			}
			
			// 字符串Entity
			StringEntity stringEntity = new StringEntity(content, charset);
			stringEntity.setContentType("text/plain"); //application/json,text/xml,text/plain
			httpPost.setEntity(stringEntity);

			// 发送请求，返回响应
            response = httpclient.execute(httpPost);
			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
				HttpEntity entity = response.getEntity();
//				BufferedReader reader = new BufferedReader(new InputStreamReader(entity.getContent(), charset));
//                String line;
//                while ((line = reader.readLine()) != null) {
//                    if (pretty)
//                    	contentSb.append(line).append(System.getProperty("line.separator"));
//                    else
//                    	contentSb.append(line);
//                }
//				reader.close();
				responseContent = EntityUtils.toString(entity, charset);
			}
			// EntityUtils.consume(entity);
		} catch (UnsupportedEncodingException e) {
			log.error(e.getMessage(), e);
		} catch (ClientProtocolException e) {
			log.error(e.getMessage(), e);
		} catch (IOException e) {
			log.error(e.getMessage(), e);
		} catch (ParseException e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if(response!=null){
					response.close();
				}
				if(httpPost!=null){
					httpPost.releaseConnection();
				}
				if(httpclient!=null){
					httpclient.close();
				}
			} catch (IOException e) {
				log.error(e.getMessage(), e);
			}
		}
        return responseContent;
        
    }
    
	// 通过code获取openId
	public static String getOpenId(String code) {
		if (StringUtils.isNotEmpty(code)) {
			String appid = PropertiesUtil.getProperty("wx.appid");
			String secret = PropertiesUtil.getProperty("wx.appsecret");
			String result = HttpUtil.doGet("https://api.weixin.qq.com/sns/oauth2/access_token?appid=" + appid + "&secret=" + secret + "&code=" + code + "&grant_type=authorization_code", null, null, "UTF-8",true);
			if (StringUtils.isNotEmpty(result)) {
				JSONObject json = JSONObject.fromObject(result);
				if (json.get("openid") != null) {
					return json.get("openid").toString();
				}
			}
		}
		return "";
	}

    public static void main(String[] args) {
    	try {
            String y = doGet("http://video.sina.com.cn/life/tips.html", null, null, "GBK", true);
            System.out.println(y);
//        		String accessToken = HttpUtil.doGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=appid&secret=secret", null, null, "UTF-8", true);
//        		System.out.println(accessToken);
//              Map params = new HashMap();
//              params.put("param1", "value1");
//              params.put("json", "{\"aa\":\"11\"}");
//              String j = doPost("http://localhost/uplat/manage/test.do?reqCode=add", null, params, "UTF-8", true);
//              System.out.println(j);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    }

}

 

 

HttpsSSLClient.java

import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;

import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;


/**
 * 创建httpsclient
 * @author happyqing
 * @since 2017-04-07
 */
public class HttpsSSLClient {
 
    /**
     * 获取Https 请求客户端
     * @return
     */
    public static CloseableHttpClient createSSLInsecureClient() {
        SSLContext sslcontext = createSSLContext();
        SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new HostnameVerifier() {
 
            @Override
            public boolean verify(String paramString, SSLSession paramSSLSession) {
                return true;
            }
        });
        CloseableHttpClient httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
        return httpclient;
    }
 
    /**
     * 获取初始化SslContext
     * @return
     */
    private static SSLContext createSSLContext() {
        SSLContext sslcontext = null;
        try {
            sslcontext = SSLContext.getInstance("TLS");
            sslcontext.init(null, new TrustManager[] {new TrustAnyTrustManager()}, new SecureRandom());
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (KeyManagementException e) {
            e.printStackTrace();
        }
        return sslcontext;
    }
 
    /**
     * 自定义静态私有类
     */
    private static class TrustAnyTrustManager implements X509TrustManager {
 
        public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {}
 
        public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {}
 
        public X509Certificate[] getAcceptedIssuers() {
            return new X509Certificate[] {};
        }
    }

}

 

 

参考：

httpclient4.x处理https协议请求

http://www.oschina.net/code/snippet_2376242_50816#74195

 

HttpClient_4 用法 由HttpClient_3 升级到 HttpClient_4 必看

http://www.cnblogs.com/loveyakamoz/archive/2011/07/21/2113252.html

 

用httpclient4.x 发送http get post请求。

http://blog.csdn.net/sunny243788557/article/details/8106265

 

HttpClient-4.3.X 中get和post方法使用

http://www.cnblogs.com/520playboy/p/6344940.html

 

HttpGet &&HttpPost方法发送header,params, Content

http://blog.csdn.net/fhlkm/article/details/7844509

 

分享到：
| spring dbcp连接池配置 BasicDataSource
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    Java后端HttpClient Post提交文件流 及服务端接收文件流

    HttpClient Post提交多文件及多个普通参数,已经封装成工具类。 需传入 要请求的url 普通参数map 例 map.put("param1","张三"); 需要传入的文件流map 其中key为文件名 服务端接收无乱码。

    HttpClientUtil工具类 里面包含GET POST 及返回值处理

    HttpClientUtil工具类是Java开发中一个非常实用的工具，它封装了Apache的HttpClient库，用于简化HTTP请求的发送，包括GET和POST方法。这个工具类的主要优点在于它可以帮助开发者快速地构建网络请求，无需深入了解...

    HttpClient工具类

    本文将详细介绍一个基于`HttpClient`的工具类，它能够帮助开发者轻松地发送GET和POST请求，并支持XML及JSON格式的数据传输。 #### 工具类概述 该工具类名为`HttpClientUtil`，位于包`com.taotao.utils`中。主要...

    httpClient 调用远程接口 获取数据到本地文件夹

    HttpClient是Apache HTTP Components项目的一部分，它是一个强大的Java库，用于执行HTTP请求。在这个场景中，我们使用HttpClient来调用远程接口，从电信公司的网站获取可用的新手机号码信息，并将这些数据存储到本地...

    webservice调用实例，通过HttpClient调用

    同时，根据具体业务需求，可能还需要对返回的数据进行解析，例如使用JSON库（如Jackson或Gson）将响应转换为Java对象。 总之，通过HttpClient调用Web服务是一个涉及网络通信和HTTP协议理解的过程。在实际开发中，...

    android之http协议编程）第三集hjava_http_post.zip

    本教程主要聚焦于HTTP POST方法的使用，这是HTTP协议中的一个核心概念，用于向服务器发送数据。POST请求常用于提交表单、上传文件或者在API接口中传递复杂的数据结构。 首先，我们需要了解HTTP协议的基本原理。HTTP...

    Java Http工具类HttpClientUtil

    多年积累，功能比较强大，可设置路由连接数，时间，请求类型包括get,post, 参数包括urlcode,map,json,xml。注释很清楚。

    android使用JSON进行网络数据交换(服务端、客户端)的实现.rar

    总结，这个压缩包的实现可能涵盖了Android客户端使用Retrofit发送网络请求、解析JSON数据，以及服务器端处理JSON请求并返回的过程。在实际项目中，还需要考虑安全性、性能优化和错误处理等多方面因素。

    Java发送httpPost请求–传消息头，消息体的方法

    在Java编程中，发送HTTP POST请求是常见的网络通信任务，特别是在与远程服务器或API接口进行交互时。Apache HttpClient库提供了一种强大且灵活的方式来实现这一功能。本文将详细讲解如何利用HttpClient工具类发送带...

    Http请求接口方法封装及Demo

    4. **发送请求**：使用HttpClient库的API，构造一个POST请求，并设置请求头、URL和请求主体。 5. **处理响应**：发送请求后，客户端会接收到服务器的响应，包括状态码、响应头和响应体。根据状态码判断请求是否成功...

    http请求工具类

    3. **Header管理**：设置请求头，如`Content-Type`、`Authorization`等，这对于发送JSON或XML数据，或者进行身份验证至关重要。 4. **异步请求**：为了不阻塞UI线程，`HttpUtil`可能提供异步请求方法，如`asyncGet...

    Java灵活易用自封装http客户端

    这些库提供了丰富的功能，包括设置请求方法（GET、POST等）、添加请求头、发送和接收数据等。 对于自封装的HTTP客户端，我们可以创建一个通用的接口，例如名为`PureWaterInterfaces`，其中定义了发起HTTP请求的方法...

    Java调用第三方接口示范的实现

    4. **执行请求**：调用HttpClient对象的`execute`方法，传入HTTP请求对象（HttpGet或HttpPost）以发送请求。 5. **处理响应**：获取响应对象`CloseableHttpResponse`，检查状态码以确认请求成功（例如，状态码200...

    基于httpClient的文件编码导入系统

    HttpClient是Apache开源组织提供的一款强大的HTTP客户端库，它允许开发者在Java环境中发送HTTP请求并接收响应，广泛应用于数据交换、文件上传下载等场景。 首先，我们需要了解HttpClient的基本用法。HttpClient支持...

    RestUtil.zip

    本文将详细介绍如何使用`RestUtil.zip`中的工具类`RestUtil`来实现REST API的调用，包括POST和GET方法，并处理JSON或XML响应数据。`RestUtil`是一个简洁实用的工具，它整合了Maven项目，使得RESTful调用变得更加便捷...

    android调用struts2源码

    在Android应用开发中，有时需要与服务器进行交互，获取或发送数据。在这个场景下，`Struts2`作为一款流行的Java Web框架，被广泛用于构建服务端接口。本示例探讨的是如何在Android客户端调用Struts2源码来实现JSON...

    request处理

    POST请求的参数则放在请求体中，可以是URL编码的形式，也可以是JSON、XML等格式。 5. **处理请求的框架**：例如Spring MVC、Struts2、Express.js（Node.js）等，它们提供了一套结构化的框架来简化请求的处理。 6. ...

    动态从后台获取数据实现搜索下拉框

    接口通常遵循RESTful原则，使用HTTP的GET或POST方法，参数可能包含搜索关键字等信息。 7. **状态管理**：在复杂的前端应用中，需要管理组件间共享的状态，如当前选中的下拉项、搜索结果等。这可以通过Redux、Vuex或...

    Map2-9-10.rar_Android programing_android google map_android htt

    使用`new Request.Builder()`构建请求，指定URL、HTTP方法（GET、POST等）、请求头和请求体。调用OkHttpClient的`newCall(request).enqueue(callback)`方法发起异步请求，回调中处理响应。对于JSON数据，可以使用...

    Android 快捷查询源码.zip项目安卓应用源码下载

    这些库可以用来发送GET或POST请求，处理JSON或XML格式的响应数据。 5. **Java编程**：整个项目是用Java编写的，因此理解和掌握面向对象编程、异常处理、集合框架（List、Map等）以及多线程（如AsyncTask）等Java...

Magicbox
Global site tag (gtag.js) - Google Analytics