kernel.java

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

package com.ict.netcom2.trash;

import com.ict.netcom2.hardware.Card;
import com.ict.netcom2.task.*;
import com.ict.netcom2.result.*;

public class Kernel {
	public static void main(String[] args) {
		String ip = "10.21.2.30";
		HttpPerfTaskParam hptParam = new HttpPerfTaskParam(
				2, 80, 10, 2, "www.baidu.com");		
		PasvEthTaskParam petParam = new PasvEthTaskParam(
				new Card(1,0), new Card(1,0), 
				2, 20, "0:1:2:3:4:5");

		ProbeManager pm = new ProbeManager();
		
		//TODO one tm for one probe... 
		TaskManager tm = new TaskManager();
		
		ResultManager rm = new ResultManager();
		
		//ActiveTaskDaemon daemon = new ActiveTaskDaemon(tm, pm);
		
		//new NotifyListener(daemon).start();
		//new PasvTaskDaemon(tm, pm, 10);

		tm.createTask(10, false, hptParam);
		tm.createTask(0, false, petParam);
		
		pm.addProbe(ip);
		rm.buildResultSet(ip);
		
		pm.register(ip, 1, "10.21.2.48");
		pm.stopTask(ip, 1);
		pm.stopTask(ip, 2);
		
		//pm.addTask(ip, tm.getTask(2));
		pm.queryTask(ip);
		rm.storeResult(pm.getResult(ip, tm.getTask(2)));
		System.err.println(rm.getResult(ip, 2));
		
	}
}