appreceiver.java

采用JAVA开发

package com.gctech.sms.app;

import java.io.InputStream;
import java.io.*;
import org.apache.log4j.Logger;
import com.gctech.util.Tools;
import com.gctech.sms.msg.MTInfo;
import java.io.ObjectOutputStream;
import com.gctech.sms.msg.MTAck;
import java.util.StringTokenizer;
import java.util.Map;
import java.util.HashMap;
import java.util.Properties;
import com.gctech.util.net.SocketService;

/**
 * <p>Title: 应用层消息接收者。</p>
 * <p>Description: 应用层接收者，负责接收应用层发过来的MT、订阅请求等信息，
 * 为了客户端方便，使用短连接。</p>
 * 要保证安全，适合异构系统。
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: AppReceiver.java,v 1.1.1.1 2004/04/21 09:30:41 wanghb Exp $
 */

public class AppReceiver extends SocketService{
  static Map appServices;
  /***
   * 载入服务。
   * */
  public static void loadServices(Properties props){
    appServices = new HashMap();
    StringTokenizer stk = new StringTokenizer(props.getProperty(
        "com.gctech.sms.app.AppReciever.services"), ",");
    for ( ; stk.hasMoreTokens(); ){
      String service = stk.nextToken();

      Integer serviceId = Integer.decode(props.getProperty(
          "com.gctech.sms.app.AppReciever.services."+service+".seq"));
      String serviceName = props.getProperty(
          "com.gctech.sms.app.AppReciever.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);
      }
    }

  }

  public AppReceiver() {
  }
  public void run(){
    try {
      //收到消息
      ObjectInputStream in = new ObjectInputStream(sock.getInputStream());

      //读取消息类型
      int cmdType = in.readInt();
      Object objService = appServices.get(new Integer(cmdType));
      if ( objService == null )
        logger.warn("消息类型："+cmdType+"没有被发现！");
      else{
        Service service = (Service)objService;
        Object obj = service.service(in.readObject());
        logger.debug(obj);
        ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
        out.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(AppReceiver.class);
}