resultmanager.java

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

package com.ict.netcom2.result;

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

public class ResultManager {

	Vector<ResultSet> resultSets;
	
	public ResultManager() {
		resultSets = new Vector<ResultSet>();		
	}
	
	public void buildResultSet(String ip) {
		ResultSet set = new ResultSet(ip);
		resultSets.add(set);
	}
	
	public MeasureResult getResult(String ip, int taskId) {
		try {
			return getByProbeIp(ip).getResult(taskId);
		} catch (NullPointerException e) {
			return null;
		}
	}
	
	public void storeResult(GetResultAck ack) {
		if (ack.status != 0) {
			System.out.println(ack.reportStatus());
			return;
		}		
		try {
			getByProbeIp(ack.result.probeIp).storeResult(ack.result);
		} catch (NullPointerException e) {}
		
	}
	
	private ResultSet getByProbeIp(String ip) {
		for (int i=0; i<resultSets.size(); i++) {
			ResultSet set = resultSets.elementAt(i); 
			if (set.probeIp.equalsIgnoreCase(ip)) {
				return set; 
			}
		}
		return null;
	}
}