mosender.java

采用JAVA开发

package com.gctech.sms.gateway.basic;

import java.net.Socket;
import java.io.ObjectOutputStream;
import java.io.ObjectInputStream;
import java.util.Vector;
import com.gctech.sms.msg.MOInfo;
import com.gctech.sms.msg.MOAck;
import java.net.InetAddress;
import org.apache.log4j.Logger;
import java.util.List;
import com.gctech.sms.core.IsReply;

/**
 * <p>Title: 上行发送者</p>
 * <p>Description: 将收到的信息发送给短信业务平台。</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: MOSender.java,v 1.1.1.1 2004/07/26 02:44:25 lijz Exp $
 */

public class MOSender extends LongConnectClient implements Runnable{


  private List msgList = null;
  //增加到上行列表

  public MOSender( int gateway, String strGateway, String gatewayDesc,
                     String serverIp, int serverPort){
    this.intGateway = gateway ;
    this.strGateway = strGateway ;
    this.serverPort = serverPort;
    this.serverIp = serverIp;
    this.gatewayDesc = gatewayDesc;
    this.gatewayType = 2;
    while(!this.keepAlive()) ;

  }

  public void run(){
    msgList = DataList.getInstance().moList;
    while( true ){
      MOInfo info = null ;
      try{
        while( true ){
          if( !msgList.isEmpty() ){
            info = ( MOInfo )msgList.remove( 0 ) ;
            logger.debug("mosender gateway:"+info.gateway);
            oos.writeObject( info ) ;
            MOAck objMOAck = ( MOAck )ois.readObject() ;
            oos.reset() ;
            logger.debug("msg "+info.strMsgID + " send to server!");
          }
          else{
            Thread.sleep( 10 ) ;
          }
        }
      } catch( Exception ex ){
        logger.error(ex, ex);
        msgList.add(info) ;
        while(!this.keepAlive()) ;
      }
    }
  }


  static final Logger logger = Logger.getLogger(MOSender.class);
}