client.java

高质量Java程序设计 源代码

package net.betterjava.memory.leak;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.lang.Exception;

class Client extends Thread {
	private ObjectInputStream in;
	private Object data;
	private int counter = 0;

	Client(String IP, int port) {
		try {
			Socket socket = new Socket(IP, port);
			in = new ObjectInputStream(socket.getInputStream());
		} catch (IOException e) {
			err(e);
		}
	}

	public void run() {
		try {
			while (true) {
				data = in.readObject();
				System.out.println(String.valueOf(counter) + ":" + data);
				counter++;
			}
		} catch (IOException e) {
			err(e);
		} catch (ClassNotFoundException e) {
			err(e);
		}
	}

	private void err(Exception e) {
		e.printStackTrace(System.out);
		System.exit(1);
	}

	public static void main(String[] args) {
		Client client = new Client("127.0.0.1", 8888);
		client.start();
	}
}