c0e24da7f259001d1122e569cdf235e2

来自「java的团队合作代码」· 代码 · 共 56 行

package com.briup.impl.net;

import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Properties;

import com.briup.Config;
import com.briup.Log;
import com.briup.NetServer;
import com.briup.exception.NetServerException;

public class NetServerImpl implements NetServer {
	private int port;
	private int backlog;
	private Config config;
	private int count;
	public NetServerImpl(Properties pro){
		port =Integer.parseInt(pro.getProperty("port"));
		backlog = Integer.parseInt(pro.getProperty("backlog"));
	}

	public void setConfig(Config config) throws NetServerException {
	//当传进一个cofig对象是将其作为一个实例变量保存下来
		this.config = config;
	}

	public void start() throws NetServerException {
		ServerSocket ss =null;
		Socket s =null;
		Log log = null;
		ObjectInputStream ois = null;
		try {
				log = config.getLog();
				ss = new ServerSocket(port,backlog);
			 log.writeInfo("Gather server is listening on port: " + port); //日志监听已起动
			 while(true){
				
				 log.writeInfo("Gather server is listening on thread");
			 }
			/*
			while(true){
				 s=ss.accept();
				 
				 NetServerThread2 thread1 = new  NetServerThread2(s,config);
				 Thread thread = new Thread(thread1);
			 } */
				
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			throw new NetServerException(e);
		}
	}
}