DEMO: Mail/Send - 邮件发送
- 支持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>
代码示例
package com.submail.demo.mail;
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.HttpGet;
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.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.util.TreeMap;
public class MailSendDemo {
public static final String TIMESTAMP = "https://api-v4.mysubmail.com/service/timestamp";
private static final String URL = "https://api-v4.mysubmail.com/mail/send";
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 appid = "";
String appkey = "";
String to = "";
String from = "";
String from_name = "";
String reply = "";
String cc = "";
String bcc = "";
String subject = "这是一个测试主题";
String text = "";
String html = "";
JSONObject vars = new JSONObject();
vars.put("param1", "3334");
vars.put("param2", "张三丰");
JSONObject links = new JSONObject();
links.put("l1", "xxxx");
links.put("l2", "xxxx");
//附件。最多支持9个附件
Atta atta = new Atta();
atta.add("text2.jpg", "/Users/submail/Desktop/text2.jpg");
atta.add("text3.jpg", "/Users/submail/Desktop/text3.jpg");
String headers = "";
String asynchronous = "true";
String tag = "xxxx";
String sign_type = "md5";
String sign_version = "2";
//组合请求数据
requestData.put("appid", appid);
requestData.put("to", to);
requestData.put("from", from);
requestData.put("from_name", from_name);
requestData.put("subject", subject);
requestData.put("tag",tag);
if (sign_type.equals(TYPE_MD5) || sign_type.equals(TYPE_SHA1)) {
String timestamp = getTimestamp();
requestData.put("timestamp", timestamp);
requestData.put("sign_type", sign_type);
requestData.put("sign_version", sign_version);
String signStr = appid + appkey + RequestEncoder.formatRequest(requestData) + appid + appkey;
System.out.println(signStr);
requestData.put("signature", RequestEncoder.encode(sign_type, signStr));
} else {
requestData.put("signature", appkey);
}
//sign_version=2 这些参数不参与signature参数加密计算
requestData.put("cc",cc);
requestData.put("bcc",bcc);
requestData.put("headers",headers);
requestData.put("text", text);
requestData.put("html", html);
requestData.put("vars", vars.toJSONString());
requestData.put("links", links.toJSONString());
requestData.put("atta", atta.toJSONString());
System.out.println("requestData = " + requestData);
//post请求
HttpPost httpPost = new HttpPost(URL);
httpPost.setHeader("Accept", "application/json");
httpPost.setHeader("Content-Type", "application/json");
StringEntity entity = new StringEntity(JSONObject.toJSONString(requestData), "UTF-8");
httpPost.setEntity(entity);
try {
CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build();
HttpResponse response = closeableHttpClient.execute(httpPost);
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();
}
}
//获取时间戳
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");
}
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
}
class Atta {
private JSONArray jsonArray = new JSONArray();
public void add(String name, String path) throws Exception {
JSONObject jsonObject = new JSONObject();
jsonObject.put("name", name);
jsonObject.put("data", encodeBase64File(path));
jsonArray.add(jsonObject);
}
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", "");
}
public String toJSONString() {
return jsonArray.toJSONString();
}
}
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;
}
}