JAVA后端主动发送post请求，访问后端接口

短命女 2023-10-10 17:15 18阅读 0赞

需要编写三个工具类进行访问，可能会添加一些依赖，如果访问的接口有登录的拦截需要将其放开才能进行访问，这里缺失的依赖后续补充！！！

> 第一个工具类：用于进行Https请求的HttpClient，代码如下

import java.security.cert.CertificateException;
    import java.security.cert.X509Certificate;
    import javax.net.ssl.SSLContext;
    import javax.net.ssl.TrustManager;
    import javax.net.ssl.X509TrustManager;
    import org.apache.http.conn.ClientConnectionManager;
    import org.apache.http.conn.scheme.Scheme;
    import org.apache.http.conn.scheme.SchemeRegistry;
    import org.apache.http.conn.ssl.SSLSocketFactory;
    import org.apache.http.impl.client.DefaultHttpClient;
    
    //用于进行Https请求的HttpClient
    public class SSLClient extends DefaultHttpClient {
    	public SSLClient() throws Exception {
    		super();
    		SSLContext ctx = SSLContext.getInstance("TLS");
    		X509TrustManager tm = new X509TrustManager() {
    			@Override
    			public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    			}
    
    			@Override
    			public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    			}
    
    			@Override
    			public X509Certificate[] getAcceptedIssuers() {
    				return null;
    			}
    		};
    		ctx.init(null, new TrustManager[] { tm }, null);
    		SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
    		ClientConnectionManager ccm = this.getConnectionManager();
    		SchemeRegistry sr = ccm.getSchemeRegistry();
    		sr.register(new Scheme("https", 443, ssf));
    	}
    }

> 第二个工具类：代码如下

import java.security.cert.CertificateException;
 import java.security.cert.X509Certificate;
 
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.TrustManager;
 import javax.net.ssl.X509TrustManager;
 
 import org.apache.http.client.HttpClient;
 import org.apache.http.conn.ssl.NoopHostnameVerifier;
 import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClients;
 
 /**
 * 
 * ClassName: SkipHttpsUtil
 * 
 * 
 * Description: httpclient跳过https验证
 * 
 * 
 * Copyright: Copyright (c) 2019
 * 
 * 
 * Company: service
 * 
 * @author: maojinqiang
 * @CreateDate: 2019-08-26
 */
 public class SkipHttpsUtil {
 //绕过证书
 public static HttpClient wrapClient() {
 try {
 SSLContext ctx = SSLContext.getInstance("TLS");
 X509TrustManager tm = new X509TrustManager() {
 public X509Certificate[] getAcceptedIssuers() {
 return null;
 }
 
 public void checkClientTrusted(X509Certificate[] arg0,
 String arg1) throws CertificateException {
 }
 
 public void checkServerTrusted(X509Certificate[] arg0,
 String arg1) throws CertificateException {
 }
 };
 ctx.init(null, new TrustManager[] { tm }, null);
 SSLConnectionSocketFactory ssf = new SSLConnectionSocketFactory(
 ctx, NoopHostnameVerifier.INSTANCE);
 CloseableHttpClient httpclient = HttpClients.custom()
 .setSSLSocketFactory(ssf).build();
 return httpclient;
 } catch (Exception e) {
 return HttpClients.createDefault();
 }
 }
 
 }

第三个工具类：代码如下

import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
 import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 
 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.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.message.BasicNameValuePair;
 import org.apache.http.util.EntityUtils;
 
 /*
 * 利用HttpClient进行post请求的工具类
 */
 public class HttpClientUtil {
 public static String doPost(String url,Map<String,String> map,String charset){
 HttpClient httpClient = null;
 HttpPost httpPost = null;
 String result = null;
 try{
 httpClient = new SSLClient();
 httpPost = new HttpPost(url);
 //设置参数
 List<NameValuePair> list = new ArrayList<NameValuePair>();
 Iterator iterator = map.entrySet().iterator();
 while(iterator.hasNext()){
 Entry<String,Object> elem = (Entry<String, Object>) iterator.next();
 list.add(new BasicNameValuePair(elem.getKey(),elem.getValue().toString()));
 }
 if(list.size() > 0){
 UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list,charset);
 httpPost.setEntity(entity);
 }
 HttpResponse response = httpClient.execute(httpPost);
 if(response != null){
 HttpEntity resEntity = response.getEntity();
 if(resEntity != null){
 result = EntityUtils.toString(resEntity,charset);
 }
 }
 }catch(Exception ex){
 ex.printStackTrace();
 }
 return result;
 }
 
 
 public static String doPostHttps(String url,Map<String,Object> map,String charset){
 SkipHttpsUtil skipHttpsUtil=new SkipHttpsUtil();
 CloseableHttpClient httpclient = null;
 CloseableHttpResponse response = null;
 httpclient = (CloseableHttpClient) SkipHttpsUtil.wrapClient();
 HttpPost httpPost = null;
 String result = null;
 try{
 httpPost = new HttpPost(url);
 //设置参数
 List<NameValuePair> list = new ArrayList<NameValuePair>();
 Iterator iterator = map.entrySet().iterator();
 while(iterator.hasNext()){
 Entry<String,Object> elem = (Entry<String, Object>) iterator.next();
 list.add(new BasicNameValuePair(elem.getKey(),elem.getValue().toString()));
 }
 if(list.size() > 0){
 UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list,charset);
 httpPost.setEntity(entity);
 }
 response = httpclient.execute(httpPost);
 if(response != null){
 HttpEntity resEntity = response.getEntity();
 if(resEntity != null){
 result = EntityUtils.toString(resEntity,charset);
 }
 }
 }catch(Exception ex){
 ex.printStackTrace();
 }
 return result;
 }
 
 /**
 * md5加密
 *
 * @param str
 * @return
 */
 public static String md5(String str) {
 try {
 MessageDigest md = MessageDigest.getInstance("MD5");
 md.update(str.getBytes());
 byte[] byteDigest = md.digest();
 int i;
 StringBuffer buf = new StringBuffer("");
 for (byte element : byteDigest) {
 i = element;
 if (i < 0) {
 i += 256;
 }
 if (i < 16) {
 buf.append("0");
 }
 buf.append(Integer.toHexString(i));
 }
 // 32位加密
 return buf.toString().toUpperCase();
 // 16位的加密
 // return buf.toString().substring(8, 24);
 } catch (NoSuchAlgorithmException e) {
 e.printStackTrace();
 return null;
 }
 }
 }

> 代码编写完成，下面是测试

public static void main(String[] args) {
 String httpCalculatTime = "http://localhost:8080/user/list";// 这里存放接口的URL
 Map<String, String> map = new HashMap<>();// 这里是接口的参数，以Map方式进行传递
 map.put("age", 20);
 Object strs = HttpClientUtil.doPost(httpCalculatTime, map, "utf-8");// 进行发送请求，返回请求状态和返回数据
 System.out.println(strs);
 }