multiuser.java.bak

来自「在网上参考的SOCKET通信多线程源代码 运行通过 共享之」· BAK 代码 · 共 55 行

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


public class MultiUser extends Thread  
{
	private Socket client;

	public MultiUser( Socket c ) 
	{
		this.client = c;
	}

	public void run() 
	{
		try
		{
			BufferedReader in = new BufferedReader( new InputStreamReader( client.getInputStream() ) );
			PrintWriter out = new PrintWriter( client.getOutputStream() );

			while( true )
			{
				String str = in.readLine();
				System.out.println( str );
				out.println( "has reveive" +   str );
				out.flush();
				if( str.equals( "end" ))
					break;
			}
			client.close();

		}
		catch ( IOException ex )
		{

		}
		finally
		{

		}
	}

	public static void main( String[] args ) throws IOException
	{
		ServerSocket server = new ServerSocket( 5678 );
		while( true )
		{
			MultiUser mu = new MultiUser( server.accept() );
			mu.start();
		}
		exit( 0 );
	}
}