clientthread.java

用JAVA进行游戏设计的图书 可以了解JAVA的运行状态 和编写游戏的特点

// 程序：处理客户端连线多线程
// 范例文件：ClientThread.java

import java.io.*;
import java.awt.*;
import java.net.*;
import java.util.*;           
import java.awt.event.*;

class ClientThread extends Thread 
{
   Socket          cSocket;   
   PrintStream     write;   
   BufferedReader  read;         
   ServerThread    sThread;

   TextArea        sStatus;
   String          m;

   public static int ConnectNumber = 0;  
   
   public ClientThread(Socket cSocket,ServerThread sThread)
   {
      this.cSocket = cSocket;
      this.sThread = sThread; 

      sStatus      = sThread.frame.ServerStatus;  
 
      ConnectNumber++;     
      
      try
      {

         write = new PrintStream(cSocket.getOutputStream());
         read  = new BufferedReader(
                     new InputStreamReader(cSocket.getInputStream()));
      }
      catch(IOException E)    
      {
         System.out.println("发生例外: " + E);
         System.out.println("建立I/O管道失败!");
         System.exit(3);  
      }
 
      m = "新伙伴<" + getClientName() + ">加入罗!!! ";
      m = m + "聊天室人数: " + ConnectNumber + " \n\n";
   
      sThread.messages.addElement(m);
   }
  
   public void run()
   {
      while(true)
      {
         try
         {
            String Message = read.readLine(); 

            synchronized(sThread.messages)    
            {
               if(Message != null)   
               {
                  if(Message.equals("bye"))  
                  {
                     ConnectNumber--;     

                     Message = getClientName() + ":" + getClientAddress() + 
                               "已离开 ";

                     sStatus.append(Message + " ");
                     sStatus.append("目前连线数: " + ConnectNumber + "\n");

                     sThread.messages.addElement(Message);

                     synchronized(sThread.Clients) 
                     {
                        sThread.Clients.removeElement(this); 
                     }

                     break;      
                  }
                  else
                  {
                     Message = "来自" + getClientName() + ":" + 
                               getClientAddress() + "\n=> " + Message + "\n";

                     sThread.messages.addElement(Message);
                  }
               }
            }
         }
         catch(IOException E) 
         { 
            break;    
         }
      }
   }

   public String getClientName() 
   {
      return cSocket.getInetAddress().getHostName();
   }
  
   public String getClientAddress()  
   {
      return cSocket.getInetAddress().getHostAddress(); 
   }

   public void finalize()
   {
      try
      {
         read.close();
         write.close();
         cSocket.close();  
      }
      catch(IOException E){}
     
      cSocket = null;    
   }
}