e签宝API对接测试

eladmin-system/src/main/java/me/zhengjie/base/util/HttpUtil.java

@@ -1,19 +1,10 @@
 package me.zhengjie.base.util;
 
-import java.io.BufferedReader;
-import java.io.FileInputStream;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-
-import java.io.PrintWriter;
-import java.net.URL;
-import java.net.URLConnection;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.io.*;
+
+import java.net.*;
+import java.text.MessageFormat;
+import java.util.*;
 
 import com.alibaba.fastjson.JSONObject;
 
@@ -27,15 +18,11 @@ public class HttpUtil {
 	 */
 	private static int DEFAULT_TIME_OUT = 1800000000;
 
-	//
-
 	/**
 	 * jdk 原生 http post 请求，默认超时时间为30秒
 	 *
 	 * @param url         请求地址
-	 * @param body        入参String
-	 * @param contentType 内容类型
-	 * @param charSet     编码格式
+	 * @param json        入参String
 	 * @return respone的body
 	 */
 	public static String sendPost(String url, String json) {
@@ -47,8 +34,6 @@ public class HttpUtil {
 	 *
 	 * @param url         访问地址
 	 * @param body        request请求体
-	 * @param contentType 请求类型
-	 * @param charSet     编码格式
 	 * @param timeOut     超时时间，单位毫秒
 	 * @return 响应体string
 	 */
@@ -66,8 +51,6 @@ public class HttpUtil {
 			conn.setRequestProperty("charsert", "utf-8");
 			conn.setConnectTimeout(timeOut);
 			conn.setReadTimeout(timeOut);
-			//
-
 			// 发送POST请求必须设置如下两行
 			conn.setDoOutput(true);
 			conn.setDoInput(true);
@@ -121,6 +104,215 @@ public class HttpUtil {
 		return stringBuilder.toString();
 	}
 
+	/***
+	 * 向指定URL发送POST方法的请求
+	 *
+	 * @param apiUrl
+	 * @param data
+	 * @param headers
+	 * @param encoding
+	 * @return
+	 * @throws Exception
+	 */
+	public static String sendPOST(String apiUrl, String data, LinkedHashMap<String, String> headers, String encoding) throws Exception {
+		// 获得响应内容
+		String http_RespContent = null;
+		HttpURLConnection httpURLConnection = null;
+		int http_StatusCode = 0;
+		String http_RespMessage = null;
+		try {
+			// 建立连接
+			URL url = new URL(apiUrl);
+			httpURLConnection = (HttpURLConnection) url.openConnection();
+			// 需要输出
+			httpURLConnection.setDoOutput(true);
+			// 需要输入
+			httpURLConnection.setDoInput(true);
+			// 不允许缓存
+			httpURLConnection.setUseCaches(false);
+			// HTTP请求方式
+			httpURLConnection.setRequestMethod("POST");
+			// 设置Headers
+			if (null != headers) {
+				for (String key : headers.keySet()) {
+					httpURLConnection.setRequestProperty(key, headers.get(key));
+				}
+			}
+			// 连接会话
+			httpURLConnection.connect();
+			if (data != null) {
+				// 建立输入流，向指向的URL传入参数
+				DataOutputStream dos = new DataOutputStream(httpURLConnection.getOutputStream());
+				// 设置请求参数
+				dos.write(data.getBytes(encoding));
+				dos.flush();
+				dos.close();
+			}
+			// 获得响应状态(HTTP状态码)
+			http_StatusCode = httpURLConnection.getResponseCode();
+			// 获得响应消息(HTTP状态码描述)
+			http_RespMessage = httpURLConnection.getResponseMessage();
+			// 获得响应内容
+			if (HttpURLConnection.HTTP_OK == http_StatusCode) {
+				// 返回响应结果
+				http_RespContent = getResponseContent(httpURLConnection);
+			} else {
+				// 返回非200状态时响应结果
+				http_RespContent = getErrorResponseContent(httpURLConnection);
+				String msg =
+						MessageFormat.format("请求失败: Http状态码 = {0} , {1}", http_StatusCode, http_RespMessage);
+				System.out.println(msg);
+			}
+		} catch (UnknownHostException e) {
+			String message = MessageFormat.format("网络请求时发生异常: {0}", e.getMessage());
+			Exception ex = new Exception(message);
+			ex.initCause(e);
+			throw ex;
+		} catch (MalformedURLException e) {
+			String message = MessageFormat.format("格式错误的URL: {0}", e.getMessage());
+			Exception ex = new Exception(message);
+			ex.initCause(e);
+			throw ex;
+		} catch (IOException e) {
+			String message = MessageFormat.format("网络请求时发生异常: {0}", e.getMessage());
+			Exception ex = new Exception(message);
+			ex.initCause(e);
+			throw ex;
+		} catch (Exception e) {
+			String message = MessageFormat.format("网络请求时发生异常: {0}", e.getMessage());
+			Exception ex = new Exception(message);
+			ex.initCause(e);
+			throw ex;
+		} finally {
+			if (null != httpURLConnection) {
+				httpURLConnection.disconnect();
+			}
+		}
+		return http_RespContent;
+	}
+
+	/***
+	 * 读取HttpResponse响应内容
+	 *
+	 * @param httpURLConnection
+	 * @return
+	 * @throws UnsupportedEncodingException
+	 * @throws IOException
+	 */
+	private static String getErrorResponseContent(HttpURLConnection httpURLConnection)
+			throws UnsupportedEncodingException, IOException {
+		StringBuffer contentBuffer = null;
+		BufferedReader responseReader = null;
+		try {
+			contentBuffer = new StringBuffer();
+			String readLine = null;
+			responseReader =
+					new BufferedReader(new InputStreamReader(httpURLConnection.getErrorStream(), "UTF-8"));
+			while ((readLine = responseReader.readLine()) != null) {
+				contentBuffer.append(readLine);
+			}
+		} finally {
+			if (null != responseReader) {
+				responseReader.close();
+			}
+		}
+		return contentBuffer.toString();
+	}
+
+	/***
+	 * 读取HttpResponse响应内容
+	 *
+	 * @param httpURLConnection
+	 * @return
+	 * @throws UnsupportedEncodingException
+	 * @throws IOException
+	 */
+	private static String getResponseContent(HttpURLConnection httpURLConnection)
+			throws UnsupportedEncodingException, IOException {
+		StringBuffer contentBuffer = null;
+		BufferedReader responseReader = null;
+		try {
+			contentBuffer = new StringBuffer();
+			String readLine = null;
+			responseReader =
+					new BufferedReader(new InputStreamReader(httpURLConnection.getInputStream(), "UTF-8"));
+			while ((readLine = responseReader.readLine()) != null) {
+				contentBuffer.append(readLine);
+			}
+		} finally {
+			if (null != responseReader) {
+				responseReader.close();
+			}
+		}
+		return contentBuffer.toString();
+	}
+
+	/**
+	 * 上传文件
+	 *
+	 * @param url
+	 * @param header
+	 * @param filePath
+	 * @return
+	 */
+	public static String postFile(String url, Map<String, String> header, String filePath) {
+		HttpURLConnection conn = null;
+		OutputStream out = null;
+		String respContent = "";
+		try {
+			URL realUrl = new URL(url);
+			// 打开和URL之间的连接
+			conn = (HttpURLConnection) realUrl.openConnection();
+			// 设置通用的请求头属性
+			conn.setRequestProperty("Content-Type", header.get("contentType"));
+			conn.setRequestProperty("Content-MD5", header.get("contentMD5"));
+			// 发送POST请求必须设置如下两行
+			conn.setDoOutput(true);
+			conn.setDoInput(true);
+			conn.setRequestMethod("PUT");
+			conn.connect();
+			// 上传文件内容
+			out = new DataOutputStream(conn.getOutputStream());
+			File file = new File(filePath);
+			DataInputStream fileIS = new DataInputStream(new FileInputStream(file));
+			int bytes = 0;
+			byte[] bufferOut = new byte[1024];
+			while ((bytes = fileIS.read(bufferOut)) != -1) {
+				out.write(bufferOut, 0, bytes);
+			}
+			fileIS.close();
+			out.flush();
+			out.close();
+			// 获取返回信息
+			int statusCode = conn.getResponseCode();
+			String respMessage = conn.getResponseMessage();
+			// 获得响应内容
+			if (HttpURLConnection.HTTP_OK == statusCode) {
+				// 返回响应结果
+				respContent = getResponseContent(conn);
+			} else {
+				// 返回非200状态时响应结果
+				respContent = getErrorResponseContent(conn);
+				String msg = MessageFormat.format("请求失败: Http状态码 = {0} , {1}", statusCode, respMessage);
+				System.out.println(msg);
+			}
+		} catch (IOException e) {
+			e.printStackTrace();
+		} finally {
+			try {
+				if (out != null) {
+					out.close();
+				}
+				if (conn != null) {
+					conn.disconnect();
+				}
+			} catch (Exception ex) {
+				ex.printStackTrace();
+			}
+		}
+		return respContent;
+	}
+
 	public static void main(String[] args) throws Exception {
 
 		int i = 0;

eladmin-system/src/main/java/me/zhengjie/base/util/TencentServiceUtil.java

@@ -17,6 +17,7 @@ import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
 import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
 import lombok.extern.slf4j.Slf4j;
 import me.zhengjie.base.config.AppConfigInfo;
+import me.zhengjie.utils.FileUtil;
 import org.springframework.web.multipart.MultipartFile;
 import sun.misc.BASE64Encoder;
 
@@ -141,7 +142,7 @@ public class TencentServiceUtil {
         try {
             String filePath = saveFile(file, UUIDGenerator.uuid() + file.getOriginalFilename());
             String compressFilePath = compressImage(filePath);
-            String content = encodeBase64File(compressFilePath);
+            String content = FileUtil.encodeBase64File(compressFilePath);
 
             // 实例化一个认证对象，入参需要传入腾讯云账户secretId，secretKey,此处还需注意密钥对的保密
             // 密钥可前往https://console.cloud.tencent.com/cam/capi网站进行获取
@@ -465,21 +466,6 @@ public class TencentServiceUtil {
     }
 
     /**
-     * 将文件内容转换成Base64编码
-     * @param path
-     * @return
-     * @throws Exception
-     */
-    private static String encodeBase64File(String path) throws Exception {
-        File file = new File(path);
-        FileInputStream inputFile = new FileInputStream(file);
-        byte[] buffer = new byte[(int) file.length()];
-        inputFile.read(buffer);
-        inputFile.close();
-        return new BASE64Encoder().encode(buffer);
-    }
-
-    /**
      * 图片压缩
      * @throws Exception
      */