listenthread.java

一个用于WEB方式的文本交谈.即N对N方式交谈

package cn.com.sihitech.cc.chat;

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

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class listenThread extends Thread {
    private Server server = null;
    private boolean listening = true;
    private ServerSocket serverSocket = null;
    public static int port = 5555;
    public listenThread(Server sr) {
        System.out.println("***new listenThread***");
        this.server = sr;
    }

    public void run() {
        System.out.println("listening............");
        try {
            serverSocket = new ServerSocket(port); //监听端口
        } catch (IOException ex) {
            System.err.println("listen fail：" + port + ":" + ex);
        }
        System.out.println("listen：" + port);
        while (listening) {
            try {
                server.addClient(serverSocket.accept()); //建立连接
            } catch (IOException ex) {
                System.err.println("listen fail：" + ex);
            }
        }
        try {
            serverSocket.close();
        } catch (IOException ex) {
            System.err.println("serverSocket close fail：" + port + ":" + ex);
        }
    }
}