server.java

flex实现的前台

/**
 * 
 */
package cn.humanmonth.chat.server;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import cn.humanmonth.chat.server.domain.User;

/**
 * @author Piterlin
 * 
 * 服务器，用于监听口
 */
public class Server extends Thread {
	private Log log = LogFactory.getLog(this.getClass());
	private ServerSocket server;
	/**
	 * 代表在线的客户
	 */
	private List users = new ArrayList();

	/**
	 * 用于指定监听的端口
	 */
	public void init(int port) throws IOException {
		server = new ServerSocket(port);
		log.info("server open，port is " + server.getLocalPort());
		this.start();
	}

	/**
	 * 随机监听端口
	 */
	public int init() throws IOException {
		server = new ServerSocket(0);
		this.start();
		log.info("server open，port is " + server.getLocalPort());
		return server.getLocalPort();
	}

	public void run() {
		while (true) {
			try {
				Socket client = server.accept();
				log.info("client access:" + client.getRemoteSocketAddress());
				User user = new User(client);
				users.add(user);
				new Processor(users, user).start();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void main(String[] args) throws IOException {
		Server server = new Server();
		server.init();
	}
}