?? resendthread.java
字號:
package mmscenter;import java.util.*;public class ResendThread extends Engine{ public DBConnection db = new DBConnection(Config.db_name ,Config.db_host); //取得200條 沒有發(fā)送成功的數(shù)據(jù) public String selectSql = "select * from mms_submit where result <> 0 and result <>1 and result <>2 and resend > 0 limit 200"; public String getServiceCode = "select service_code from mms_content where content_id ="; public ResendThread() { super("ResendThread"); setDaemon(true); } public void run(){ while(true){ Vector taskV = new Vector(); taskV = (Vector)db.execute(selectSql) ; if(taskV.size() >0){ System.out.println(":"+Utility.getTimeString()+":"+"補發(fā)線程 : "+"發(fā)現(xiàn) "+taskV.size()+" 條沒有發(fā)送成功的MMS包"); Config.LogPool.push("補發(fā)線程 : "+"發(fā)現(xiàn) "+taskV.size()+" 條沒有發(fā)送成功的MMS包"); }else{ System.out.println(":"+Utility.getTimeString()+":"+"補發(fā)線程 : "+"發(fā)現(xiàn) "+taskV.size()+" 條沒有發(fā)送成功的MMS包"); } for(int i = 0 ;i < taskV.size() ; i++){ Vector sV = new Vector(); MMS mms = new MMS(); mms.id = Long.parseLong(((String)(((Vector)taskV.get(i)).get(0)))); mms.content_id = Long.parseLong(((String)(((Vector)taskV.get(i)).get(1)))); mms.subject = (String )((Vector)taskV.get(i)).get(2); mms.create_time = (String)((Vector)taskV.get(i)).get(3); mms.dest_terminal_id = (String)((Vector)taskV.get(i)).get(5); mms.fee_terminal_id = (String)((Vector)taskV.get(i)).get(6); mms.fee_type = (String)((Vector)taskV.get(i)).get(7); mms.fee_code = (String)((Vector)taskV.get(i)).get(8); //mms.servicecode = (String)((Vector)taskV.get(i)).get(9); sV = (Vector)db.execute(getServiceCode+mms.content_id); String service_code = (String)((Vector)sV.get(0)).get(0); //mms.servicecode = (String)((Vector)taskV.get(i)).get(9); mms.servicecode = service_code; mms.resend = (String)((Vector)taskV.get(i)).get(11); if(Config.TaskPool.getSize()<200){//保證隊列中有<=200個MMS包 Config.TaskPool.push(mms); System.out.println(":"+Utility.getTimeString()+":"+"補發(fā)線程 : "+"ID號 "+mms.id+" 的MMS包進(jìn)入發(fā)送隊列"); Config.LogPool.push("補發(fā)線程 : "+"ID號 "+mms.id+" 的MMS包進(jìn)入發(fā)送隊列"); } }// System.out.println(Config.TaskPool.getSize());// MMS mms1 = new MMS();// mms1 = (MMS) Config.TaskPool.pop();// System.out.println(mms1.id); try{ sleep(TimeConfig.TIME_ONE_MINUTE/6); }catch(Exception e){ e.printStackTrace() ; } } } public static void main(String[] args) { ResendThread resendThread1 = new ResendThread(); }}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -