阻塞java线程通讯例子

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

	ServerSocket serverSocket;

	private void initServer() throws IOException {
		serverSocket = new ServerSocket();
		serverSocket.bind(new InetSocketAddress("localhost", 8000));
		System.out.println("服务器已启动......");
	}

	private void listenSocket() throws IOException {
		while (true) {
			Socket client = serverSocket.accept();
			System.out.println("和客户端" + client.toString() + "建立连接......");
			new ClientThread(client);
		}
	}

	public static void main(String[] args) throws IOException {
		Server server = new Server();
		server.initServer();
		server.listenSocket();
	}

}

class ClientThread extends Thread {

	private static final String BYE = "bye";

	private Socket socket;

	private DataInputStream inputStream;

	private DataOutputStream outputStream;

	BufferedReader sysin = new BufferedReader(new InputStreamReader(System.in));

	Socket client;

	private boolean openFlag = true;

	public ClientThread(Socket client) {
		super();
		this.client = client;
		process();
	}

	public void process() {
		try {
			this.inputStream = new DataInputStream(client.getInputStream());
			this.outputStream = new DataOutputStream(client.getOutputStream());

			// 监听System.in的输入，把输入转输入给客户
			new Thread() {
				public void run() {
					while (openFlag) {
						try {
							//sysin.ready()这个很重要，先判断是否有值可读，有则读，没有这轮训
							//如果一开始就用sysin.readLine那么会阻塞，导致程序如果出现异常，而不能close
							if (sysin.ready()) {
								String msg = sysin.readLine();
								if (msg.toLowerCase().equals(BYE)) {
									shutdown();
									break;
								}
								outputStream.writeUTF(msg);
								outputStream.flush();
							}
						} catch (IOException e) {
							shutdown();
							break;
						}
					}
				}
			}.start();

			while (openFlag) {
				try {
					String msg = inputStream.readUTF();
					System.out.println("客户端说： " + msg);
				} catch (IOException e) {
					shutdown();
					break;
				}
			}

		} catch (IOException e) {
			System.out.println("连接失败");
			shutdown();
		}
	}

	public void shutdown() {
		System.out.println("关闭Clent连接");
		try {
			if (socket != null) {
				socket.close();
			}
			if (inputStream != null) {
				inputStream.close();
			}
			if (outputStream != null) {
				outputStream.close();
			}
			if (sysin != null) {
				sysin.close();
			}
			System.out.println("关闭Clent连接完成");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}

 

 

 

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.net.Socket;

public class Client {

	private static final String HOST = "localhost";

	private static final int PORT = 8000;

	private static final String BYE = "bye";

	private Socket socket = new Socket();

	private DataInputStream inputStream;

	private DataOutputStream outputStream;

	private boolean openFlag = true;

	private BufferedReader sysin = new BufferedReader(new InputStreamReader(
			System.in));

	public static void main(String[] args) {
		Client client = new Client();
		client.doProcess();
	}

	public void doProcess() {
		try {
			socket.connect(new InetSocketAddress(HOST, PORT));
			// socket.setSoTimeout(1000);
			System.out.println("已经和服务器端连接.....");
			this.inputStream = new DataInputStream(socket.getInputStream());
			this.outputStream = new DataOutputStream(socket.getOutputStream());

			// 监听System.in的输入，把输入转输入给客户
			new Thread() {
				public void run() {
					while (openFlag) {
						try {
							// sysin.ready()这个很重要，先判断是否有值可读，有则读，没有这轮训
							// 如果一开始就用sysin.readLine那么会阻塞，导致程序如果出现异常，而不能close
							if (sysin.ready()) {
								String msg = sysin.readLine();
								if (msg.toLowerCase().equals(BYE)) {
									shutdown();
									break;
								}
								outputStream.writeUTF(msg);
								outputStream.flush();
							}

						} catch (IOException e) {
							shutdown();
							break;
						}
					}
				}
			}.start();

			while (openFlag) {
				try {
					String msg = inputStream.readUTF();
					System.out.println("服务端说： " + msg);
				} catch (IOException e) {
					shutdown();
					break;
				}
			}

		} catch (IOException e) {
			System.out.println("连接失败");
			e.printStackTrace();
			shutdown();
		}
		System.out.println("over");
	}

	public void shutdown() {
		System.out.println("开始关闭连接");

		openFlag = false;
		try {
			if (socket != null) {
				socket.close();
			}
			if (inputStream != null) {
				inputStream.close();
			}
			if (outputStream != null) {
				outputStream.close();
			}
			if (sysin != null) {
				sysin.close();
			}
			System.out.println("关闭完成");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}