singleserver.java

JAVA

package chatSystem;
import java.io.*;
import java.net.*; 
import java.awt.*;

/**
 * 这个类是单聊的服务线程序,每个客户端都有一个这样的线程,用来监听该用户是否被请求单聊,如果被请求
 * 就启动一个单聊的线程,专门用来与请求的用户通信,利用的是套接字,所以比较稳定些,这个线程式就负责
 * 监听而已
 * @author 黄祖光
 *
 */

public class SingleServer extends Thread
{
    int port;
    ServerSocket socket=null;
    boolean stop=false;
    String me;
	
	public SingleServer(int port,String me)
	{
		this.port=port;
		this.me=me;
		try
		{
			socket=new ServerSocket(port);
			
		} 
		catch (IOException e) 
		{
			e.printStackTrace();
		}
	}
	/**
	 * 一直监听,一收到请求就立刻生成一个ChatFr单聊线程式,用户就可以与其单聊了
	 */
	public void run()
	{
		while(!stop)
		{
			Socket s=null;
			try 
			{
				s=socket.accept();
				ChatFr cf=new ChatFr(Color.yellow,s,me);
			}
			catch (IOException e)
			{
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 关闭socket退出监听
	 *
	 */
	public void stops()
	{
         try {
			socket.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}