So erstellen Sie die Registrierungs- und Deregistrierungsmeldungen

Nachdem Sie die Helper-Klassen, die die XML-Meldungen generieren, erstellt haben, können Sie die Implementierung der createRegistrationString-Methode schreiben. Diese Methode wird von der registerCallbacks-Methode aufgerufen, die unter So registrieren und deregistrieren Sie Rückrufe beschrieben wird.

createRegistrationString erstellt ein CallbackReg-Objekt und richtet dessen Registrierungstyp und Port ein. Anschließend konstruiert createRegistrationString unter Verwendung der createAllEvent-, createMembershipEvent-, createRgEvent- und createREvent-Helper-Methoden verschiedene Ereignisse. Jedes Ereignis wird diesem Objekt nach Erstellung des CallbackReg-Objekts hinzugefügt. Zuletzt ruft createRegistrationString die convertToXml-Methode des CallbackReg-Objekts auf, um die XML-Meldung im String-Format abzurufen.

Beachten Sie, dass die regs-Mitgliedsvariable die Befehlszeilenargumente speichert, die ein Benutzer der Anwendung liefert. Das fünfte und alle folgenden Argumente geben die Ereignisse an, für die eine Anwendung registriert werden soll. Das vierte Argument gibt den Registrierungstyp an; es wird in diesem Beispiel jedoch übergangen. Der vollständige Code in Anhang G, CrnpClient.java-Anwendung zeigt, wie dieses vierte Argument verwendet wird.

Schritte

1. Erstellen Sie den Java-Code, der die vorstehende Logik implementiert.

   private String createRegistrationString() throws Exception
   {
           CallbackReg cbReg = new CallbackReg();
           cbReg.setPort("" + localPort);
   
           cbReg.setRegType(CallbackReg.ADD_CLIENT);
   
           // add the events
           for (int i = 4; i < regs.length; i++) {
                   if (regs[i].equals("M")) {
                           cbReg.addRegEvent(createMembershipEvent());
                   } else if (regs[i].equals("A")) {
                           cbReg.addRegEvent(createAllEvent());
                   } else if (regs[i].substring(0,2).equals("RG")) {
                           cbReg.addRegEvent(createRgEvent(regs[i].substring(3)));
                   } else if (regs[i].substring(0,1).equals("R")) {
                           cbReg.addRegEvent(createREvent(regs[i].substring(2))); 
                   }
           }
   
           String xmlStr = cbReg.convertToXml();
           return (xmlStr);
   }
   
   private Event createAllEvent()
   {
           Event allEvent = new Event();
           allEvent.setClass("EC_Cluster");
           return (allEvent);
   }
   
   private Event createMembershipEvent()
   {
           Event membershipEvent = new Event();
           membershipEvent.setClass("EC_Cluster");
           membershipEvent.setSubclass("ESC_cluster_membership");
           return (membershipEvent);
   }
   
   private Event createRgEvent(String rgname)
   {
           Event rgStateEvent = new Event();
           rgStateEvent.setClass("EC_Cluster");
           rgStateEvent.setSubclass("ESC_cluster_rg_state");
   
           NVPair rgNvpair = new NVPair();
           rgNvpair.setName("rg_name");
           rgNvpair.setValue(rgname);
           rgStateEvent.addNvpair(rgNvpair);
   
           return (rgStateEvent);
   }
   
   private Event createREvent(String rname)
   {
           Event rStateEvent = new Event();
           rStateEvent.setClass("EC_Cluster");
           rStateEvent.setSubclass("ESC_cluster_r_state");
   
           NVPair rNvpair = new NVPair();
           rNvpair.setName("r_name");
           rNvpair.setValue(rname);
           rStateEvent.addNvpair(rNvpair);
   
           return (rStateEvent);
   }

2. Erstellen Sie die Deregistrierungs-Zeichenkette.

   Das Erstellen der Deregistrierungszeichenkette ist einfacher als das Erstellen der Registrierungszeichenkette, da Sie keine Ereignisse zu berücksichtigen brauchen.

   private String createUnregistrationString() throws Exception
   {
           CallbackReg cbReg = new CallbackReg();
           cbReg.setPort("" + localPort);
           cbReg.setRegType(CallbackReg.REMOVE_CLIENT);
           String xmlStr = cbReg.convertToXml();
           return (xmlStr);
   }