multiserverlistener.java

基于JavaSoundDemo的多客户端语音通信

package tcpSoundCommunication;

import java.net.ServerSocket;
import java.net.Socket;
//import java.io.IOException;
import java.util.Vector;

public class MultiServerListener {
  Vector sos = new Vector();
  ServerListener g;
  ServerSocket s;
  //给计数
  static int count=0;
  static int maxCon=9;
  static final int PORT = 1983;
  MultiServerListener() {
  }

  public void clearServer() {
    for (int i = 0; i < sos.size(); i++) {
      ServerListener g = (ServerListener) sos.get(i);
      g.stop();
      g=null;
//      for (Enumeration e = g.getElements(); e.hasMoreElements(); ) {
//        }
    }
    sos.removeAllElements();
    count=0;
  }

  public void getServer() throws Exception {
    s = new ServerSocket(PORT);
    System.out.println("Server Started");
    try {
      while (true) {
        if(count >= maxCon)break;
        // Blocks until a connection occurs:
        Socket socket = s.accept();
        try {
          ServerListener sl = new ServerListener(socket);
          sos.addElement(sl);
          count++;
          System.out.println("连接:" + socket.isConnected()+"，目前有连接 "+count+" 个，上限为"+maxCon+"人");
        }
        catch (Exception e) {
          // If it fails, close the socket,
          // otherwise the thread will close it:
          socket.close();
        }
      }
    }
    finally {
      s.close();
    }
  }
}