readthread.java

来自「一个使用JB9编写的网络俄罗斯方块,大家可以下载如有不足还请原谅,有是可以给我E」· Java 代码 · 共 64 行

package Server;

//类serverThread
import java.io.*;
import java.net.*;

class ReadThread extends Thread
{
    Socket clientRequest;
    //用户连接的通信套接字
    BufferedReader input;
    //输入流
    String m_sReadIn="";
    //读进来的数
     Server m_myServer;
    public ReadThread(Socket s,Server ms)
    {  //serverThread的构造器
        this.clientRequest=s;

        this.m_myServer=ms;
        //接收receiveServer传来的套接字
        InputStreamReader reader;
        try{
        //初始化输入、输出流
              reader=new InputStreamReader(clientRequest.getInputStream());
              input=new BufferedReader(reader);//将reader的流放如Buffer缓存中
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }
    }

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

        while(!done && m_myServer!=null)
        {
            try
            {
                m_sReadIn=input.readLine();
                m_myServer.readStr(m_sReadIn);
                //接收客户机指令

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

   }
}