userthread.java

来自「java网络高级编程的配套源码,java网络高级编程为清华出版社出版.」· Java 代码 · 共 67 行

/*源程序清单8-16*/
	
import java.io.*;
import java.net.*;

public class UserThread extends Thread
{
	protected DataInputStream inStream;
	protected DataOutputStream outStream;
	protected Socket socket;

	public UserThread(Socket socket)
	{
		try
    {
    	this.socket=socket;
      inStream=new DataInputStream(socket.getInputStream());
      outStream=new DataOutputStream(socket.getOutStream());
      sendString("我是客户机！");
     }
     catch(Exception e)
     {
       System.out.println(e.toString());
     }
  }

	public void run()
	{
		String str=null;
		try
		{
			while(true)
			{
				str=inStream.readUTF();
				dataProcess(str);
			}
		}
		catch(Exception e)
		{
			System.out.println(e.toString());
		}
		finally
		{
			try
			{
				socket.close();
			}
			catch(IOException e1)
			{
				System.out.println(e1.toString());
			}
		}
	}

  public void dataProecess(String msg)
  {
    System.out.println("客户机接收到数据"+msg);
  }

	public void sendString(String msg) throws IOException
	{
		StringBuffer msgBuffer=new StringBuffer(msg);
		outStream.println(msgBuffer);
	}
}