package test;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Enumeration;
import java.util.Hashtable;
import test.*;

public class Communicate implements Runnable
{

 private Socket sockct;
 private Hashtable sockets;
 private InputStream is;
 
 
 public Communicate(Socket sockct, Hashtable sockets) throws IOException
 {
  this.sockct = sockct;
  this.sockets = sockets;
  is  = sockct.getInputStream();
 }
 
 public void run()
 {
  byte[] b = new byte[20];
  while(true)
  {
   try
   {
    //接收該客戶機(jī)的繪制信息
    is.read(b, 0, 20);
    Enumeration enumeration = sockets.elements();
    
    while(enumeration.hasMoreElements())
    {
     Object object = enumeration.nextElement();
     Socket socketAllClient = (Socket)object;
     if(sockct != socketAllClient)
     {
      //向其他客戶機(jī)發(fā)送信息
      OutputStream osAllClient = socketAllClient.getOutputStream();
      osAllClient.write(b, 0, 20);
     }
    }
   }
   catch (IOException e)
   {
    e.printStackTrace();
   }
  }
 }
 
}