线程做短信发送服务，存在的问题。我没有积分了请见谅

0 0

线程做短信发送服务，存在的问题。我没有积分了请见谅0

知道自己的代码写的很烂，但是还是忍不住要贴上来，求指点啊。
我现在在做一个短信发送的服务，我的想法是用线程来发送短信，但是一直存在问题，如果一次发送短信过多，创建线程多了的话就会有内存异常。所以现在改成了，控制最多只创建100个线程来发送，但是同事说这种做法很有问题。
第一sendThreadCount这个变量没有同步，多个线程同时访问的话会有问题.
第二在创建100个线程也很占资源。
关于第一个问题，我就没有想明白哪有问题了，static 的int 变量也需要同步么？
第二个问题是我真的不知道该如何控制能更好了。代码已贴了，请大伙帮忙看看。

public class ServiceThread implements Runnable {
	private int timeout;// 轮询间隔时间毫秒
	List returnHistoryList = new ArrayList();// 返回的发送历史
	List sendingList = new ArrayList<Map>();// 发送的短信队列
	public static int sendThreadCount = 0;//标识发送线程数量
	public ServiceThread() {
		this.timeout = 10000;
	}

	public void run() {
		sendThreadCount = 0;
		while (SmsManager.run) {
			try {
				// 1、查找发送表已发送状态的记录
				findResutedlMsg();
				// 3、写入历史表，从发送表中删除
				insertHistory();
				// 4、查找发送表中待发送状态的记录
				findSending();
				// 发送待发送的短信
				sendQueue();
			} catch (Exception e) {
			}
			reset();
			try {
				Thread.sleep(timeout);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		clear();
	}

	//查找发送了的数据
	private void findResutedlMsg() throws Exception {
		returnHistoryList = SmsManager.getJdbcTemplate().queryForList(
				"select send_id from t_sms_send where send_state in (2,3,4,5)");
	}

	// 将返回的历史记录写入历史表
	private void insertHistory() throws Exception {
		int count = returnHistoryList.size();
		if (count > 0) {
			StringBuffer send_ids = new StringBuffer();
			for (int i = 0; i < count; i++) {
				Map map = (Map) returnHistoryList.get(i);
				send_ids.append(map.get("send_id")+",");
			}
			send_ids.deleteCharAt(send_ids.lastIndexOf(","));
			StringBuffer sqlstr = new StringBuffer();
			sqlstr.append("insert into t_sms_send_history( ");
			sqlstr.append("select * FROM t_sms_send where send_id in (");
			sqlstr.append(send_ids.toString());
			sqlstr.append(")");
			Connection conn = SmsManager.getJdbcTemplate().getDataSource().getConnection();
			Statement stat = null;
			try {
				conn.setAutoCommit(false);
				stat = conn.createStatement(); 
				stat.execute(sqlstr.toString());
				stat.execute("delete from t_sms_send where send_id in ("+send_ids.toString()+")");
				conn.commit();
			} catch (Exception e) {
				SmsManager.sendMsgToServicer(e,"平台短信服务器出现异常");
			}finally{
				if(!stat.isClosed()){
					stat.close();
				}
				if(!conn.isClosed()){
					conn.close();
				}
			}
		}
	}

	// 查找400平台发送表中待发送的记录
	private void findSending() throws Exception {
		sendingList = SmsManager
				.getJdbcTemplate()
				.queryForList(
						"select send_id,customer_id,msg_type,msg_content,phone_nums from t_sms_send where send_state = 1 and smsg_id is null limit 100");
	}

	// 发送短信
	private void sendQueue() throws Exception {
		for (int i = 0; i < sendingList.size(); i++) {
			if(sendThreadCount <= 100){
				Map map = (Map) sendingList.get(i);
				SmsManager.getJdbcTemplate().execute("update t_sms_send set smsg_id = '10000' where send_id = "+map.get("send_id"));
				Map msg = new HashMap();
				msg.put("send_id", map.get("send_id"));
				msg.put("customer_id", map.get("customer_id"));
				msg.put("phone_nums", map.get("phone_nums"));
				msg.put("msg_content", map.get("msg_content"));
				Thread trecv = new SendThread(msg);
				trecv.setName("SMS_"+sendThreadCount);
				sendThreadCount++;
				trecv.start();
			} 
		}
	}

	/**
	 * 重置发送数据
	 */
	private void reset() {
		returnHistoryList = new ArrayList();
		sendingList = new ArrayList<Map>();
	}
}


//发送短信线程
class SendThread extends Thread {
	private Map msg = null;
	public SendThread(Map msg){
		this.msg = msg;
	}
	public void run() {
		String sMsgId = "";
		try {
			String strMsg = msg.get("msg_content").toString();
			String phone_nums = msg.get("phone_nums").toString();
			if(!Public.isNotNull(phone_nums)){
				return;
			}
			//发送短信
			SmsManager.send(strMsg,phone_nums);
			returun;
		} catch (Exception e) {
		} finally{
			ServiceThread.sendThreadCount--;
		}
	}
}