tcpprocesser.java

ssd8 java socket编程实验的代码

import java.io.DataOutputStream;
import java.net.Socket;

public class TCPProcesser implements Runnable {
	private Socket connectionSocket;
	private byte[] message;

	public TCPProcesser(Socket connectionSocket) {
		this.connectionSocket = connectionSocket;
	}

	public void run() {
		try {
			
			RequestProcesser pro = new RequestProcesser(connectionSocket.getInputStream());
			DataOutputStream outToClient = new DataOutputStream(
					connectionSocket.getOutputStream());
			message = pro.proccess();
			System.out.println(message);
			outToClient.write(message);
			outToClient.flush();
			outToClient.close();
			connectionSocket.close();
			this.finalize();
		} catch (Exception e) {
			e.printStackTrace();
		} catch (Throwable e) {
			e.printStackTrace();
		}
	}
	

}