adaptersocketserver.java

实现简单的群聊功能

package cn.edu.buaa.scse.liyi.network.test;

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

public class AdapterSocketServer
{
	private static final int RECEIVE_PORT=9090;	// 该服务器的端口号
	private static AdapterSocketServer _adapterSocketServer=null;
	
	private AdapterSocketServer()
	{
		AdapterSocketServer.startAdapterSocketServer();
	}
	
	public static AdapterSocketServer instance()
	{
		if(_adapterSocketServer==null)
			_adapterSocketServer=new AdapterSocketServer();
		return _adapterSocketServer;
	}
	
	// receiveServer的构造器
	private static void startAdapterSocketServer()
	{
		ServerSocket rServer=null;		// ServerSocket的实例
		Socket request=null;			// 用户请求的套接字
		Thread receiveThread=null;
		try
		{
			rServer=new ServerSocket(RECEIVE_PORT);		// 初始化ServerSocket
			System.out.println("The AdapterSocketServer is ready!");
			System.out.println("ip:"+InetAddress.getLocalHost().getHostAddress());
			// System.out.println("ip:"+rServer.getLocalSocketAddress().toString());
			System.out.println("Port: "+RECEIVE_PORT);
			while(true)
			{ // 等待用户请求
				request=rServer.accept();					// 接收客户机连接请求
				receiveThread=new ServerThread(request);	// 生成serverThread的实例
				receiveThread.start();						// 启动serverThread线程
			}
		}
		catch(IOException e)
		{
			System.out.println(e.getMessage());
		}
	}
	
	public static void main(String args[])
	{
		AdapterSocketServer.instance();
	}
}