notifylistener.java

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

package com.ict.netcom2.net;

import java.io.*;
import java.net.*;
import com.ict.netcom2.kernel.*;

public class NotifyListener extends Thread{
	
	ProbeManager2 pm;
	
	public NotifyListener(ProbeManager2 pm) {
		this.pm = pm;
		// TODO true
		this.setDaemon(true);
	}
	
	public void run() {
		try {
			ServerSocket sskt = new ServerSocket(163);
			while (true) {
				Socket skt = sskt.accept();
				System.out.println("Accepted connect on port 163.");
				String ip = skt.getRemoteSocketAddress().toString();
				ip = ip.substring(1, ip.indexOf(":"));
				System.out.println(ip);
				new NotifyProcessor(skt,
						pm.getProbe(ip).getActiveDaemon()).start();
			}			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
	}

}