clientthread.java

java2 游戏设计书的全部源码

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

import java.io.*;
import java.awt.*;
import java.net.*;
import java.util.*;                             //为了建立Vector实体
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++;               //建立新联机,联机数加1
      
      try
      {
         //建立I/O管道
         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"))   //如果是bye字符串则结束联机
                  {
                     ConnectNumber--;         //联机数减1

                     //广播成员离开讯息      
                     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;                //释放资源
   }
}