createpeergroup.java

JXTA的 即时通信系统 JXTACHAT

import net.jxta.discovery.DiscoveryService;
import net.jxta.id.IDFactory;
import net.jxta.peergroup.PeerGroup;
import net.jxta.protocol.ModuleImplAdvertisement;
import net.jxta.protocol.PeerGroupAdvertisement;
import net.jxta.peergroup.PeerGroupID;

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


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

	private PeerGroupAdvertisement padv;
	private PeerGroup chatpg1;
	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();
			// 创建一个点组
			chatpg1 = netPeerGroup.newGroup(peerGroupId,implAdv,"chatpg1","this is a chat peergroup");
			chatpg1.init(netPeerGroup, peerGroupId, implAdv);
			hdisco = chatpg1.getDiscoveryService();
			System.out.println("点组创建成功");
		} catch (Exception eee) {
			System.out.println("创建点组失败： " + eee.toString());
			return null;
		}

		try {
			// 发布点组通告
			padv = chatpg1.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 chatpg1;
	}	
}