readthread.java~11~

JBuilder实现的具有单机

package Server;

import java.io.*;
import java.net.*;




public class ReadThread extends Thread
{

    BufferedReader input;
    //输入流
    String m_sReadIn="";

    public static boolean Isnotread=true;

    MyServer m_myServer;
    Socket clientRequest;

    public ReadThread( Socket s,MyServer ms)
    {   clientRequest=s;
        m_myServer=ms;
        InputStreamReader reader;
        try{
        //初始化输入、输出流
        reader=new InputStreamReader(this.clientRequest.getInputStream());
        input=new BufferedReader(reader);
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }
    }

    public void run()
    {
        //线程的执行方法
        boolean done=false;

        while(!done )
        {
            try
            {
                if(this.Isnotread){
                  m_sReadIn = input.readLine();
                }
              if(!this.isAlive())
                  this.resume();
              else this.suspend();

                //接收客户机指令

            }
            catch(IOException e)
            {
                System.out.println(e.getMessage());
            }
        }
        try
        {    input.close();
             clientRequest.close();        //关闭套接字
             m_myServer.close();
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }
        //end of run
   }

   public String getReadIn(){
     return m_sReadIn;
   }
}