JAVA调用梦网云通讯平台API实现短信发送

package com.montnets.smsutil; import java.io.UnsupportedEncodingException; import java.lang.reflect.Field; import java.lang.reflect.Method; import java.nio.charset.StandardCharsets; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import org.apache.http.HttpEntity; import org.apache.http.HttpHost; import org.apache.http.HttpResponse; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.HttpPost; 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.JSONObject; /** * 发送管理类 * @author redburning * */ public class CHttpPost { // http请求失败 private static int ERROR_310099 = -310099; // 连接超时时间(毫秒) 10秒 private static int HTTP_CONNECT_TIMEOUT = 10 * 1000; // 从连接池获取connection的超时时间 1秒 private static int HTTP_CONNECTION_REQUEST_TIMEOUT = 1 * 1000; // 响应超时时间(毫秒) 10秒 private static int HTTP_SOCKET_TIMEOUT = 10 * 1000; // 请求路径 public static String REQUEST_PATH = "/sms/v2/std/"; public String singleSend(Message message, String ipAddress, String ipProxy, String portProxy) { String result = String.valueOf(ERROR_310099); try { String urlSingleSend = "http://" + ipAddress + REQUEST_PATH + "single_send"; result = send(message, urlSingleSend, ipProxy, portProxy); } catch (Exception e) { e.printStackTrace(); } return result; } public String batchSend(Message message, String ipAddress, String ipProxy, String portProxy) { String result = String.valueOf(ERROR_310099); try { String urlBatchSend = "http://" + ipAddress + REQUEST_PATH + "batch_send"; result = send(message, urlBatchSend, ipProxy, portProxy); } catch (Exception e) { e.printStackTrace(); } return result; } private String send(Message message, String httpUrl, String ipProxy, String portProxy) { String result = String.valueOf(ERROR_310099); try { // 对密码进行加密 String encryptPwd = encryptPwd(message.getUserid(), message.getPwd(), message.getTimestamp()); // 设置加密后的密码 message.setPwd(encryptPwd); Field[] fields = message.getClass().getDeclaredFields(); JSONObject requestBody = new JSONObject(); // 循环拼接请求参数 for (int i = 0; i < fields.length; i++) { String fieldName = fields[i].getName(); String fieldNameUpper = Character.toUpperCase(fieldName.charAt(0)) + fieldName.substring(1); Method getMethod = message.getClass().getMethod("get" + fieldNameUpper); Object value = getMethod.invoke(message); if (value != null) { //拼接请求参数 requestBody.put(fieldName, value); } } // 设定编码方式 StringEntity stringEntity = new StringEntity(requestBody.toString(), StandardCharsets.UTF_8); // 定义请求头 HttpPost httpPost = new HttpPost(httpUrl); httpPost.setHeader("Content-Type", "application/json"); // 定义请求体 httpPost.setEntity(stringEntity); // 创建连接 CloseableHttpClient httpClient = HttpClients.createDefault(); HttpHost proxy = null; if (ipProxy != null && portProxy != null) { // 设置代理 proxy = new HttpHost(ipProxy, Integer.parseInt(portProxy), "http"); } // 设置请求超时时间 RequestConfig requestConfig = RequestConfig.custom() .setProxy(proxy) .setConnectTimeout(HTTP_CONNECT_TIMEOUT) .setConnectionRequestTimeout(HTTP_CONNECTION_REQUEST_TIMEOUT) .setSocketTimeout(HTTP_SOCKET_TIMEOUT) .build(); httpPost.setConfig(requestConfig); HttpEntity entity = null; HttpResponse httpResponse = null; try { // 向网关请求 httpResponse = httpClient.execute(httpPost); // 若状态码为200，则代表请求成功 if (httpResponse != null && httpResponse.getStatusLine().getStatusCode() == 200) { //获取响应的实体 entity = httpResponse.getEntity(); result = EntityUtils.toString(entity); } else { // 设置错误码 result = String.valueOf(ERROR_310099); System.out.println("请求失败：" + httpResponse.getStatusLine().toString()); } } catch (Exception e) { result = String.valueOf(ERROR_310099); e.printStackTrace(); } } catch (Exception e) { result = String.valueOf(ERROR_310099); e.printStackTrace(); } return result; } public String encryptPwd(String userid, String pwd, String timestamp) { // 加密后的字符串 String encryptPwd = null; try { String passwordStr = userid.toUpperCase() + "00000000" + pwd + timestamp; // 对密码进行加密 encryptPwd = getMD5Str(passwordStr); } catch (Exception e) { e.printStackTrace(); } return encryptPwd; } private static String getMD5Str(String str) { MessageDigest messageDigest = null; // 加密前的准备 try { messageDigest = MessageDigest.getInstance("MD5"); messageDigest.reset(); messageDigest.update(str.getBytes("UTF-8")); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); //初始化加密类失败，返回null。 return null; } catch (UnsupportedEncodingException e) { e.printStackTrace(); //初始化加密类失败，返回null。 return null; } byte[] byteArray = messageDigest.digest(); // 加密后的字符串 StringBuffer md5StrBuff = new StringBuffer(); for (int i = 0; i < byteArray.length; i++) { if (Integer.toHexString(0xFF & byteArray[i]).length() == 1){ md5StrBuff.append("0").append(Integer.toHexString(0xFF & byteArray[i])); } else { md5StrBuff.append(Integer.toHexString(0xFF & byteArray[i])); } } return md5StrBuff.toString(); } }