DEMO: MMS/Template - 彩信模板管理

• 支持JDK版本：1.5以上
• 依赖的jar包：httpclient-4.5.3.jar、httpcore-4.4.14.jar、commons-logging1.1.1.jar、fastjson-1.2.75.jar

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.3</version>
</dependency>
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpcore</artifactId>
    <version>4.4.14</version>
</dependency>
<dependency>
    <groupId>commons-logging</groupId>
    <artifactId>commons-logging</artifactId>
    <version>1.1.1</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.75</version>
</dependency>

代码示例

MMSTemplateDemo

package com.submail.demo.mms;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.submail.demo.RequestEncoder;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.*;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import sun.misc.BASE64Encoder;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.URI;
import java.util.Map;
import java.util.TreeMap;

public class MMSTemplate {
    public static final String TIMESTAMP = "https://api-v4.mysubmail.com/service/timestamp";
    private static final String URL = "https://api-v4.mysubmail.com/mms/template.json";
    public static final String TYPE_MD5 = "md5";
    public static final String TYPE_SHA1 = "sha1";

    public static void main(String[] args) throws Exception {
        TreeMap<String, String> requestData = new TreeMap<String, String>();
        String method = "post";       //  get | post | put | delete
        String appid = "";
        String appkey = "";
        String signtype = "md5";         // normal | md5 | sha1
        //get请求参数
        String template_id = "d0CAq";
        //post请求参数
        String mms_type = "mms";
        String mms_title = "彩信测试title";
        String mms_signature = "【测试彩信】";
        String mms_subject = "";
        String sign_version="2";

        requestData.put("appid", appid);
        requestData.put("sign_version",sign_version);
        switch (method) {
            /**
             * 彩信模板最大支持9页，mms_content参数中每一组数据为一页，并且依次排序。
             * 彩信模板每一页必须至少包含一种类型数据，媒体文件或者文字。
             * 单模板仅支持一种媒体类型，图片或音频，即图片+文字，或音频+文字，并将彩信标题+签名+媒体文件+正文文字的大小总和控制在 85KB 以内。
             * 媒体文件中的数据必须是 base64 编码，并通过 type 参数正确的说明文件类型。
             */
            case "post":
                String signature = buildSignature(appid, appkey, signtype, requestData);
                requestData.put("mms_type", mms_type);
                requestData.put("signature", signature);
                requestData.put("mms_title", mms_title);
                requestData.put("mms_signature", mms_signature);
                requestData.put("mms_subject", mms_subject);
                Content content = new Content();
                content.addPage("image", "image/jpg", "/Users/submail/Desktop/text.jpg", "测试image类型");
                content.addPage("image", "image/jpg", "/Users/submail/Desktop/text.jpg");
                requestData.put("mms_content", content.toJsonString());
                System.out.println("requestData = " + requestData);
                HttpPost httpPost = new HttpPost(URL);
                httpPost.addHeader("charset", "UTF-8");
                httpPost.setHeader("Accept", "application/json");
                httpPost.setHeader("Content-Type", "application/json");
                StringEntity postEntity = new StringEntity(JSONObject.toJSONString(requestData), "UTF-8");
                httpPost.setEntity(postEntity);
                httpRequest(httpPost);
                break;
            case "get":
                requestData.put("template_id", template_id);
                requestData.put("signature", buildSignature(appid, appkey, signtype, requestData));
                System.out.println("requestData = " + requestData);
                String urlGet = URL + "?";
                for (Map.Entry<String, String> entry : requestData.entrySet()) {
                    String key = entry.getKey();
                    Object value = entry.getValue();
                    if (value instanceof String) {
                        urlGet += key + "=" + value + "&";
                    }
                }
                urlGet = urlGet.substring(0, urlGet.length() - 1);
                System.out.println("urlGet = " + urlGet);
                HttpGet httpGet = new HttpGet(urlGet);
                httpRequest(httpGet);
                break;
            case "put":
                requestData.put("template_id", template_id);
                requestData.put("signature", buildSignature(appid, appkey, signtype, requestData));
                requestData.put("mms_type", mms_type);
                requestData.put("mms_title", mms_title);
                requestData.put("mms_signature", mms_signature);
                requestData.put("mms_subject", mms_subject);
                Content content_put = new Content();
                content_put.addPage("image", "image/jpeg", "/Users/submail/Desktop/text.jpeg", "张测试image类型");
                content_put.addPage("image", "image/jpeg", "/Users/submail/Desktop/text.jpeg", "hello world ");
                requestData.put("mms_content", content_put.toJsonString());
                System.out.println("requestData = " + requestData);
                HttpPut httpput = new HttpPut(URL);
                httpput.addHeader("charset", "UTF-8");
                httpput.setHeader("Accept", "application/json");
                httpput.setHeader("Content-Type", "application/json");
                StringEntity entity = new StringEntity(JSONObject.toJSONString(requestData), "UTF-8");
                httpput.setEntity(entity);
                httpRequest(httpput);
                break;
            case "delete":
                requestData.put("template_id", template_id);
                requestData.put("signature", buildSignature(appid, appkey, signtype, requestData));
                String entityStr = "";
                for (Map.Entry<String, String> entry : requestData.entrySet()) {
                    String key = entry.getKey();
                    String value = entry.getValue();
                    entityStr += key + "=" + value + "&";
                    System.out.println(entityStr);
                }
                HttpDeleteWithBody httpDelete = new HttpDeleteWithBody(URL);
                HttpEntity delEntity = new StringEntity(entityStr);
                httpDelete.setEntity(delEntity);
                httpRequest(httpDelete);
                break;
        }

    }

    /**
     * 获取时间戳
     *
     * @return
     */
    private static String getTimestamp() {
        CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build();
        HttpGet httpget = new HttpGet(TIMESTAMP);
        try {
            HttpResponse response = closeableHttpClient.execute(httpget);
            HttpEntity httpEntity = response.getEntity();
            String jsonStr = EntityUtils.toString(httpEntity, "UTF-8");
            if (jsonStr != null) {
                JSONObject json = JSONObject.parseObject(jsonStr);
                return json.getString("timestamp");
            }
            closeableHttpClient.close();
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return null;
    }

    public static void httpRequest(HttpRequestBase httpRequestBase) {
        try {
            CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build();
            HttpResponse response = closeableHttpClient.execute(httpRequestBase);
            HttpEntity httpEntity = response.getEntity();
            if (httpEntity != null) {
                String jsonStr = EntityUtils.toString(httpEntity, "UTF-8");
                System.out.println(jsonStr);
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static String buildSignature(String appid, String appkey, String sign_type, TreeMap<String, String> requestData) {
        if (sign_type.equals(TYPE_MD5) || sign_type.equals(TYPE_SHA1)) {
            String timestamp = getTimestamp();
            requestData.put("timestamp", timestamp);
            requestData.put("sign_type", sign_type);
            String signStr = appid + appkey + RequestEncoder.formatRequest(requestData) + appid + appkey;
            System.out.println("signStr = " + signStr);
            return RequestEncoder.encode(sign_type, signStr);
        }
        return appkey;
    }
}


class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase {
    public static final String METHOD_NAME = "DELETE";

    public String getMethod() {
        return METHOD_NAME;
    }

    public HttpDeleteWithBody(final String uri) {
        super();
        setURI(URI.create(uri));
    }

    public HttpDeleteWithBody(final URI uri) {
        super();
        setURI(uri);
    }

    public HttpDeleteWithBody() {
        super();
    }
}

class Content {
    private JSONArray jsonArray = new JSONArray();

    public void addPage(String media_type, String type, String media_path, String text) throws Exception {
        JSONObject json_data = new JSONObject();
        JSONObject json_media = new JSONObject();
        json_media.put("data", encodeBase64File(media_path));
        json_media.put("type", type);
        json_data.put(media_type, json_media);
        if (text != null) {
            json_data.put("text", text);
        }
        jsonArray.add(json_data);
    }

    public void addPage(String media_type, String type, String media_path) throws Exception {
        addPage(media_type, type, media_path, null);
    }

    public String toJsonString() {
        return jsonArray.toJSONString();
    }

    public 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).replaceAll("\n", "");
    }
}

RequestEncoder

package com.submail.demo;

/**
 * @author zhang
 * @date 2021/8/4 - 5:52 下午
 */

import java.security.MessageDigest;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

public class RequestEncoder {
    private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5',
            '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};

    public static String encode(String algorithm, String str) {
        if (str == null) {
            return null;
        }
        try {
            MessageDigest messageDigest = MessageDigest.getInstance(algorithm);
            messageDigest.update(str.getBytes("UTF-8"));
            return getFormattedText(messageDigest.digest());
        } catch (Exception e) {
            throw new RuntimeException(e);
        }

    }

    private static String getFormattedText(byte[] bytes) {
        int len = bytes.length;
        StringBuilder buf = new StringBuilder(len * 2);
        for (int j = 0; j < len; j++) {
            buf.append(HEX_DIGITS[(bytes[j] >> 4) & 0x0f]);
            buf.append(HEX_DIGITS[bytes[j] & 0x0f]);
        }
        return buf.toString();
    }

    public static String formatRequest(Map<String, String> data) {
        Set<String> keySet = data.keySet();
        Iterator<String> it = keySet.iterator();
        StringBuffer sb = new StringBuffer();
        while (it.hasNext()) {
            String key = it.next();
            Object value = data.get(key);
            if (value instanceof String) {
                sb.append(key + "=" + value + "&");
            }
        }
        if (sb.length() != 0) {
            System.out.println("sb.substring(0, sb.length() - 1) = " + sb.substring(0, sb.length() - 1));
            return sb.substring(0, sb.length() - 1);
        }
        return null;
    }
}