import org.globus.mds.servicegroup.client.ServiceGroupRegistrationParameters; //导入依赖的package包/类
/**
 * Parses the file representing ServiceGroupRegistrationParameters
 * 
 * @param registrationConfigFile
 * @throws InvalidConfigurationException
 */

public AdvertisementClient(File registrationConfigFile) throws InvalidConfigurationException {
    this();
    if (registrationConfigFile == null) {
        throw new InvalidConfigurationException("Configuration file cannot be null.");
    }
    if (!registrationConfigFile.isFile() || !registrationConfigFile.canRead()) {
        throw new InvalidConfigurationException("Configuration file must be a readable file.");
    }
    ServiceGroupRegistrationParameters readParams = null;
    try {
        readParams = ServiceGroupRegistrationClient.readParams(registrationConfigFile.getAbsolutePath());
    } catch (Exception e) {
        LOG.error("Problem parsing file:" + registrationConfigFile, e);
        throw new InvalidConfigurationException("Problem parsing configuration file:" + registrationConfigFile, e);
    }
    reinitialize(readParams);
}
 

import org.globus.mds.servicegroup.client.ServiceGroupRegistrationParameters; //导入依赖的package包/类
/**
 * Can be called to cancel any existing registration, and repurpose the
 * client for new registrations.
 * 
 * @param registrationConfig
 * @throws InvalidConfigurationException
 *             if the specified config is invalid (in this case the client
 *             remains in the old state). An invalid config is one which is
 *             null, or has a null servicegroup or registrant epr
 */
public void reinitialize(ServiceGroupRegistrationParameters registrationConfig)
    throws InvalidConfigurationException {
    if (registrationConfig == null) {
        throw new InvalidConfigurationException("Cannot use null parameters.");
    }
    if (registrationConfig.getRegistrantEPR() == null) {
        throw new InvalidConfigurationException("Must specify a non-null registrant.");
    }
    if (registrationConfig.getServiceGroupEPR() == null) {
        throw new InvalidConfigurationException("Must specify a non-null service group.");
    }

    try {
        unregister();
    } catch (UnregistrationException e) {
        // ignore this, as client is requesting a new registration, and
        // nothing they can do to correct problems with the existing one
        LOG.error("Problem unregistering existing entry", e);
    }
    this.sgParams = registrationConfig;
}
 

import org.globus.mds.servicegroup.client.ServiceGroupRegistrationParameters; //导入依赖的package包/类
/**
 * Returns a prinatable string representing the registration information
 * 
 * @param params
 * @return The registration parameters
 */
public static String printServiceGroupRegistrationParameters(ServiceGroupRegistrationParameters params) {
    if (params == null) {
        return "null";
    }
    return "resource (" + params.getRegistrantEPR() + ") registering every (" + params.getRefreshIntervalSecs()
        + ") seconds to Service Group (" + params.getServiceGroupEPR() + ")";

}
 

import org.globus.mds.servicegroup.client.ServiceGroupRegistrationParameters; //导入依赖的package包/类
public boolean setRegistrationStatus(ServiceGroupRegistrationParameters regParams, boolean wasSuccessful,
    boolean wasRenewalAttempt, Exception exception) {
    LOG.debug("Status Callback: " + AdvertisementClient.printServiceGroupRegistrationParameters(regParams)
        + " was " + (wasSuccessful ? "" : "not") + " successful.");
    if (exception != null) {
        LOG.error("Got exception from status callback:" + exception.getMessage(), exception);
    }
    return true;
}
 

import org.globus.mds.servicegroup.client.ServiceGroupRegistrationParameters; //导入依赖的package包/类
public static void main(String[] args) throws RemoteResourcePropertyRetrievalException, QueryInvalidException,
    ResourcePropertyRetrievalException, InvalidConfigurationException, InterruptedException, IOException {

    for (int i = 0; i < args.length; i++) {
        String sourceURL = args[i];

        DiscoveryClient sourceClient = new DiscoveryClient(sourceURL);
        EndpointReferenceType[] allServices = sourceClient.getAllServices(true);
        System.out.println("Found " + allServices.length + " services in Index Service:" + sourceURL);

        for (EndpointReferenceType epr : allServices) {
            System.out.println("Processing service: " + epr.getAddress());

            try {
                File registrationFile = new File("resources/registrationTemplate.xml");
                if (registrationFile.exists() && registrationFile.canRead()) {

                    ServiceGroupRegistrationParameters params = ServiceGroupRegistrationClient
                        .readParams(registrationFile.getAbsolutePath());

                    params.setRegistrantEPR(epr);

                    for (int j = 0; j < MULTIPLIER; j++) {
                        // System.out.println("Registering for the " + (j+1)
                        // + " time.");
                        AdvertisementClient registrationClient = new AdvertisementClient(params);
                        registrationClient.register();
                    }

                    Thread.sleep((long) (1000 + (1000 * (10 * Math.random()))));

                } else {
                    System.out.println("Unable to read registration file:" + registrationFile);
                }
            } catch (Exception e) {
                System.err.println("Exception when trying to register service (" + epr + "): " + e.getMessage());
            }

        }
    }

    System.out.println("Type 'exit' to quit, and unregister services:");
    BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    String line = br.readLine();
    while (line != null) {
        if (line.equals("exit")) {
            System.out.println("Exiting.");
            System.exit(0);
        }
        line = br.readLine();
    }
}