java使用Http链接接口

梦里梦外; 2023-06-08 10:51 19阅读 0赞

package cn.linkey.rulelib.test;
    
    import java.nio.charset.Charset;
    import java.security.cert.CertificateException;
    import java.security.cert.X509Certificate;
    import java.util.HashMap;
    import java.util.Map;
    
    import javax.net.ssl.HttpsURLConnection;
    import javax.net.ssl.SSLContext;
    import javax.net.ssl.TrustManager;
    import javax.net.ssl.X509TrustManager;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.http.HttpEntity;
    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.conn.ssl.SSLConnectionSocketFactory;
    import org.apache.http.conn.ssl.SSLContextBuilder;
    import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    
    import com.alibaba.fastjson.JSONArray;
    
    @SuppressWarnings("deprecation")
    public class HttpSSLTest {
    
    	static String ad = "";
    
    	private static void getLogin(CloseableHttpClient http) throws Exception {
    		String url = ad + "/login";
    		HashMap<String, String> map = new HashMap<String, String>();
    		map.put("username", "admin");// admpadmin
    		map.put("password", "admin");// CMDB#admp
    
    		// BeanCtx.out("1");
    		String postSend = postSend(map, url, http);
    		System.out.println("postSend=" + postSend);
    	}
    
    	public static String getAppInfo(String condition) {
    		try {
    			SSLContextBuilder builder = new SSLContextBuilder();
    			builder.loadTrustMaterial(null, new TrustSelfSignedStrategy());
    			SSLConnectionSocketFactory sslFactory = new SSLConnectionSocketFactory(builder.build());
    			CloseableHttpClient http = HttpClients.custom().setSSLSocketFactory(sslFactory).build();
    			// BeanCtx.out("0");
    			getLogin(http);
    			if (StringUtils.isBlank(condition)) {
    				String url2 = ad + "/getAllApp";
    				String list = Get(url2, http);
    				return list;
    			} else {
    				HashMap<String, String> map2 = new HashMap<String, String>();
    				map2.put("condition", condition);
    				String url3 = ad + "/getAppByCondition";
    				String list = postSend(map2, url3, http);
    				return list;
    			}
    		} catch (Exception e) {
    			// TODO Auto-generated catch block
    			System.out.println(e);
    			return "";
    		}
    	}
    
    	public static String getDbInfo(String appID) throws Exception {
    		try {
    			// 禁止证书验证
    			SSLContextBuilder builder = new SSLContextBuilder();
    			builder.loadTrustMaterial(null, new TrustSelfSignedStrategy());
    			SSLConnectionSocketFactory sslFactory = new SSLConnectionSocketFactory(builder.build());
    			CloseableHttpClient http = HttpClients.custom().setSSLSocketFactory(sslFactory).build();
    			// BeanCtx.out("0");
    			getLogin(http);
    			String url2 = ad + "/etAppDataBase?appID=" + appID;
    			String res = Get(url2, http);
    
    			// String json = JSONArray.toJSONString(ll);
    			return res;
    		} catch (Exception e) {
    			// TODO Auto-generated catch block
    			System.out.println(e);
    			return null;
    		}
    	}
    
    	public static String Get(String url, CloseableHttpClient http) throws Exception {
    
    		HttpGet httpget = new HttpGet(url);
    
    		// System.out.println("Executing request " + httpget.getRequestLine());
    		String body = "";
    		CloseableHttpResponse response = http.execute(httpget);
    		// response.
    
    		// 获取结果实体
    		HttpEntity entity = response.getEntity();
    		if (entity != null) {
    			// 按指定编码转换结果实体为String类型
    			body = EntityUtils.toString(entity, "utf-8");
    		}
    		// EntityUtils.consume(entity);
    		// The server refused this request because the request entity is in a format not
    		// supported by the requested resource for the requested method.
    		// 释放链接
    		// System.out.println(body);
    		response.close();
    		body = body.replaceAll("/", ",");
    		return body;
    	}
    
    	public static String postSend(Map<String, String> map, String url, CloseableHttpClient http) throws Exception {
    
    		String body = "";
    		String encoding = "utf-8";
    		// 创建httpclient对象
    		// 创建post方式请求对象
    		// trustAllHosts();
    		HttpPost httpPost = new HttpPost(url);
    		// System.out.println(url);
    		// 装填参数
    		/*
    		 * List<NameValuePair> nvps = new ArrayList<NameValuePair>(); if (map != null) {
    		 * for (Entry<String, String> entry : map.entrySet()) {
    		 * //System.out.println(entry.getKey()+"=="+ entry.getValue()); nvps.add(new
    		 * BasicNameValuePair(entry.getKey(), entry.getValue())); } } // 设置参数到请求对象中
    		 * httpPost.setEntity(new UrlEncodedFormEntity(nvps, encoding));
    		 */
    		// System.out.println(JSONArray.toJSONString(map));
    		httpPost.setEntity(new StringEntity(JSONArray.toJSONString(map), Charset.forName("UTF-8")));
    
    		// 设置header信息
    		// 指定报文头【Content-type】、【User-Agent】
    		httpPost.setHeader("Content-type", "application/json;charset=utf-8");
    		httpPost.setHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
    		// httpPost.setHeader("Cookie",
    		// "__RequestVerificationToken=chnnebtmwF4wywnr_rhTpb5uBZIsZ9REvHkFYC4PjobRk1aQx2KSY-8u3Kv3b8j6BBbDwbGg-BZkuydOk8zTOrmjyP5l2DeAXBEFAkk-ZWL_jQTwdx8cITH_SbK_qu6GsmCs-l8yTupmVjH5BpKdyA2;
    		// .AUTHTOKEN=E915F2C6D6F437786142D0D190FC7F5A9F1C6C04BA080F24E8AD258106BE45C7053FE362F92043B3C684F8B44BCE868319EE309150C0EAF0CF5477825DB526668275F8005F7D3F6536B3CE70318448AE6BA77D4C989BCC77A92A2FC905F5857574261C1A06C308DC8C45027D65BE6D9D1EC02E9CF27759811F4997BAA63673CE8061EF4BEBD5B14C449F59FF5B440BE8");
    
    		// 执行请求操作，并拿到结果（同步阻塞）
    		CloseableHttpResponse response = http.execute(httpPost);
    		// response.
    
    		// 获取结果实体
    		HttpEntity entity = response.getEntity();
    		if (entity != null) {
    			// 按指定编码转换结果实体为String类型
    			body = EntityUtils.toString(entity, encoding);
    		}
    		// EntityUtils.consume(entity);
    		// The server refused this request because the request entity is in a format not
    		// supported by the requested resource for the requested method.
    		// 释放链接
    		// System.out.println(body);
    		response.close();
    		return body;
    	}
    
    	// 信任所有证书
    	@SuppressWarnings("unused")
    	private static void trustAllHosts() {
    		final String TAG = "trustAllHosts";
    		// Create a trust manager that does not validate certificate chains
    		TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() {
    			public java.security.cert.X509Certificate[] getAcceptedIssuers() {
    				return new java.security.cert.X509Certificate[] {};
    			}
    
    			public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    				// Log.i(TAG, "checkClientTrusted");
    			}
    
    			public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    				// Log.i(TAG, "checkServerTrusted");
    			}
    		} };
    		// Install the all-trusting trust manager
    		try {
    			SSLContext sc = SSLContext.getInstance("TLS");
    			sc.init(null, trustAllCerts, new java.security.SecureRandom());
    			HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }