sendthread.java

中国联通短信通信协议

package com.wireless.sms.unsoap.workthread;

import java.util.Timer;
import java.util.TimerTask;

import com.wireless.sms.gwif.smsagent.global.LoggerConstant;
import com.wireless.sms.pub.entity.MO;
import com.wireless.sms.pub.entity.Monitor;
import com.wireless.sms.pub.net.MOClientSocket;
import com.wireless.sms.pub.net.MonitorClientSocket;
import com.wireless.sms.unsoap.global.Constant;

public class SendThread {

	  private static SendThread _instance = new SendThread();
	  private Timer timer = null;
	  public MOClientSocket moClientSocket = null;

	  public static SendThread getInstance(){
	    return _instance;
	  }

	  private SendThread(){
	  }

	  public void start(){
	    if( timer == null ){
	      LoggerConstant.mo_log.info("Start mo sender !");
	      moClientSocket = new MOClientSocket(Constant.ROUTERHOST, Constant.ROUTERPORTS);
	      timer = new Timer();
	      timer.schedule(new TimerTask(){
	        public void run(){
	          MO mo = (MO)Constant.MOQUEUE.removeNoWait();
	          if( mo != null ){
	            boolean sendFlag = moClientSocket.sendMO(mo);

	            if( sendFlag ){
	              LoggerConstant.mo_log.info("发送 MO 成功 !");
	            }
	            else{
	              Constant.MOQUEUE.add(mo);
	              sendmonitor("R000101");
	            }
	          }
	        }
	      }, 5000, 5000);
	    }
	  }

	  public void stop(){
	    if( timer != null ){
	      timer.cancel();
	      timer = null;
	      LoggerConstant.mo_log.info("Stop mo sender !");
	    }
	  }

	  public void sendmonitor(String code) {
	  Monitor monitor = new Monitor();
	  monitor.setErrorCode(code);
	  monitor.setIp(Constant.PROCESSHOST);
	  monitor.setPeriod("");
	  monitor.setProcessName(Constant.switch_name);
	  MonitorClientSocket errorsocket = new MonitorClientSocket(Constant.MONITORHOST, Constant.MONITORPORT);
	  errorsocket.sendMonitor(monitor);
	}



}