smsreceiver.java

中国联通短信通信协议

package com.wireless.sms.unsoap;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.configuration.Configuration;
import org.apache.commons.configuration.DOM4JConfiguration;

import com.wireless.sms.gwif.SmsGWIF;
import com.wireless.sms.gwif.smsagent.global.LoggerConstant;
import com.wireless.sms.gwif.smsagent.global.SmsGWIFGlobal;
import com.wireless.sms.gwif.smsagent.workthread.ReloadProcess;
import com.wireless.sms.pub.db.ConnectionPool;
import com.wireless.sms.unsoap.global.Constant;
import com.wireless.sms.unsoap.global.DBPool;
import com.wireless.sms.unsoap.workthread.StructMO;

public class SMSReceiver extends HttpServlet {
	static final long serialVersionUID=1L; 

	static final private String CONTENT_TYPE = "text/xml;charset=UTF-8";

	public static Configuration configuration = null;

	/**Initialize global variables*/
	public void init() throws ServletException {

	    /**ServletConfig.getInitParameter(name)返回web.xml配置文件中name的值<一般是init-param.param-name和.param-value>
	     * ServletConfig.getServletContext()返回servlet上下文对象的引用
	     */
	    String path = getServletContext().getRealPath("");
	    System.out.println("ServletContext path = "+path);
	    //初始化log4j
		String log4j_filename = getInitParameter("log4j");
		try {
		      File file ;
		      if(log4j_filename.startsWith(path))
		    	  file = new File(log4j_filename);
		      else
		    	  file = new File(path + log4j_filename);
		      if (file.exists()) {
		    	  LoggerConstant.init(path + log4j_filename);
		      }
		      else {
		        System.err.println("System can not find " + file +
		                                   " file !Please try again \n");
		        return;
		      }
		} catch (Exception ex) {
			ex.printStackTrace();
			return;
		}
		//初始化全局配置文件config.xml
	    String config_filename = getInitParameter("config");
	    try {
	      File file ;
	      if(config_filename.startsWith(path))
				file = new java.io.File(config_filename);
			else
				file = new java.io.File(path + config_filename);
	      if (file.exists()) {
	        configuration = new DOM4JConfiguration(file);
	      } else {
	        LoggerConstant.stat_log.error("System can not find " + file +
	                                   " file !Please try again \n");
	        return;
	      }
	    }
	    catch (Exception ex) {
	    	LoggerConstant.stat_log.error("Exception:",ex);
	    	return;
	    }
	    initConstant(path);
	    //启动主要处理进程
	    new SmsGWIF().start();
	    //启动mt发送
	    SMSSender.getInstance().start();
//	    Runtime.getRuntime().addShutdownHook(new Thread(new StopSignal()));
	}
	
	public static void initConstant(String path){
		/**初始化系统常量*/
	    Constant.TYPE = configuration.getString("type");
	    Constant.optype = configuration.getString("optype","un");
	    Constant.USEDBFLAG = configuration.getString("usedbflag", "false");
	    Constant.SENDFLAG = configuration.getString("sendflag", "false");
	    Constant.DBFILEPATH = configuration.getString("dbfilepath");
	    //监控ip和端口
	    Constant.MONITORHOST = configuration.getStringArray("monitorserver.monitor");
	    Constant.MONITORPORT = configuration.getStringArray(
	        "monitorserver.monitor[@port]");
	    //路由IP和端口
	    Constant.ROUTERHOST = configuration.getStringArray(
	        "routerservers.routerserver");
	    Constant.ROUTERPORTS = configuration.getStringArray(
	        "routerservers.routerserver[@port]");
	    //SOAP请求服务端URL地址
	    Constant.SendSms_address = configuration.getString("SendSms_address");
	    //本地接收服务地址
	    Constant.ReciveSms_address = configuration.getString("ReciveSms_address");
	    if(Constant.SendSms_address == null){
	    	LoggerConstant.stat_log.error("ERROR Config : SendSms_address can't be null!");
	    	return;
	    }else{
	    	Constant.SendSms_address = Constant.SendSms_address.trim();
	    }
	    //监控包初始化对象:处理主机,名称
	    Constant.PROCESSHOST = configuration.getString("processhost");
	    Constant.switch_name = configuration.getString("switch_name");
	    //网关服务号及编号
	    Constant.SPNUMBER = configuration.getString("spnumber");
	    Constant.GATEWAYID = configuration.getString("gatewayid");
	    
	    //初始化数据库
	    if(Constant.DBFILEPATH.replaceAll("\\\\", "/").startsWith(path.replaceAll("\\\\", "/")))
	    	DBPool.POOL = ConnectionPool.getInstance(Constant.DBFILEPATH.replaceAll("\\\\", "/"));
	    else
	    	DBPool.POOL = ConnectionPool.getInstance((path + Constant.DBFILEPATH).replaceAll("\\\\", "/"));

	    //初始化mo队列
//	    queueinit(Constant.MOFILEPATH);
	    LoggerConstant.stat_log.info("SendSms_address = "+Constant.SendSms_address);
	    LoggerConstant.stat_log.info("ReciveSms_address = "+Constant.ReciveSms_address);
	    LoggerConstant.stat_log.info("optype = "+Constant.optype);
	    LoggerConstant.stat_log.info("Provision process initiate");
	    
	}

  public void doGet(HttpServletRequest request, HttpServletResponse response) throws
      ServletException, IOException {
    doPost(request, response);
  }

  /**
   * 1.接收流2.解析流3.返回值4.处理（发送mo或调用存储过程）
   * @param request HttpServletRequest
   * @param response HttpServletResponse
   * @throws ServletException
   * @throws IOException
   */
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws
      ServletException, IOException {
/*5.3.2.2  上行 SOAP HEADER 参数 
参数名  类型  描述 
SPrevID xsd:string SP反向调用名，可选 
SPrevpassword  xsd:string SP反向调用密码，可选 
SpId xsd:string SP 
SPNumber xsd:string  业务接入码 
ServiceId xsd:string  业务ID 
SessionID xsd:string  业务流水号，用于组合业务。可选 
LinkID xsd:string  事务关联ID，用于点播业务的事务关联，由平台产生。格式
为：MMDDHHMMSS+10 */
    response.setContentType(CONTENT_TYPE);
    BufferedOutputStream bout = new BufferedOutputStream(response.
        getOutputStream());
//    PrintWriter out = response.getWriter();
    String requesturl = request.getRequestURL().toString();//重新构造客户端用于产生请求的URL(包括:服务器名、端口、路径)
    LoggerConstant.mo_log.info("Request from Client: " + request.getRemoteAddr());//返回请求的客户端或最后一个代理服务器的IP
    LoggerConstant.mo_log.info("requesturl: " + requesturl);
    //声明输入流
    BufferedInputStream bin = null;
    try {
			// 1.接收流*****************************//
			bin = new BufferedInputStream(request.getInputStream());// 返回一个输入流，该输入流将以二进制数据方式读取请求正文的内容
			int len = request.getContentLength();// 以字节为单位，返回正文的长度，如果长度不可知，则返回-1
			byte[] tmp = new byte[len];
			bin.read(tmp);
			LoggerConstant.mo_log.info(new String(tmp));

			String response_xml = "";
			try {
				response_xml = new StructMO().process(tmp);
			} catch (Exception ex) {
				ex.printStackTrace();
				LoggerConstant.mo_log.error(new String(tmp));
			}
			
			bout.write(response_xml.getBytes());//"ISO-8859-1"));
			bout.flush();
			LoggerConstant.mo_log.info("Send Response:" + response_xml);
		} finally {
			try {
				if (bin != null) {
					bin.close();
					bin = null;
				}
				if (bout != null) {
					bout.close();
					bout = null;
				}
			} catch (Exception e) {
				LoggerConstant.mo_log.error(e.getMessage());
			}
		}
  }

  // Clean up resources
  public void destroy() {
		LoggerConstant.mo_log.info("run destroy!");
		SMSSender.getInstance().stopSendMT();
//		StopSignal.doStop();
	    SmsGWIFGlobal.sendMonitor("I000011");
	    ReloadProcess.getInstance().stopInterface();
		LoggerConstant.stat_log.info("destory over!");
	}
}