pasvtaskdaemon.java

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

package com.ict.netcom2.trash;

import java.util.*;
import com.ict.netcom2.task.*;
import com.ict.netcom2.net.*;
import com.ict.netcom2.message.*;

public class PasvTaskDaemon {

	private Timer timer;
	private TaskManager tm;
	private ProbeManager pm;

	public PasvTaskDaemon(TaskManager tm, ProbeManager pm, int period) {
		this.tm = tm;
		this.pm = pm;
		timer = new Timer();
		timer.schedule(new TimerTask() {
			public void run() {
				runTask();
			}
		}, 0, period*1000);
	}
	
	private void runTask() {
		
		System.out.println("runTask() start.");
		
		Vector<Communicator> probes = pm.getProbes();
		QueryTaskRep rep;
		TaskInfo taskInfo;
		Communicator comm;
		for (int i=0; i<probes.size(); i++) {
			comm = probes.elementAt(i);
			rep = comm.queryTask(2);
			
			// warning: taskNum is long.
			for (int j=0; j<rep.taskNum; j++) {
				taskInfo = rep.tasks.get(j);
				
				if (taskInfo.taskType == TaskType.PASSIVE_ETH) {
					pm.getResult(comm.ip, tm.getTask(taskInfo.taskId));
				} 
				else if(taskInfo.taskType == TaskType.PASSIVE_ATM) {
					//TODO
				}
			}
				 
		}
	}
	
	public static void main(String[] args) {
	}
}