import java.net.*; import java.io.*; import java.util.*; public class SocketServer2 extends Thread{ Vector v = null; ServerSocket ss = null; public SocketServer2() { v = new Vector(); try{ ss = new ServerSocket(8000); }catch(Exception e){System.out.println(e);} this.start(); }
public static void main(String[] args) { new SocketServer2(); } public void run() { try{ while(true) { /* 为各个客户端建立连接并用Vector存储相关信息,据<thinking in java>上说ArrayList更好,不过我对ArrayList不熟,就将就用Vector了 */
Socket sc = ss.accept(); InputStream is = sc.getInputStream(); OutputStream os = sc.getOutputStream() ; Exchange ct = new Exchange(this,is,os); v.addElement(ct); } } catch(Exception e){} } public void sendMsg(String str){ /* 利用存储的各个流信息进行广播 */