如何使用JXTA技术建立P2P网络

 public static void main(String[] args) {
 RestoPeer myapp = new RestoPeer();   //此处实例化一个对等体对象。
 myapp.startJxta();                                  //此处启动JXTA方法，用来加入组，获得服务等等。
 System.exit(0);                                      //功能至完成，退出系统。
 }
public void startJxta() {
 try {
         加入默认对等组NetPeerGroup
 netpg = new NetPeerGroupFactory().getInterface();
 } catch (PeerGroupException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}
  ......
 }

 // 加入拍卖组
 private void joinRestoNet() {
 int count = 3; // 试图发现的最高循环次数
 System.out.println(" 试图发现组名为 RestoNet 对等组");

 从NetPeerGroup获得发现服务
 DiscoveryService hdisco = netpg.getDiscoveryService();

 Enumeration ae = null; // 记录发现的广告。

 // 循环直到我们发现RestoNet对等组或是直到我们达到了试图预期发现的次数。
 while (count-- > 0) {
 try {
 // 第一次搜索对等体的本地缓存来查找RestoNet对等组通告。
// 通过NetPeerGroup组提供的发现服务发现"Name"属性为"RestoNet"的对等组
 ae = hdisco.getLocalAdvertisements(DiscoveryService.GROUP,"Name", "RestoNet");

// 如果发现RestoNet对等组通告，该方法完成，退出循环。
 if ((ae != null) && ae.hasMoreElements()) {
       break;
     }

// 如果我们没有在本地找到它，便发送发现远程请求。
 // 参数依次为要查找的对等体ID，为空时不以此为发现条件；发现的通告类型，取值还有PEER,和ADV；
 // 要发现的通告属性名称；属性取值；需获取的最大通告数量；发现监听器
  hdisco.getRemoteAdvertisements(null, DiscoveryService.GROUP,"Name", "RestoNet", 1, null);

 // 线程暂停一下等待对等体?该发现请求。
  try {
         Thread.sleep(timeout);
         } catch (InterruptedException e) {
           // TODO Auto-generated catch block
               e.printStackTrace();
               }
          } catch (IOException e) {
            // TODO Auto-generated catch block
               e.printStackTrace();
               }
       }

 /*-------------------------------------------
 *     以上为循环发现目标组过程,以下为加入过程
 * ----------------------------------------*/
                
 // 创建一个对等组通告引用
PeerGroupAdvertisement restoNetAdv = null;

 // 检查我们是否找到RestoNet通告。如果没有找到，表示我们可能是第一个试图加入该组的对等体，
//或是其他知道RestoNet组的对等体成员已经关闭或不可到达
// 万一出现这种情况，我们必须创建一个RestoNet对等组。
 if (ae == null || !ae.hasMoreElements()) {

// 如果该组不在，给出提示信息，创建该组
 System.out.println("Could not find the RestoNext peergroup;createing me");
try {
         // 创建一个新的对等组RestoNet,全能对等组
         // 通过NetPeerGroup获得一个一般对等组的通告。
         ModuleImplAdvertisement implAdv = netpg.getAllPurposePeerGroupImplAdvertisement();

        // 通过NetPeerGroup创建一个新的对等组，JXTA会自行发布该对等组通告，
        //参数依次为对等组ID，通告，组名，描述
        restoNet = netpg.newGroup(mkGroupID(), implAdv, "RestoNet","RestoNet,Inc.");

        // 获得一个对等组通告
        restoNetAdv = netpg.getPeerGroupAdvertisement();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
} else {
           // RestoNet通告在缓存内找到意味着我们可以加入这个存在的组。
           // 在集合中提取一个对等组通告元素
           restoNetAdv = (PeerGroupAdvertisement) ae.nextElement();
try {
          // 加入该对等组，由于该通告已经发布，JXTA不会再行发布。
          restoNet = netpg.newGroup(restoNetAdv);
          System.out.println("找到RestoNet对等组，并加入存在的该组");
       } catch (PeerGroupException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
       }
}

   // 获得RestoNet提供的发现服务和管道服务
   disco = restoNet.getDiscoveryService();
    pipes = restoNet.getPipeService();

    System.out.println("RestoNet Restaurant_(" + brand + ") is on-line");
    return;
}