readthread.java~3~

JBuilder实现的具有单机

package client;

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

class ReadThread extends Thread
{
    Socket socketIn=null;
    //用户连接的通信套接字
    BufferedReader input;
    //输入流
    String m_sReadIn="";
    //读进来的数

    final int RECEIVE_IN_PORT=9091;
    public ReadThread(String str)
    {
        InputStreamReader reader;
        try{
        //初始化输入、输出流
              socketIn=new Socket(str,RECEIVE_IN_PORT);
              reader=new InputStreamReader(socketIn.getInputStream());
              input=new BufferedReader(reader);
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }
    }

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

        while(!done)
        {
            try
            {
                m_sReadIn=input.readLine();

            }
            catch(IOException e)
            {
                System.out.println(e.getMessage());
            }
            m_sReadIn=m_sReadIn.trim().toLowerCase();
            if(m_sReadIn.equals("quit")) done=true;
            //命令quit结束本次连接
        }
        try
        {    input.close();
             socketIn.close();        //关闭套接字
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }
        //end of run
   }
}