moreceiver.java

采用JAVA开发

package com.gctech.sms.platform;

import org.apache.log4j.Logger;

import com.gctech.sms.msg.GatewayType;
import com.gctech.sms.msg.MOAck;
import com.gctech.sms.msg.MOInfo;
import com.gctech.sms.util.MsgIdConverter;
import com.gctech.sms.util.ThreadManager;
import com.gctech.sms.util.Utility;

/**
 * <p>Title: 上行接收者</p>
 * <p>Description: 上行接收者，接收来自各个网关的MO信息。</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: MOReceiver.java,v 1.3 2004/05/11 02:13:23 wanghb Exp $
 */

public class MOReceiver extends LongSockService {
	public MOReceiver() {
		this.gatewayType = GatewayType.MO;
	}
	private static final Logger logger = Logger.getLogger(MOReceiver.class);

	/**
	 * 上行处理类。
	 * 每网关一个连接。
	 * */
	protected void processRequest() throws Exception {
		//收到上行
		final MOInfo moInfo = (MOInfo) ois.readObject();
		moInfo.srcPhoneNo = moInfo.srcPhoneNo.trim();

		//日志功能，文件和数据库各记一份。
		moInfo.strMsgID = MsgIdConverter.convert(moInfo.strMsgID.getBytes()).toString();
		logger.info(moInfo);
		MyLogger.getInstance().logMo(moInfo);

		//回复消息
		MOAck objMOAck = new MOAck();
		objMOAck.donetime = Utility.getInstance().curTime();
		objMOAck.status = 0;
		oos.writeObject(objMOAck);
		oos.reset();

		//如果不是状态报告
		//edit by liyi 将状态报告传给handler
		//if (moInfo.IsReply == 0) {
			//放到线程池中处理一条上行。
			ThreadManager.getInstance().execute(new Runnable() {
				public void run() {
					MODispatcher.getInstance().dispatch(moInfo);
				}
			});
		//}
	}

}