?? httpservices.java
字號:
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();
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -