multisvcconsvr.java

采用JAVA开发

package com.gctech.util.net;

import java.util.Map;
import java.net.Socket;
import java.io.ObjectInputStream;
import java.util.HashMap;
import java.io.InputStream;
import org.apache.log4j.PropertyConfigurator;

/**
 * <p>Title: 多服务并发服务器。</p>
 * <p>Description: 多服务并发服务器。</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @deprecated
 * @author 王红宝
 * @version $Id: MultiSvcConSvr.java,v 1.1.1.1 2004/04/21 09:30:42 wanghb Exp $
 */

public class MultiSvcConSvr extends AbstractConcurrentServer{
  private Map services;
  public static void main(String[] args){
    //ThreadManager.getInstance().loadThreadPool();
    PropertyConfigurator.configure("./conf/log4j.properties");
    Map svcs = new HashMap();
    svcs.put(new Byte((byte)97), "com.gctech.sms.net.EchoService");
    svcs.put(new Byte((byte)98), "com.gctech.sms.net.EchoService2");
    MultiSvcConSvr svr = new MultiSvcConSvr(8001, "TEST SERVER", svcs);
    Thread t = new Thread(svr);
    t.start();
  }
  public MultiSvcConSvr(int port, String serverName,
                          Map services) {
    this.port = port;
    this.serverName = serverName;
    this.services = services;
  }
  protected SocketService createSocketService(Socket sock) throws
      Exception{
    InputStream in = sock.getInputStream();
    int serviceId = in.read();
    System.out.println(serviceId);
    String serviceName = services.get(new Byte((byte)serviceId)).toString();
    SocketService service =
            (SocketService)Class.forName(serviceName).newInstance();
    return service;
  }

}