reloadserver.java

中国联通短信通信协议

package com.wireless.sms.gwif.smsagent.workthread;


//import java.util.*;
import org.apache.log4j.*;

//import com.wireless.sms.pub.entity.*;
//import com.wireless.sms.pub.mq.*;
import com.wireless.gwif.socketconn.*;
import com.wireless.sms.gwif.smsagent.func.CommonData;
import com.wireless.sms.gwif.smsagent.global.*;
import org.apache.log4j.xml.DOMConfigurator;

public class ReloadServer {

    private static Logger log = LoggerConstant.stat_log;
    private static ObjectReceAdapter ora = null;
    private static boolean startFlag = false;
    /** 启动退出进程监听线程 */
    public static void start(String port) {
    	log.info("启动退出程序监听线程....监听本地端口 : "+port);
        if( startFlag )
            return;
        else
            startFlag = true;

            ora = new ObjectReceAdapter();
            ObjectReceAdapter.Templet receive = ora.new Templet() {
                public void receive(Object object) {
                    int value = Integer.parseInt((String)object);
                    log.info("Receive flag : " + value);

                    switch(value){
                        case 1:
                            //退出系统
                            log.info("Stop Interface ...");
                            ReloadProcess.getInstance().stopInterface();
                            stop();
                            break;
                        case 2:
                          //保存数据
                          log.info("Stop For Save Data ...");
                          ReloadProcess.getInstance().stopForSaveData();
                          break;
                        case 3:
                          //保存数据
                          log.info("测试连接信息 ...");
                          break;
                        case 4:
                          //更新测试数据
                          log.info("更新测试数据 ...");
                          CommonData.updateTestData();
                          break;
                      default:
                          log.info("指令错误，请发送正确指令 ...");
                          break;
                    }
                }

                /**
                 * processException
                 * @param cause Throwable
                 */
                public void processException(Throwable cause) {
                    log.error("Exception : ", cause);
                    log.error("当前加载器----------------------"+getClass().getClassLoader().toString());
                }
            };

            receive.setLog(log);
            ora.start(receive, port);
    }

    public static void stop(){
        new Thread(){
          public void run(){
            if( ora != null ){
                ora.stop();
            }

            startFlag = false;
          }
        }.start();


    }

    public static void main(String args[]){
        DOMConfigurator.configure(System.getProperty("log4j"));

        try {
            SmsGWIFGlobal agent = SmsGWIFGlobal.getInstance();
            agent.initYD_System();
        } catch (Throwable ex) {
            ex.printStackTrace();
        }

        MtReceiver.start(new String[]{"9000"});
    }

}