reloadserver.java

中国联通炫铃业务接口开发

package com.wireless.crbt.gwif.workthread;

import org.apache.log4j.Logger;
import org.apache.log4j.xml.DOMConfigurator;

import com.wireless.crbt.gwif.global.LoggerConstant;
import com.wireless.gwif.socketconn.ObjectReceAdapter;
//import com.wireless.sms.business.logicprocess.CommonData;
//import com.wireless.sms.business.threadpool.ReloadProcess;
import com.wireless.sms.gwif.smsagent.SmsGWIFGlobal;

public class ReloadServer {

    private static Logger log = LoggerConstant.statlog;
    private static ObjectReceAdapter ora = null;
    private static boolean startFlag = false;

    public static void start(String port) {
        if( startFlag )
            return;
        else
            startFlag = true;
        LoggerConstant.log.info("------启动退出监控线程");

            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 ...");
                            CrbtReloadProcess.getInstance().stopInterface();
                            stop();
                            break;
                        case 2:
                          //保存数据
                          log.info("Stop For Save Data ...");
//                          CrbtReloadProcess.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"});
    }

}