mtsender.java

采用JAVA开发

package com.gctech.sms.platform;

import java.io.IOException;
import java.net.SocketTimeoutException;

import org.apache.log4j.Logger;

import com.gctech.sms.core.Gateway;
import com.gctech.sms.msg.GatewayType;
import com.gctech.sms.msg.MTAck;
import com.gctech.sms.msg.MTInfo;
import com.gctech.sms.sp.Constants;
import com.gctech.sms.sp.SpServer;
import com.gctech.util.ProtocolBuffer;
import com.gctech.util.Tools;

/**
 * <p>Title: 下行发送者</p>
 * <p>Description: 下行发送者，分拣发送各个网关的MT信息。
 * 每个网关有一个线程发送下行。</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: MTSender.java,v 1.3 2004/05/11 02:13:23 wanghb Exp $
 */

public class MTSender extends LongSockService {
	private static Logger logger = Logger.getLogger(MTSender.class);
	public MTSender() {
		this.gatewayType = GatewayType.MT;
	}

	public synchronized void sendMt(MTInfo info) throws IOException {
		oos.writeObject(info);
		oos.reset();
	}

	//读取返回消息，记录日志。
	protected void processRequest() throws Exception {
		while (sock != null && sock.isConnected()) {
			try {
				MTAck objMTAck = (MTAck) ois.readObject();
				System.out.println("要找的msgid:" + objMTAck.msgId);
				Object obj = Server.getInstance().removeMt(objMTAck);
				if (obj == null) {
					logger.warn(objMTAck + " 没有被找到！");
				} else {
					MTInfo info = (MTInfo) obj;
					System.out.println("返回的sqenceid:" + info.squeceid);
					info.MsgID2 = objMTAck.msgId2;
					System.out.println("返回的msgid2:" + info.MsgID2);
					info.nStatus = objMTAck.status;
					//记录日志
					MyLogger.getInstance().logMt(info);
					//将响应发送给二级sp
					byte[] data = new byte[36];
					ProtocolBuffer pb = ProtocolBuffer.create(36);
					pb.appendInt(36);
					pb.appendInt(Constants.SUBMIT_RES);
					pb.appendInt(objMTAck.getStatus());
					pb.appendInt(info.squeceid);
					pb.appendString(objMTAck.msgId2, 20);
					System.out.println("msgid2:"+Tools.byteArrayToHexString(objMTAck.msgId2.getBytes()));
					String spid = Gateway.getSpIdByGateway(info.gateway);
					if (spid == null)
						return;
					SpServer.getInstance().send(spid, pb.toBytes());
				}
			} catch (SocketTimeoutException ex) {
				try {
					Thread.sleep(1000L);
				} catch (InterruptedException ex1) {
					logger.error(ex1, ex1);
					throw ex1;
				}
			}
		}
	}

}