server.java

利用Java Socket写的一段通讯协议

package com.ict.netcom2.net;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import com.ict.netcom2.kernel.*;

public class Server extends Thread{
	
	private Kernel2 core;
	
	public Server() {
		core = new Kernel2();
		new NotifyListener(core.pm).start();
	}
	
	public void run() {
		try {
			ServerSocket sskt = new ServerSocket(8899);
			while (true) {
				System.out.println("Listening on port 8899.");
				Socket skt = sskt.accept();
				System.out.println("Accepted connect: "+skt.getRemoteSocketAddress());
				new ServerThread(skt, core).start();
			}			
		} catch (IOException e) {
			e.printStackTrace();
		}
		
	}
	
	public static void main(String[] args) { 
		new Server().start();
	}

}