對等計算實踐之：構建 P2P 應用程序框架

　　安裝與執行
　　讓我們從安裝的具體細節開始在可以運行 PP 應用程序之前必須下載兩個 jar 文件 ppjar 和 sppjar 以及配置文件 apppropertiesppjar 文件包含 PP 應用程序自身的類文件sppjar 文件包含 PP 應用程序所使用的消息傳遞庫的類文件下載這些文件之後將這兩個 jar 文件和包含配置文件的目錄添加到類路徑中如果您正在運行 Windows並且已經將這兩個 jar 文件和配置文件下載到 c:\pp 目錄則可以如下設置類路徑
　　
　　set CLASSPATH=c:\pp\ppjar;c:\pp\sppjar;c:\pp
　　
　　如果您正在運行 LinuxSolaris 或某個合適的 UNIX 變體並且已經將這兩個 jar 文件和配置文件下載到 /home/foo/pp 目錄可如下設置類路徑
　　
　　export CLASSPATH=/home/foo/pp/ppjar:/home/foo/pp/sppjar:/home/foo/pp
　　
　　（以上命令假設您正在運行 BASH 來作為命令 shell）將如何在其它流行的 shell（如 CSH）中設置環境變量的問題留給您自己去考慮一旦設置了類路徑就可以用以下命令啟動應用程序
　　
　　java cometceeappkiMain
　　
　　PP 應用程序將顯示一個別致的信息性標志和一個命令提示來歡迎您最後再說一遍我的 PP 應用程序一定需要 Java 平台
　　
　　配置文件
　　前幾步將啟動並運行 PP 應用程序但是在能夠很好地使用它之前必須編輯配置文件配置文件定義 PP 應用程序使用的端口控制的資源以及識別的伙伴清單 演示了每一個定義
　　
　　清單 示例配置文件
　　
　　cometceeappkiport=
　　cometceeappkiresourcename=share
　　cometceeappkiresourceclass=cometceeappkiresourcefileFileResource
　　cometceeappkiresourcearg=/home/foo/share
　　cometceeappkiresourcename=tmp
　　cometceeappkiresourceclass=cometceeappkiresourcefileFileResource
　　cometceeappkiresourcearg=/tmp
　　cometceeappkipeer=bass:
　　cometceeappkipeer=salmon:
　　cometceeappkipeer=perch:
　　cometceeappkipeer=guppy:
　　
　　第一部分由一行組成它定義了 PP 應用程序用來接收其它伙伴連接請求的端口最好不要改變這行第二部分定義 PP 應用程序管理的資源您可能需要編輯這部分清單 定義了兩個資源share 和 tmp從應用程序的觀點來看資源只是實現 Resource 接口的類的實例我們將馬上講到這點資源定義一般具有以下基本形式
　　
　　清單 資源定義
　　
　　cometceeappkiresourcename=
　　cometceeappkiresourceclass=
　　cometceeappkiresourcearg=
　　cometceeappkiresourcearg=
　　
　　
　　name 是給予資源的名稱它用來生成人們可讀的輸出class 是 Java 類的名稱可以將其初始化以創建資源PP 應用程序在運行期間動態裝入這個類並將其初始化在其初始化期間argN 自變量被傳遞到新初始化的資源例如FileResource 類使用這些自變量定義目錄來為文件提供服務您需要編輯目錄自變量以指向您機器上的某個目錄
　　
　　第三部分定義 PP 應用程序識別的伙伴每一行都包含伙伴的名稱（或 IP 地址）和伙伴的端口用這種方式定義伙伴顯然不是可伸縮的解決方案在以後的文章中我們將看一種更好的解決方案
　　
　　代碼
　　除了對等通信采用的 SPP（簡單點到點）包之外PP 應用程序不包含很多類首先我們先仔細查看最重要的類最後再看一下 SPP 通信包
　　
　　資源
　　PP 應用程序的主要組件是資源事實上PP 應用程序只是允許和控制對已發布資源的遠程訪問資源可以是任何可尋址的事物 文件系統電話簿數據庫和目錄每個資源都管理零個或多個適當類型的項（文件系統資源管理文件電話簿資源管理電話號碼）為演示如何實現資源我創建了一個簡單的文件系統資源類 FileResource如清單 所示這個文件系統資源管理零個或多個文件
　　
　　清單 Resource 接口
　　
　　public
　　interface Resource
　　{
　　// The initialize() method requires a TTDFactory instance
　　// (which the factory uses to create the TTDItem instances
　　// it returns from the select() method in response to a
　　// query) and a String array (which contains the arguments
　　// from the configuration file)
　　public
　　void
　　initialize(TTDFactory ttdfactory String [] arstring)
　　throws ResourceException;
　　// The select() method requires a String instance that
　　// defines the selection criteria　It returns an array
　　// of TTDItems one for each entry that matches the
　　// selection criteria
　　public
　　TTDItem []
　　select(String stringSelector)
　　throws ResourceException;
　　}
　　Resource 接口定義資源的結構和行為該接口還定義允許在資源上執行的操作目前的操作列表包括 select以後的實現還將包括 insert 和 delete
　　
　　select() 方法將一個定義選擇標准的字符串作為參數該方法返回有關所有與選擇標准匹配的資源項的信息按照當前 PP 應用程序中的文件系統資源所實現的方式選擇字符串既可以直接命名一項也可以包含通配符 *當直接命名一項時資源將返回該項本身及其相關元數據當包含通配符時資源將只返回它所管理的所有項的元數據還可以使用更復雜的查詢語言但這不在本文討論范圍之內
　　
　　Shell
　　
　　Shell 類只是一個允許用戶浏覽本地和遠程資源的非常簡單的命令行用戶接口它使用 PeerReferenceResourceReference 和 ItemReference 類向其它伙伴發送請求但它本身只分析用戶輸入為了從請求伙伴的角度更好地理解通信的工作原理讓我們看一下清單 中顯示的 PeerReference 類的一部分
　　
　　因為我在上個月詳細描述了通過 shell 進行的用戶交互所以不再這裡重述在第一次啟動 PP 應用程序之前請停一下並使自己重新熟悉它的操作
　　
　　通信
　　PP 所做的全部就是伙伴間的通信那些對原始得令人難以置信的 Napster 協議熟悉的讀者應該理解我為什麼選擇高級一些的協議我在這裡只略微提及 SPP在以後有關 PP 通信的文章中我將詳細描述它
　　
　　SPP 將消息建模成一個幀序列如圖 所示
　　
　　圖 消息
　　
　　消息中的每一幀都有一個類型（由 MIME 類型指明）和一個主體幀中的頭是可選的它用來描述主體中的數據構成完整而正確的消息的序列中的幀類型取決於應用程序一般來講一條消息由一個控制幀和其後零個或多個數據幀組成數據幀包含控制幀所引用的數據我們的 PP 應用程序就采用這種模式
　　
　　消息出現在請求／響應對中一個伙伴向另一個伙伴發送請求那個伙伴再將響應發回給第一個伙伴請求消息中的控制幀是命令幀它包含命令和為該命令提供的所有參數如果有任何其它幀存在則這些幀包含命令幀所需的信息響應消息中的控制幀是狀態幀它包含狀態（正確或錯誤）如果有任何其它幀存在則這些幀包含狀態幀所引用的信息如果向文件系統資源發出請求則該信息將包含所選文件的內容多幀消息模式的優點在於它允許在通信應用程序之間交換內容豐富的消息SPP 在很多方面都類似於 BXXP
　　
　　完全理解了框架之後我們就可以繼續討論 PP 安全性了我們還將在 PP 應用程序中集成安全性支持
From:http://tw.wingwit.com/Article/program/Java/gj/201311/27492.html