package com.product; import java.util.HashMap; import java.util.Map; import java.util.concurrent.CountDownLatch; import javax.ws.rs.core.MediaType; import com.alibaba.fastjson.JSONObject; import com.mashape.unirest.http.HttpResponse; import com.mashape.unirest.http.JsonNode; import com.mashape.unirest.http.Unirest; import com.mashape.unirest.http.exceptions.UnirestException; import com.sun.jersey.api.client.Client; import com.sun.jersey.api.client.ClientResponse; import com.sun.jersey.api.client.WebResource; import com.sun.jersey.api.client.filter.HTTPBasicAuthFilter; import com.sun.jersey.core.util.MultivaluedMapImpl; public class MailgunSendEmail { //////测试账号 //private static final String API_KEY = "84d2c563e45e4aa32000a0f608a20e32-cb3791c4-580c662f"; //private static final String DOMAIN = "sandbox425b6a32b61840fa902c2e614f4616fc.mailgun.org"; //////正式账号 private static final String API_KEY = "8d52b0a748b20c61331587fa9a3fe6fc-cb3791c4-8cf158ef"; private static final String DOMAIN = "mail.purtato.com"; private static final String API_URI = "https://api.mailgun.net/v3/"+DOMAIN+"/messages"; /** * 普通邮件发送，不包含模板 * @return * @throws UnirestException */ public JsonNode sendSimpleMessage() throws UnirestException { HttpResponse request = Unirest.post(API_URI) .basicAuth("api", API_KEY) //测试账号发件人 //.queryString("from", "fuller@sandbox425b6a32b61840fa902c2e614f4616fc.mailgun.org") //正式账号发件人 .queryString("from", "brianho@mail.purtato.com") //.queryString("to", "b.hokaming@gmail.com") //.queryString("to", "FullerFB@163.com") //.queryString("to","370036259@qq.com") //.queryString("to","brianho1023@yahoo.com") .queryString("subject", "Mailgun test subject") .queryString("html","Testing some Mailgun awesomness! 测试测试测试

Bruce") //.queryString("text", "Mailgun Testing") .asJson(); return request.getBody(); } /** * 包含模板的邮件发送，首先在mailgun管理端进行模板配置 * @return */ public static ClientResponse SendSimpleMessage() { Client client = Client.create(); client.addFilter(new HTTPBasicAuthFilter("api", API_KEY)); WebResource webResource = client.resource("https://api.mailgun.net/v3/mail.purtato.com/messages"); MultivaluedMapImpl formData = new MultivaluedMapImpl(); formData.add("from", "brianho@mail.purtato.com"); formData.add("subject", "Hello Brian Ho"); formData.add("template", "test"); formData.add("h:X-Mailgun-Variables", buildTemplateParameter()); return webResource.type(MediaType.APPLICATION_FORM_URLENCODED).post(ClientResponse.class, formData); } /** * 组装mailgun模板名称为test的，name、reset_password_url 这两个参数进行传递数据 * @return */ public static String buildTemplateParameter() { Map map = new HashMap(); map.put("name", "Fuller"); map.put("reset_password_url", "https://www.baidu.com"); return JSONObject.toJSONString(map); } @SuppressWarnings("static-access") public static void main(String[] args) { MailgunSendEmail latchTest = new MailgunSendEmail(); //////普通测试发送 /* JsonNode jsonNode; try { jsonNode = latchTest.sendSimpleMessage(); System.out.println("result......"+jsonNode.toString()); } catch (UnirestException e) { // TODO Auto-generated catch block e.printStackTrace(); } */ //////邮件模板测试发送 ClientResponse clientResponse = latchTest.SendSimpleMessage(); System.out.println(clientResponse.getStatus()); //////并发邮件发送测试 /* Runnable taskTemp = new Runnable() { // 注意，此处是非线程安全的，留坑 private int iCounter; @Override public void run() { for(int i = 0; i < 5; i++) { JsonNode jsonNode; try { jsonNode = latchTest.sendSimpleMessage(); System.out.println("result......"+jsonNode.toString()); } catch (UnirestException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } iCounter++; System.out.println(System.nanoTime() + " [" + Thread.currentThread().getName() + "] iCounter = " + iCounter); try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } } } }; try { latchTest.startTaskAllInOnce(5, taskTemp); } catch (InterruptedException e) { e.printStackTrace(); } */ } public long startTaskAllInOnce(int threadNums, final Runnable task) throws InterruptedException { final CountDownLatch startGate = new CountDownLatch(1); final CountDownLatch endGate = new CountDownLatch(threadNums); for(int i = 0; i < threadNums; i++) { Thread t = new Thread() { public void run() { try { // 使线程在此等待，当开始门打开时，一起涌入门中 startGate.await(); try { task.run(); } finally { // 将结束门减1，减到0时，就可以开启结束门了 endGate.countDown(); } } catch (InterruptedException ie) { ie.printStackTrace(); } } }; t.start(); } long startTime = System.nanoTime(); System.out.println(startTime + " [" + Thread.currentThread() + "] All thread is ready, concurrent going..."); // 因开启门只需一个开关，所以立马就开启开始门 startGate.countDown(); // 等等结束门开启 endGate.await(); long endTime = System.nanoTime(); System.out.println(endTime + " [" + Thread.currentThread() + "] All thread is completed."); return endTime - startTime; } }