serverthread.java

最基础的网络聊天器TCP 有兴趣的朋友可以下载来

import java.io.*;
import java.net.Socket;

public class ServerThread extends Thread {
	// 绑定服务器
	private Server server;

	// 获得连接
	private Socket socket;

	// 构造函数
	public ServerThread(Server server, Socket socket) {
		// 保存参数
		this.server = server;
		this.socket = socket;
		// 运行本线程
		start();
	}

	public void run() {
		try {
			// 获得客户端输入流
			DataInputStream din = new DataInputStream(socket.getInputStream());

			while (true) {
				// 读取客户端信息
				String message = din.readUTF();
				// System.out.println("Sending "+message);
				// 发送信息给所有客户端
				server.sendToAll(message);
			}
		} catch (EOFException ie) {
			ie.printStackTrace();
		} catch (IOException ie) {
			ie.printStackTrace();
		} finally {
			// 当连接断开时在客户端列表中删除
			server.removeConnention(socket);
		}
	}
}