acceptthread.java

聊天工具

package thread;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import server.login.ServerFrme;

/**
 * 循环接受客户端连接线程
 * @author 洪景泉
 *
 */

public class AcceptThread extends Thread {
	private ServerSocket ss;

	private ServerFrme qqServerFrm = null;

	public AcceptThread(ServerFrme qqServerFrm, ServerSocket ss) {
		this.qqServerFrm = qqServerFrm;
		this.ss = ss;

	}

	@Override
	public void run() {
		try {
			while (true) {
				// 接受客户端连接
				Socket s = ss.accept();
				// 创建读取线程
				ChatThread ct = new ChatThread(qqServerFrm, s);
				ct.start();
				sleep(20);

			}

		} catch (IOException e) {
			//System.out.println("服务器关闭");
			e.printStackTrace();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}