JXSEv2.6程序员指南：Java标准版实现详解

需积分: 10 168 浏览量更新于2024-07-29 收藏 921KB PDF 举报

"JXSE_ProgGuide_v2.6 是JXTA（Java eXtensible Peer-to-Peer Protocol）技术在2.6版本的编程指南，由Jérôme Verstrynge撰写，发布于2010年7月。该指南详细介绍了如何使用JXSE实现P2P（对等网络）应用。" **JXTA技术简介** JXTA（Java eXtensible Peer-to-Peer Protocol）是一个开放的P2P平台，由Sun Microsystems开发。它提供了一组基于XML的协议，用于让设备之间进行通信，共享资源和服务。JXTA的核心概念包括对等节点、广告（Advertises，用于发布服务或资源）、发现、管道（Pipes，数据传输通道）和身份（Identities，用于节点认证）。 **JXSE (Java Standard Edition) 实现** JXSE是JXTA技术在Java环境中的实现，它允许开发者利用Java语言构建P2P应用程序。JXSE提供了丰富的API，包括网络发现、设备身份管理、服务发布和发现、安全通信等功能。JXSE v2.6作为新版本，相比之前的版本可能包含了更多的改进、性能优化以及新的特性和功能。 **JXSE v2.6程序员指南内容** 虽然没有提供详细的章节内容，但通常此类编程指南会涵盖以下几个方面： 1. **介绍**：解释JXSE的基本概念，以及JXSE v2.6的主要改进和更新。 2. **安装与设置**：指导用户如何配置和安装JXSE环境。 3. **API概述**：详细列出JXSE提供的类库和接口，解释其用途和用法。 4. **发现机制**：描述如何在P2P网络中发现其他节点和服务。 5. **服务发布与发现**：讲解如何发布自己的服务并查找网络上的可用服务。 6. **管道通信**：介绍如何创建和管理用于数据交换的管道。 7. **安全性**：讨论如何确保P2P通信的安全性，包括身份验证和加密。 8. **示例代码**：提供实际的代码示例，帮助开发者理解如何使用JXSE API。 9. **故障排查**：给出常见问题的解决方案和调试技巧。 10. **附录**：可能包含参考文档、API索引和其他补充信息。 **商标信息** 文档中提到的Sun Microsystems、Java、SPARC、Oracle、Berkeley DB和UNIX都是各自公司的注册商标，这表明JXTA和JXSE在技术上与这些公司有紧密的关联或依赖。 JXSE v2.6程序员指南是开发基于JXTA的P2P应用的重要参考资料，涵盖了从基础概念到高级特性的全方位指导。通过深入学习和实践，开发者可以掌握构建分布式、自组织的P2P系统的关键技能。

Logger.getLogger(EdgePeerRdvService.class.getName()).setLevel(Level.CONFIG);

// Removing any existing configuration?

NetworkManager.RecursiveDelete(ConfigurationFile_EDGE_A);

// Creation of the network manager

final NetworkManager MyNetworkManager = new NetworkManager(

NetworkManager.ConfigMode.EDGE,

Name_EDGE_A, ConfigurationFile_EDGE_A.toURI());

// Retrieving the network configurator

NetworkConfigurator MyNetworkConfigurator = MyNetworkManager.getConfigurator();

// Setting Configuration

MyNetworkConfigurator.setTcpPort(TcpPort_EDGE_A);

MyNetworkConfigurator.setTcpEnabled(true);

MyNetworkConfigurator.setTcpIncoming(true);

MyNetworkConfigurator.setTcpOutgoing(true);

MyNetworkConfigurator.setUseMulticast(true);

// Setting the Peer ID

MyNetworkConfigurator.setPeerID(PID_EDGE_A);

// Adding RDV a as a seed

MyNetworkConfigurator.clearRendezvousSeeds();

String TheSeed = "tcp://" + InetAddress.getLocalHost().getHostAddress() + ":"

+ RENDEZVOUS_A.TcpPort_RDV_A;

URI LocalRendezVousSeedURI = URI.create(TheSeed);

MyNetworkConfigurator.addSeedRendezvous(LocalRendezVousSeedURI);

TheSeed = "tcp://" + InetAddress.getLocalHost().getHostAddress() + ":"

+ RENDEZVOUS_B.TcpPort_RDV_B;

LocalRendezVousSeedURI = URI.create(TheSeed);

MyNetworkConfigurator.addSeedRendezvous(LocalRendezVousSeedURI);

// Starting the JXTA network

PeerGroup NetPeerGroup = MyNetworkManager.startNetwork();

// Starting the connectivity monitor

new ConnectivityMonitor(NetPeerGroup);

// Disabling any rendezvous autostart

NetPeerGroup.getRendezVousService().setAutoStart(false);

// Retrieving a module implementation advertisement

ModuleImplAdvertisement TheModuleImplementationAdvertisement = null;

try {

TheModuleImplementationAdvertisement =

NetPeerGroup.getAllPurposePeerGroupImplAdvertisement();

} catch (Exception ex) {

System.err.println(ex.toString());

}

// Creating a child group

PeerGroup ChildPeerGroup = NetPeerGroup.newGroup(

ChildPeerGroupID,

TheModuleImplementationAdvertisement,

ChildPeerGroupName,

"For test purposes..."

);

JXSE 2.6 Programmer's Guide 15

// Creation of the network manager

final NetworkManager MyNetworkManager = new NetworkManager(

NetworkManager.ConfigMode.RENDEZVOUS,

Name_RDV_A, ConfigurationFile_RDV_A.toURI());

// Retrieving the network configurator

NetworkConfigurator MyNetworkConfigurator = MyNetworkManager.getConfigurator();

// Setting Configuration

MyNetworkConfigurator.setTcpPort(TcpPort_RDV_A);

MyNetworkConfigurator.setTcpEnabled(true);

MyNetworkConfigurator.setTcpIncoming(true);

MyNetworkConfigurator.setTcpOutgoing(true);

MyNetworkConfigurator.setUseMulticast(true);

// Setting the Peer ID

MyNetworkConfigurator.setPeerID(PID_RDV_A);

// Starting the JXTA network

PeerGroup NetPeerGroup = MyNetworkManager.startNetwork();

// Starting the connectivity monitor

new ConnectivityMonitor(NetPeerGroup);

// Retrieving a module implementation advertisement

ModuleImplAdvertisement TheModuleImplementationAdvertisement = null;

try {

TheModuleImplementationAdvertisement =

NetPeerGroup.getAllPurposePeerGroupImplAdvertisement();

} catch (Exception ex) {

System.err.println(ex.toString());

}

// Creating a child group

PeerGroup ChildPeerGroup = NetPeerGroup.newGroup(

ChildPeerGroupID,

TheModuleImplementationAdvertisement,

ChildPeerGroupName,

"For test purposes..."

);

if (Module.START_OK != ChildPeerGroup.startApp(new String[0]))

System.err.println("Cannot start child peergroup");

// Enable rendezvous

ChildPeerGroup.getRendezVousService().startRendezVous();

new ConnectivityMonitor(ChildPeerGroup);

// Stopping the network asynchronously

ConnectivityMonitor.TheExecutor.schedule(

new DelayedJxtaNetworkStopper(

MyNetworkManager,

"Click to stop " + Name_RDV_A,

"Stop"),

TimeUnit.SECONDS);

} catch (IOException Ex) {

System.err.println(Ex.toString());

JXSE 2.6 Programmer's Guide 17

}

public void contentTransferStateUpdated(ContentTransferEvent event) {

System.out.println("Transfer state: " + event.getTransferState());

}

public void contentTransferProgress(ContentTransferEvent event) {

Long bytesReceived = event.getBytesReceived();

Long bytesTotal = event.getBytesTotal();

System.out.println("Transfer progress: "

+ bytesReceived + " / " + bytesTotal);

}

};

/**

* Content transfer aggregator listener used to detect transitions

* between multiple ContentProviders.

private ContentTransferAggregatorListener aggListener =

new ContentTransferAggregatorListener() {

public void selectedContentTransfer(ContentTransferAggregatorEvent event) {

System.out.println("Selected ContentTransfer: "

+ event.getDelegateContentTransfer());

}

public void updatedContentTransferList(ContentTransferAggregatorEvent event) {

ContentTransferAggregator aggregator =

event.getContentTransferAggregator();

System.out.println("ContentTransfer list updated:");

for (ContentTransfer xfer : aggregator.getContentTransferList()) {

System.out.println(" " + xfer);

}

};

/**

* Constructor.

* @param id ContentID of the Content we are going to attempt to retrieve.

* @param waitForRendezvous true to wait for rdv connection, false otherwise

public ContentClient(ContentID id, boolean waitForRendezvous) {

contentID = id;

// Start the JXTA network

try {

manager = new NetworkManager(

NetworkManager.ConfigMode.ADHOC, "ContentClient",

new File(new File(".cache"), "ContentClient").toURI());

manager.startNetwork();

} catch (Exception e) {

e.printStackTrace();

System.exit(-1);

}

netPeerGroup = manager.getNetPeerGroup();

if (waitForRendezvous) {

manager.waitForRendezvousConnection(0);

}

/**

* Interact with the server.

JXSE 2.6 Programmer's Guide 19

剩余91页未读，继续阅读

weiqiang200456

粉丝: 1
资源: 4

JXSEv2.6程序员指南：Java标准版实现详解

qualcomm_mde.win.2.6_installer_2.6.1.26.zip

volatility_2.6_win64system_standalone.rar

osTube_2.6_osTube_2.6_community_edt.tar.gz

vis_h323_dll_2.6r.zip_723_g.723.1_vis_h323_dll_2.6r_网络视频会议_视频会议

raytracegroundup_v2.6_GlobalTace_CornellBox_20170316

XSteam_V2.6b.rar_xsteam_xsteam_v2.6b.dll_水蒸气_水蒸气dll文件_蒸气

CaiHong_V2.6_Fixed_Setup

mongodb_java_2.6_API

Quick_CHM_v2.6_CHS.rar自用自用

Product_Manager_2_2.6_[TNT]_.zip

最新资源