httpservices.java

对于cmpp3.0 开发有一定的帮助,请大家下载下来进行研究.

package com.zhanghao.provision;

import java.io.*;
import java.net.*;
import java.util.*;

import com.zhanghao.common.util.*;

public class HttpServices extends Thread{

  private String configProperty ="";

  private ServerSocket serverSocket ;

  public boolean isRuned = false;

  public HttpServices() throws Exception{
    try{
      loadInitCfg();
      serverSocket = new ServerSocket(ProvisionParameter.Provision_ServerSocket_Port);
    }
    catch(Exception ex){
      throw new Exception("Provision接口初始化失败:"+ex.getMessage());
    }
    isRuned = true;
  }



  public void run(){
    Debug.outInfo("[Provision]"+PublicFunction.getFormatTime()+" 同步定购客户端启动...");

    while(isRuned){
      try{
        Socket socket = serverSocket.accept();
        Debug.outInfo("[Provision]"+PublicFunction.getFormatTime()+" 新连接来自:"+socket.getRemoteSocketAddress());
        new ProvisionProcess(socket).start();
      }
      catch(Exception ex){
        ex.printStackTrace();
      }
    }

    isRuned = false;
  }


  /**
   * 读取配置文件
   */
  public void loadInitCfg() throws Exception{
    String cfgFile = "";
    try{
      cfgFile = System.getProperties().getProperty(configProperty);
      cfgFile = cfgFile == null ? "Cmpp.cfg":cfgFile;
      Debug.outDebug("Config file path:"+cfgFile);
      InputStream is = new FileInputStream(cfgFile) ;
      Properties pt = new Properties() ;
      pt.load(is) ;

      /** 更改SOCKET通讯配置参数 **/
      ProvisionParameter.Provision_ServerSocket_Port =
          Integer.parseInt(pt.getProperty("LocalProvPort", "8088"));
      Debug.outDebug("Provision LocalProvPort: \t" + ProvisionParameter.Provision_ServerSocket_Port);

      ProvisionParameter.Misc_Addr = pt.getProperty("MiscProvAddr", "8088");
      Debug.outDebug("Provision MiscProvAddr: \t" + ProvisionParameter.Provision_ServerSocket_Port);

      ProvisionParameter.SubscribeXMLFile = pt.getProperty("SubscribeXMLFile", "D:\\ISMG\\Subscribe\\SubscribeXMLFile.xml");
      Debug.outDebug("Provision SubscribeXMLFile: \t" + ProvisionParameter.SubscribeXMLFile);


    }
    catch(Exception ex){
      Debug.outDebug("[CMPP] loadInitCfg error :" +ex) ;
      throw new Exception("Provision加载配置文件失败:"+ex.getMessage());
    }
  }

  public static void main(String[] args){

    try{
      com.zhanghao.common.database.ConnectionPool.initConnectionPool(
          com.zhanghao.cmpp.CMPParameter.DBDriver,
          com.zhanghao.cmpp.CMPParameter.Connect_URL,
          com.zhanghao.cmpp.CMPParameter.DBUser,
          com.zhanghao.cmpp.CMPParameter.DBPass,
          com.zhanghao.cmpp.CMPParameter.DBPoolSize,
          20
          );
      Debug.outInfo("[CMPPMaster]"+PublicFunction.getFormatTime()+" 初始化数据库连接池成功，大小"+com.zhanghao.cmpp.CMPParameter.DBPoolSize+"，超时间隔20秒");
    }catch(Exception e){
      Debug.outInfo("[CMPPMaster]"+PublicFunction.getFormatTime()+" 初始化数据库连接池失败 "  +e.toString());
    }

    try{
      new HttpServices().start();
    }
    catch(Exception ex){
      ex.printStackTrace();
    }

  }


}