import org.globus.wsrf.impl.servicegroup.client.ServiceGroupRegistrationClient; //导入依赖的package包/类
protected AdvertisementClient() {
    this.client = new ServiceGroupRegistrationClient();
    this.client.setClientCallback(new Callback());
   	System.out.println("Installing JVM shutdown hook to unregister.");
    Runtime.getRuntime().addShutdownHook(new Thread() {
        @Override
        public void run() {
           	System.out.println("Running shutdown hook.");
            try {
                unregister();
            } catch (UnregistrationException e) {
           		System.err.println("Problem unregistering");
           		System.err.println(e);
            }
        }
    });
}
 

import org.globus.wsrf.impl.servicegroup.client.ServiceGroupRegistrationClient; //导入依赖的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();
    }
}