createpeergroup.java

jxta新建点组的示例程序

import net.jxta.discovery.DiscoveryEvent;
import net.jxta.discovery.DiscoveryListener;
import net.jxta.discovery.DiscoveryService;
import net.jxta.document.Advertisement;
import net.jxta.document.AdvertisementFactory;
import net.jxta.document.MimeMediaType;
import net.jxta.document.XMLDocument;
import net.jxta.exception.PeerGroupException;
import net.jxta.membership.*;
import net.jxta.id.IDFactory;
import net.jxta.impl.peergroup.StdPeerGroupParamAdv;
import net.jxta.peergroup.NetPeerGroupFactory;
import net.jxta.peergroup.PeerGroup;
import net.jxta.protocol.ModuleImplAdvertisement;
import net.jxta.protocol.DiscoveryResponseMsg;
import net.jxta.protocol.PeerAdvertisement;
import net.jxta.protocol.PeerGroupAdvertisement;
import net.jxta.peergroup.PeerGroupID;
import net.jxta.pipe.PipeID;
import net.jxta.platform.NetworkConfigurator;

import java.net.URI;
import java.net.URISyntaxException;

import java.io.IOException;
import java.util.Enumeration;

/**
 * Illustrates the use of the Discovery Service
 */
public class CreatePeerGroup{

	private PeerGroupAdvertisement padv;
	private PeerGroup myGroup;
	private DiscoveryService hdisco;
	private PeerGroupID peerGroupId;
	private String peerGroupID = "urn:jxta:uuid-6BAE3087D3874BB29872B0C51CCDA54802";


	public PeerGroup createPeerGroup(PeerGroup netPeerGroup) {
		try {
			peerGroupId = (PeerGroupID) IDFactory.fromURI(new URI(peerGroupID));
		} catch (URISyntaxException use) {
			use.printStackTrace();
		}
		try {
			// 创建一个包含有点组所有核心服务的模块实现通告implAdv
			ModuleImplAdvertisement implAdv = netPeerGroup
					.getAllPurposePeerGroupImplAdvertisement();
			// 创建一个点组
			myGroup = netPeerGroup.newGroup(peerGroupId,implAdv,"chaolu","hotct");
			hdisco = myGroup.getDiscoveryService();
			System.out.println("点组创建成功");
		} catch (Exception eee) {
			System.out.println("创建点组失败： " + eee.toString());
			return null;
		}

		try {
			// 发布点组通告
			padv = myGroup.getPeerGroupAdvertisement();
			System.out.println(padv);
			hdisco.remotePublish(padv);
			hdisco.publish(padv);			
			System.out.println("点组通告发布成功");
		} catch (Exception e) {
			System.out.println("点组通告发布出现错误");
			e.printStackTrace();
			return null;
		}
		return myGroup;
	}	
}