HttpClient4.5 post请求xml到服务器

2019-11-08 01:52:03
字体：大中小
来源：转载
供稿：网友
1.加入HttpClient4.5和junit依赖包
<dependencies>		<dependency>			<groupId>org.apache.httpcomponents</groupId>			<artifactId>httpclient</artifactId>			<version>4.5</version>		</dependency>		<dependency>			<groupId>commons-collections</groupId>			<artifactId>commons-collections</artifactId>			<version>3.2.2</version>		</dependency>		<dependency>			<groupId>junit</groupId>			<artifactId>junit</artifactId>			<version>4.12</version>		</dependency>	</dependencies>
2.编写工具类
import java.io.IOException;import java.security.cert.CertificateException;import java.security.cert.X509Certificate;import java.util.ArrayList;import java.util.List;import java.util.Map;import org.apache.commons.collections.MapUtils;import org.apache.http.Consts;import org.apache.http.HeaderIterator;import org.apache.http.HttpEntity;import org.apache.http.HttPResponse;import org.apache.http.HttpStatus;import org.apache.http.NameValuePair;import org.apache.http.ParseException;import org.apache.http.client.entity.UrlEncodedFormEntity;import org.apache.http.client.methods.HttpPost;import org.apache.http.config.Registry;import org.apache.http.config.RegistryBuilder;import org.apache.http.conn.socket.ConnectionSocketFactory;import org.apache.http.conn.socket.PlainConnectionSocketFactory;import org.apache.http.conn.ssl.NoopHostnameVerifier;import org.apache.http.conn.ssl.SSLConnectionSocketFactory;import org.apache.http.conn.ssl.TrustStrategy;import org.apache.http.entity.StringEntity;import org.apache.http.impl.client.CloseableHttpClient;import org.apache.http.impl.client.HttpClients;import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;import org.apache.http.message.BasicNameValuePair;import org.apache.http.ssl.SSLContextBuilder;import org.apache.http.util.EntityUtils;/** *     * @ClassName: HttpsUtils    * @Description: TODO(https post忽略证书请求) */public class HttpsUtils {	private static final String HTTP = "http";	private static final String HTTPS = "https";	private static SSLConnectionSocketFactory sslsf = null;	private static PoolingHttpClientConnectionManager cm = null;	private static SSLContextBuilder builder = null;	static {		try {			builder = new SSLContextBuilder();			// 全部信任 不做身份鉴定			builder.loadTrustMaterial(null, new TrustStrategy() {				@Override				public boolean isTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {					return true;				}			});			sslsf = new SSLConnectionSocketFactory(builder.build(),					new String[] { "SSLv2Hello", "SSLv3", "TLSv1", "TLSv1.2" }, null, NoopHostnameVerifier.INSTANCE);			Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory> create()					.register(HTTP, new PlainConnectionSocketFactory()).register(HTTPS, sslsf).build();			cm = new PoolingHttpClientConnectionManager(registry);			cm.setMaxTotal(200);// max connection		} catch (Exception e) {			e.printStackTrace();		}	}	/**	 * httpClient post请求	 * 	 * @param url	 *            请求url	 * @param header	 *            头部信息	 * @param param	 *            请求参数 form提交适用	 * @param entity	 *            请求实体 json/xml提交适用	 * @return 可能为空 需要处理	 * @throws Exception	 *	 */	public static String post(String url, Map<String, String> header, Map<String, String> param, StringEntity entity)			throws Exception {		String result = "";		CloseableHttpClient httpClient = null;		try {			httpClient = getHttpClient();			//HttpGet httpPost = new HttpGet(url);//get请求			HttpPost httpPost = new HttpPost(url);//Post请求			// 设置头信息			if (MapUtils.isNotEmpty(header)) {				for (Map.Entry<String, String> entry : header.entrySet()) {					httpPost.addHeader(entry.getKey(), entry.getValue());				}			}			// 设置请求参数			if (MapUtils.isNotEmpty(param)) {				List<NameValuePair> formparams = new ArrayList<NameValuePair>();				for (Map.Entry<String, String> entry : param.entrySet()) {					// 给参数赋值					formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));				}				UrlEncodedFormEntity urlEncodedFormEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);				httpPost.setEntity(urlEncodedFormEntity);			}			// 设置实体 优先级高			if (entity != null) {				httpPost.addHeader("Content-Type", "text/xml"); 				httpPost.setEntity(entity);			}			HttpResponse httpResponse = httpClient.execute(httpPost);			int statusCode = httpResponse.getStatusLine().getStatusCode();			System.out.println("状态码："+statusCode);			if (statusCode == HttpStatus.SC_OK) {				HttpEntity resEntity = httpResponse.getEntity();				result = EntityUtils.toString(resEntity);			} else {				readHttpResponse(httpResponse);			}		} catch (Exception e) {			throw e;		} finally {			if (httpClient != null) {				httpClient.close();			}		}		return result;	}	/**	 * httpClient post请求	 * 	 * @param url	 *            请求url	 * @param header	 *            头部信息	 * @param param	 *            请求参数 form提交适用	 * @param entity	 *            请求实体 json/xml提交适用 (指定参数名的方式来POST数据)	 * @return 可能为空 需要处理	 * @throws Exception	 *	 */	public static String post(String url, Map<String, String> header, Map<String, String> param, HttpEntity entity)			throws Exception {		String result = "";		CloseableHttpClient httpClient = null;		try {			httpClient = getHttpClient();			//HttpGet httpPost = new HttpGet(url);//get请求			HttpPost httpPost = new HttpPost(url);//Post请求			// 设置头信息			if (MapUtils.isNotEmpty(header)) {				for (Map.Entry<String, String> entry : header.entrySet()) {					httpPost.addHeader(entry.getKey(), entry.getValue());				}			}			// 设置请求参数			if (MapUtils.isNotEmpty(param)) {				List<NameValuePair> formparams = new ArrayList<NameValuePair>();				for (Map.Entry<String, String> entry : param.entrySet()) {					// 给参数赋值					formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));				}				UrlEncodedFormEntity urlEncodedFormEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);				httpPost.setEntity(urlEncodedFormEntity);			}			// 设置实体 优先级高			if (entity != null) {				httpPost.setEntity(entity);			}			HttpResponse httpResponse = httpClient.execute(httpPost);			int statusCode = httpResponse.getStatusLine().getStatusCode();			System.out.println("状态码："+statusCode);			if (statusCode == HttpStatus.SC_OK) {				HttpEntity resEntity = httpResponse.getEntity();				result = EntityUtils.toString(resEntity);			} else {				readHttpResponse(httpResponse);			}		} catch (Exception e) {			throw e;		} finally {			if (httpClient != null) {				httpClient.close();			}		}		return result;	}
	public static CloseableHttpClient getHttpClient() throws Exception {		CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(sslsf).setConnectionManager(cm)				.setConnectionManagerShared(true).build();		return httpClient;	}	public static String readHttpResponse(HttpResponse httpResponse) throws ParseException, IOException {		StringBuilder builder = new StringBuilder();		// 获取响应消息实体		HttpEntity entity = httpResponse.getEntity();		// 响应状态		builder.append("status:" + httpResponse.getStatusLine());		builder.append("headers:");		HeaderIterator iterator = httpResponse.headerIterator();		while (iterator.hasNext()) {			builder.append("/t" + iterator.next());		}		// 判断响应实体是否为空		if (entity != null) {			String responseString = EntityUtils.toString(entity);			builder.append("response length:" + responseString.length());			builder.append("response content:" + responseString.replace("/r/n", ""));		}		return builder.toString();	}}
3.测试类
@Test	public void testSendHttpPost2() {		String url = "https://XXXX.XXX.XXX.XXX/XXX/XXX.html";		try {			StringEntity entity = new StringEntity(getXMLString(), "UTF-8"); //不指定参数名的方式来POST数据			String responseContent = HttpsUtils.post(url, null, null, entity);			System.out.println(responseContent);		} catch (Exception e) {			e.printStackTrace();		}	}@Test	public void testSendHttpPost3() {//https://209.160.54.4/suns/XML_Rx.php		String url = "http://10.122.1.92:8080/products.html";		try {			List<NameValuePair> formparams = new ArrayList<NameValuePair>(); 		    formparams.add(new BasicNameValuePair("xmldate", "<html>你好啊啊</html>")); //指定参数名的方式来POST数据		    UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, "UTF-8"); 			String responseContent = HttpsUtils.post(url, null, null, entity);			System.out.println(responseContent);		} catch (Exception e) {			e.printStackTrace();		}	}