利用spring线程池ThreadPoolTaskExecutor发送手机短信

import java.awt.image.BufferedImage;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import javax.annotation.Resource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import redis.clients.jedis.JedisCluster;

/**
* 激活用户
*
* @author skyler
* @time 2016-05-23
*/
@RestController
@RequestMapping("version{vv:\\d+}/user")
@Validated
public class UserController {

private static Logger log = LoggerFactory.getLogger(UserController.class);

@Resource
private ThreadPoolTaskExecutor taskExecutor;

@RequestMapping("/send_msg")
public ResponseJson sendMsg(long id) throws InterruptedException, ExecutionException {

//FutureTask<String> futureTask = new FutureTask<>(new MyCallable(200));
System.out.println(taskExecutor.getActiveCount());
taskExecutor.submit(new MyCallable(10));
Future<Object> f = taskExecutor.submit(new MyCallable(5));
System.out.println(f.get());
//taskExecutor.shutdown();
return new ResponseJson();
}

class MyCallable implements Callable<Object> {
private int id;

public MyCallable(int id) {
this.id = id;
}

@Override
public String call() throws Exception {
System.out.println("call()方法被调用！" + Thread.currentThread().getName());
// Thread.sleep(200);
List<Integer> list = new ArrayList<Integer>(10);
List<MessageInfo> msgList = new ArrayList<MessageInfo>();
// for (Integer i : list) {
// 1.组装短信对象
Message info = new Message("******", "您的验证码是："
+ RandomStringUtils.random(6, true, true));
Message info2 = new Message("*******", "您的验证码是：
+ RandomStringUtils.random(6, true, true));
// 2.放入list中，为批量发送短信做准备
msgList.add(info);
msgList.add(info2);
// 3.组装staff_invite对象
// }

SenderUtils.batchSend(msgList);
return "结果是：" + id;
}
}
}

@Bean
public ThreadPoolTaskExecutor taskExecutor() {
ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
// 线程池所使用的缓冲队列
pool.setQueueCapacity(queueCapacity);
// 线程池维护线程的最少数量
pool.setCorePoolSize(corePoolSize);
// 线程池维护线程的最大数量
pool.setMaxPoolSize(maxPoolSize);
// 线程池维护线程所允许的空闲时间
pool.setKeepAliveSeconds(keepAliveSeconds);
// pool.setWaitForTasksToCompleteOnShutdown(true);
System.out.println("------------ThreadPoolTaskExecutor init--------------------");

return pool;
}

import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import org.apache.commons.lang3.RandomStringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SenderUtils {

private static Logger log = LoggerFactory.getLogger(SenderUtils.class);

/**
* 发送短信
*
* @param content
*            要发送的短信内容
* @param phoneNumber
*            发送目的号码
* @throws IOException
*             {@link send.MessageInfo}
* @time 2016-05-20
*/
public static void send(MessageInfo info) throws IOException {

// 创建StringBuffer对象用来操作字符串
StringBuffer sb = new StringBuffer(MessageInfo.url);

// 向StringBuffer追加用户名
sb.append("name=").append(MessageInfo.name);

// 向StringBuffer追加密码（登陆网页版，在管理中心--基本资料--接口密码，是28位的）
sb.append("&pwd=").append(MessageInfo.pwd);

// 向StringBuffer追加手机号码
sb.append("&mobile=").append(info.getMobile());

// 向StringBuffer追加消息内容转URL标准码
sb.append("&content=" + URLEncoder.encode(info.getContent(), "UTF-8"));

// 追加发送时间，可为空，为空为及时发送
sb.append("&stime=").append(info.getStime());

// 加签名
sb.append("&sign=" + URLEncoder.encode(info.getSign(), "UTF-8"));

// type为固定值pt extno为扩展码，必须为数字 可为空
sb.append("&type=").append(info.getType()).append("&extno=").append(info.getExtno());
// 创建url对象
// String temp = new String(sb.toString().getBytes("GBK"),"UTF-8");
System.out.println("sb:" + sb.toString());
URL url = new URL(sb.toString());

// 打开url连接
HttpURLConnection connection = (HttpURLConnection) url.openConnection();

// 设置url请求方式 ‘get’ 或者 ‘post’
connection.setRequestMethod("POST");

// 发送
InputStream is = url.openStream();

// 转换返回值
String returnStr = SenderUtils.convertStreamToString(is);

// 返回结果为‘0，20140009090990,1，提交成功’ 发送成功 具体见说明文档
log.info(returnStr);
// 返回发送结果
}

public static void batchSend(List<MessageInfo> list) throws IOException {

// 创建StringBuffer对象用来操作字符串
StringBuffer sb = new StringBuffer(MessageInfo.url);

// 向StringBuffer追加用户名
sb.append("name=").append(MessageInfo.name);

// 向StringBuffer追加密码（登陆网页版，在管理中心--基本资料--接口密码，是28位的）
sb.append("&pwd=").append(MessageInfo.pwd);

String contents = "";

// 追加发送时间，可为空，为空为及时发送
sb.append("&stime=").append("");

// 加签名
sb.append("&sign=" + URLEncoder.encode("公司名", "UTF-8"));

// type为固定值pt extno为扩展码，必须为数字 可为空
sb.append("&type=").append("gx").append("&extno=").append("");

// 你好张三#@#13566666666#@@#你好李四#@#13999999999
for (MessageInfo info : list) {
contents += info.getContent() + "#@#" + info.getMobile() + "#@@#";
}

String c = "";
if (contents.endsWith("#@@#")) {
c = contents.substring(0, contents.lastIndexOf("#@@#"));
}
// 向StringBuffer追加手机号码
// sb.append("&mobile=").append(mobiles);

// 向StringBuffer追加消息内容转URL标准码
sb.append("&content=" + URLEncoder.encode(c, "UTF-8"));

// 创建url对象
// String temp = new String(sb.toString().getBytes("GBK"),"UTF-8");
System.out.println("sb:" + sb.toString());
URL url = new URL(sb.toString());

// 打开url连接
HttpURLConnection connection = (HttpURLConnection) url.openConnection();

// 设置url请求方式 ‘get’ 或者 ‘post’
connection.setRequestMethod("POST");

// 发送
InputStream is = url.openStream();

// 转换返回值
String returnStr = SenderUtils.convertStreamToString(is);

// 返回结果为‘0，20140009090990,1，提交成功’ 发送成功 具体见说明文档
log.info(returnStr);
// 返回发送结果

}

public static String batchSend(String msgUrl) throws IOException {

// String temp = new String(sb.toString().getBytes("GBK"),"UTF-8");
System.out.println("msgUrl:" + msgUrl);
URL url = new URL(msgUrl);

// 打开url连接
HttpURLConnection connection = (HttpURLConnection) url.openConnection();

// 设置url请求方式 ‘get’ 或者 ‘post’
connection.setRequestMethod("POST");

// 发送
InputStream is = url.openStream();

// 转换返回值
String returnStr = SenderUtils.convertStreamToString(is);

// 返回结果为‘0，20140009090990,1，提交成功’ 发送成功 具体见说明文档
log.info(returnStr);
// 返回发送结果
return returnStr;
}

/**
* 转换返回值类型为UTF-8格式.
*
* @param is
* @return
*/
public static String convertStreamToString(InputStream is) {
StringBuilder sb1 = new StringBuilder();
byte[] bytes = new byte[4096];
int size = 0;

try {
while ((size = is.read(bytes)) > 0) {
String str = new String(bytes, 0, size, "UTF-8");
sb1.append(str);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return sb1.toString();
}
}

/**
* 发送信息类，用于发送短信
*
* @time 2016-05-20
* @author skyler
*
*/
public class Message {

public final static String url = "http://web.cr6868.com/asmx/smsservice.aspx?";
public final static String name = "********";
public final static String pwd = "********";

private String sign = "公司";
private String mobile = "";
private String content = "";
private String stime = "";
private String type = "pt";
private String extno = "";

public Message() {
}

public Message(String mobile, String content) {
super();
this.mobile = mobile;
this.content = content;
}

public Message(String sign, String mobile, String content, String stime, String type, String extno) {
super();
this.sign = sign;
this.mobile = mobile;
this.content = content;
this.stime = stime;
this.type = type;
this.extno = extno;
}

public String getSign() {
return sign;
}

public void setSign(String sign) {
this.sign = sign;
}

public String getMobile() {
return mobile;
}

public void setMobile(String mobile) {
this.mobile = mobile;
}

public String getContent() {
return content;
}

public void setContent(String content) {
this.content = content;
}

public String getStime() {
return stime;
}

public void setStime(String stime) {
this.stime = stime;
}

public String getType() {
return type;
}

public void setType(String type) {
this.type = type;
}

public String getExtno() {
return extno;
}

public void setExtno(String extno) {
this.extno = extno;
}

}