server.java

聊天程序

package com.javahomework.Server;

import java.net.*;
import java.io.*;
import java.util.*;
import com.javahomework.Server.Log.*;

public class Server implements Runnable {
	private int port;
//用ServerSocket的实例ss来接收线程
	private ServerSocket ss = null;
//映射
	static Map<String, ServThread> map;
	static List<ServThread> threadList;
	
	//正确日志
	static Loger normalLoger = null;
//错误日志
	static Loger errorLoger = null;
	static {
		//
		threadList = new ArrayList<ServThread>(10);
		map = new HashMap<String, ServThread>();
		normalLoger = new NormalLoger();
		normalLoger.open();
		errorLoger = new ErrorLoger();
		errorLoger.open();
	}

	public Server(int port) {
//服务器端监听
		this.port = port;
		Thread _listenThread = new Thread(this);
		_listenThread.start();
	}

	public void run() {
		try {
			ss = new ServerSocket(port);
			//死循环保证服务器端不停接收下一客户端连接信息
			while (true) {
				Socket s = ss.accept();
				System.out.println(s + " Connected");
				ServThread servThread = new ServThread(s);
			}

		} catch (IOException e) {
			e.printStackTrace();
		}

	}

}