Socket(2)--基于线程实现

代码例子：

package com.test;

import java.net.ServerSocket;
import java.net.Socket;
/**
 * 服务器端
 * @author yale
 *
 */
public class MainServer
{
	public static void main(String[] args) throws Exception
	{
		ServerSocket ss = new ServerSocket(5000);

		while (true)
		{
			Socket socket = ss.accept();
			// 启动读写2个线程
			new ServerInputThread(socket).start();

			new ServerOutputThread(socket).start();

		}

	}
}

package com.test;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
/**
 * 服务器端输入流线程
 * @author yale
 *
 */
public class ServerInputThread extends Thread
{
	private Socket socket;

	public ServerInputThread(Socket socket)
	{
		this.socket = socket;
	}

	@Override
	public void run()
	{
		try
		{
			InputStream in = socket.getInputStream();

			while (true)
			{
				byte[] buffer = new byte[1024];

				int length = 0;

				while (-1 != (length = in.read(buffer, 0, buffer.length)))
				{
					String str = new String(buffer, 0, length);
					System.out.println(str);
				}
			}

		}
		catch (IOException e)
		{
			e.printStackTrace();
		}

	}

}

package com.test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
/**
 * 服务器端输出流线程
 * @author yale
 *
 */
public class ServerOutputThread extends Thread
{
	private Socket socket;

	public ServerOutputThread(Socket socket)
	{
		this.socket = socket;
	}

	@Override
	public void run()
	{
		try
		{
			OutputStream os = socket.getOutputStream();

			while (true)
			{
				BufferedReader reader = new BufferedReader(
						new InputStreamReader(System.in));
				
				String line = reader.readLine();
				
				os.write(line.getBytes());
			}

		}
		catch (IOException e)
		{
			e.printStackTrace();
		}

	}
}

package com.test;

import java.net.Socket;

/**
 * 客户端
 * @author yele
 *
 */
public class MainClient
{
	public static void main(String[] args) throws Exception
	{
		Socket socket = new Socket("127.0.0.1",5000);
		//启动客户端读写线程
		new ClientInputThread(socket).start();
		
		new ClientOutputThread(socket).start();
		
	}

}

package com.test;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
/**
 * 客户端输入流线程
 * @author yale
 *
 */
public class ClientInputThread extends Thread
{
	private Socket socket;

	public ClientInputThread(Socket socket)
	{
		this.socket = socket;
	}

	@Override
	public void run()
	{
		try
		{
			InputStream in = socket.getInputStream();

			while (true)
			{
				byte[] buffer = new byte[1024];

				int length = 0;

				while (-1 != (length = in.read(buffer, 0, buffer.length)))
				{
					String str = new String(buffer, 0, length);
					System.out.println(str);
				}
			}

		}
		catch (IOException e)
		{
			e.printStackTrace();
		}

	}
}

package com.test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
/**
 * 客户端输出流线程
 * @author yale
 *
 */
public class ClientOutputThread extends Thread
{
	private Socket socket;

	public ClientOutputThread(Socket socket)
	{
		this.socket = socket;
	}

	@Override
	public void run()
	{
		try
		{
			OutputStream os = socket.getOutputStream();

			while (true)
			{
				BufferedReader reader = new BufferedReader(
						new InputStreamReader(System.in));
				
				String line = reader.readLine();
				
				os.write(line.getBytes());
			}

		}
		catch (IOException e)
		{
			e.printStackTrace();
		}

	}
}