userthread.java

来自「java制作的C/S程序」· Java 代码 · 共 60 行

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.getOutputStream());
		}
		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 dataProcess(String msg) throws IOException
	{
		System.out.println("服务器接收到数据:"+msg);
		String newMsg;
		newMsg="服务器接收到你的数据为:"+msg;
		sendString(newMsg);
	}
	public void sendString(String msg) throws IOException
	{
		StringBuffer msgBuffer=new StringBuffer(msg);
		outStream.(msg);
	}
}