abstractappreceiver.java

采用JAVA开发

package com.gctech.sms.app;

import com.gctech.util.net.SocketService;
import java.util.Properties;
import com.gctech.util.StartException;
import com.gctech.util.Startable;
import java.util.Map;
import java.util.HashMap;
import java.util.StringTokenizer;
import org.apache.log4j.Logger;
import java.io.InputStream;
import java.io.IOException;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public abstract class AbstractAppReceiver extends SocketService implements Startable{
  public AbstractAppReceiver() {

  }
  Map appServices;
  /**
   * 载入服务。
   * */
  public void start(Properties props) throws StartException {
    appServices = new HashMap();
    StringTokenizer stk = new StringTokenizer(props.getProperty(
        "com.gctech.sms.app.AbstractAppReceiver.services"), ",");
    for ( ; stk.hasMoreTokens(); ){
      String service = stk.nextToken();

      Integer serviceId = Integer.decode(props.getProperty(
          "com.gctech.sms.app.AbstractAppReceiver.services."+service+".seq"));
      String serviceName = props.getProperty(
          "com.gctech.sms.app.AbstractAppReceiver.services."+service+".class");
      try {
        appServices.put(serviceId, Class.forName(serviceName).newInstance());
        logger.info("注册服务 ID："+ serviceId + ",服务类名："+serviceName
                    +" 成功。" );
      }
      catch (Exception ex) {
        logger.info("注册服务 ID："+ serviceId + ",服务类名："+serviceName
                    +" 失败。" , ex);
      }
    }
  }

  abstract protected int getType(InputStream in) throws IOException ;
  abstract protected Object readObject(InputStream in) throws IOException
      ,ClassNotFoundException;
  abstract protected void writeObject(Object obj) throws IOException ;
  public void run(){
    try {
      //收到消息
      InputStream in = sock.getInputStream();

      //读取消息类型
      int cmdType = getType(in);
      Object objService = appServices.get(new Integer(cmdType));
      if ( objService == null )
        logger.warn("消息类型："+cmdType+"没有被发现！");
      else{
        Service service = (Service)objService;
        Object obj = service.service(readObject(in));
        logger.debug(obj);
        writeObject(obj);
      }
    }
    catch (Throwable ex) {
      logger.error(ex, ex);
    }finally{
      if ( sock != null ){
        try {
          sock.close();
        }
        catch (Throwable ex1) {
          logger.error(ex1, ex1);
        }
      }
    }
  }


  static final Logger logger = Logger.getLogger(AbstractAppReceiver.class);

}