clientthread.java

一个简单的java聊天程序

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

public class ClientThread extends Thread {

	Socket clientSocket;

	DataInputStream in = null;
	DataOutputStream out = null;

	ServerThread serverThread;
	String str;
	public static int ConnectNumber = 0;

	public ClientThread(Socket socket, ServerThread serverThread) {
		clientSocket = socket;
		this.serverThread = serverThread;
		try {
			in = new DataInputStream(clientSocket.getInputStream());
			out = new DataOutputStream(clientSocket.getOutputStream());

		} catch (IOException e2) {
			System.out.println("发生异常" + e2);
			System.out.println("建立i/0通道失败!");
			System.exit(3);// ??
		}
	}

	public void run()
	{
		while(true)
		{
			try{
				String message = in.readUTF();
				synchronized (serverThread.messages) {
					if(message != null)
					{
						serverThread.messages.addElement(message);
						Server.jTextArea1.append(message+"\n");
					}
					
				}
			}catch(IOException e3)
			{
				break;
			}
		}
	}
}