discoveryclient.java

JXTA发布公告的一个小程序

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package jxta5;

import net.jxta.discovery.DiscoveryEvent;
import net.jxta.discovery.DiscoveryListener;
import net.jxta.discovery.DiscoveryService;
import net.jxta.document.Advertisement;
import net.jxta.peergroup.PeerGroup;
import net.jxta.protocol.DiscoveryResponseMsg;

import net.jxta.platform.NetworkManager;

import java.io.File;
import java.util.Enumeration;

/**
 *
 * @author m1m07a08
 */
public class DiscoveryClient implements DiscoveryListener{
      
      private transient NetworkManager manager;
      private transient DiscoveryService discovery;
      
      public DiscoveryClient(){
          try{
              manager=new NetworkManager(NetworkManager.ConfigMode.EDGE,"DiscoveryClient",new File(new File(".cache"),"DiscoveryClient").toURI());
             manager.startNetwork();
             
          }catch(Exception e){
              e.printStackTrace();
              System.exit(-1);
              
          }
          PeerGroup netPeerGroup=manager.getNetPeerGroup();
          discovery=netPeerGroup.getDiscoveryService();
          
      }
      public static void main(String args[]){
          DiscoveryClient discoveryClient=new DiscoveryClient();
          discoveryClient.start();
          
      }
public void start(){
     long waittime=60*1000L;
     try{
         discovery.addDiscoveryListener(this);
         discovery.getRemoteAdvertisements(null, DiscoveryService.ADV, null, null, 1,null);
         while(true){
             try{
                  System.out.println("Sleeping for:"+waittime);
                  Thread.sleep(waittime);
             }catch(Exception e){
                 
             }
                 System.out.println("Sending a Discovery Message");
                 discovery.getRemoteAdvertisements(null, DiscoveryService.ADV, "NAME", "Discovery tutorial", 1,null);
                 
             }
     }catch(Exception e){
             e.printStackTrace();
         }
     }
       public void discoveryEvent(DiscoveryEvent ev){
             DiscoveryResponseMsg res=ev.getResponse();
             System.out.println("[Got aDiscover Reaponse["+res.getResponseCount()+"elements] from peer:"+ev.getSource()+"]");
             Advertisement adv;
             Enumeration en=res.getAdvertisements();
             if(en!=null){
                 while(en.hasMoreElements()){
                     adv=(Advertisement)en.nextElement();
                     System.out.println(adv);
                     
                 }
             }
       }  
   public void stop(){
 manager.stopNetwork();
   }
    
}