tcpserverlistener.java

scoket 网络聊天室支持私聊

package chenmin.server;

import java.net.ServerSocket;
import java.net.Socket;
/**
 * 类名:用户服务监听类
 * 作用:监听用户请求
 * 文件名:TcpServerListener.java
 * 最后修改日期 20060917
 * @author Chenmin
 */

public class TcpServerListener implements Runnable
{
	private int port;
	public TcpServerListener(int _port)
	{
		port=_port;
	}
	public void run()
	{
		try
		{
			ServerSocket ss=new ServerSocket(port);
			System.out.println("TcpServerListener Started!");
			UserThreadManger utm=new UserThreadManger(10);
			Thread utmthd=new Thread(utm);
			utmthd.start();
			while(true)
			{
				Socket s=ss.accept();
				//System.out.println(s.getLocalPort()+s.getLocalAddress());
				System.out.println("Socket:"+s.getInetAddress()
						+":"+s.getPort()+" Connected!");
				utm.process(s);
				
			}
			//ss.close();
		}catch(Exception e){e.printStackTrace();}
	}
	

}