1、Distributed Travel Reservation System,(Part ),任務(wù)描述,用JAVA建立一個分布式的應(yīng)用程序以實現(xiàn)一個簡單的旅行預(yù)訂系統(tǒng)，分為三個階段： 1. 實現(xiàn)一個簡單的資源管理器(Resource Manager，一個具有固定的表和操作集的非常簡易的數(shù)據(jù)庫系統(tǒng))，用來支持并發(fā)事務(wù)的ACID性質(zhì)(原子性、一致性、獨立性、持久性)； 2. 實現(xiàn)一個工作流程控制器（Workflow Controller）和一個事務(wù)管理器（Transaction Manager），用來在多個資源管理器（Resource Managers）之間實現(xiàn)分布式事務(wù)處理； 3. 實現(xiàn)一些擴展功

2、能。 本課程只要求實現(xiàn)第一部分。,簡易的旅行資源管理器,RM支持并發(fā)事務(wù)的ACID性質(zhì)。RM存儲著關(guān)于航班，出租車，賓館房間和客戶的數(shù)據(jù)信息。多個客戶端通過一個事務(wù)處理界面可同時訪問這個RM以查詢和更新數(shù)據(jù)。這個RM要保證這些并發(fā)事務(wù)的執(zhí)行正確性，即符合ACID性質(zhì)的要求。 RM存儲著下列表： FLIGHTS (String flightNum, int price, int numSeats, int numAvail) HOTELS(String location, int price, int numRooms, int numAvail) CARS(String location, i

3、nt price, int numCars, int numAvail) CUSTOMERS(String custName) RESERVATIONS(String custName, int resvType, String resvKey),簡易的旅行資源管理器,我們提供了資源管理器（Resource Manager）的標準接口（詳見ResourceManager API）。這個接口允許每一個在RM中存儲的表中的行被添加、刪除和修改。你的工作是為每一個我們提供的接口寫出實現(xiàn)程序。,事務(wù)處理,RM支持事務(wù)處理。一個事務(wù)調(diào)用RM的start( )方法來獲取一個唯一的事務(wù)標識（transact

4、ion id）。所有對RM的后續(xù)調(diào)用都要包括這個事務(wù)標識。最后，事務(wù)調(diào)用commit( )或abort( )方法結(jié)束事務(wù)處理。,并發(fā)控制,并發(fā)控制是通過兩階段鎖（two-phase locking）來實現(xiàn)的。當一個客戶端要求查詢或更新信息時，你的RM要適當?shù)亟o相應(yīng)元組加鎖，并在事務(wù)正常完成（commits）或異常中斷（abort）時釋放所有的鎖。我們提供了一個鎖管理器（lock manager）幫助你完成任務(wù)。,文件說明,part1.tar LockManager.java LockManagerTest.java Client.java Makefile make.exe,文件說明,part

5、1.tar是源碼（詳見API），有兩個文件夾：lockmgr和transaction。 lockmgr實現(xiàn)了LockManager的功能，你不必修改這個包中的內(nèi)容。 transaction提供了一些基本的類以幫助你完成工作，它包含了ResourceManager的接口。請注意，你不要修改此文件，你的RM實現(xiàn)要基于名為ResourceManagerImpl的類（以及一些自己定義的新類），這個類提供了ResourceManager的接口。你必須自己編寫接口實現(xiàn)代碼，以替代目前提供的這個ResourceManagerImpl.java文件中的接口實現(xiàn)代碼。,文件說明,請注意：用LockManager

6、.java文件和LockManagerTest.java文件替換part1和part2中的同名文件（因為part1和part2中的同名文件有錯誤?。ヽlient.java是用來做最后測試的。,文件說明,Windows下需要Make工具，即make.exe，需將make.exe放到j(luò)avac.exe所在目錄下。 Windows下需用我們提供的makefile文件替換part1.tar中的makefile文件。而Linux下則不用。,基本框架結(jié)構(gòu)(Part I) :C/S,Flights, Hotels, Cars, Customers,1.運行環(huán)境,操作系統(tǒng) Solaris VM or Wind

7、ows or Linux (Unix) 開發(fā)語言 JAVA JDK1.2.2以上版本 (Windows下需要Make工具),1.運行環(huán)境,JAVA環(huán)境變量設(shè)置 Set path = ;C:j2sdk1.4.0_01bin CLASSPATH = .;C:j2sdk1.4.0_01libtools.jar;C:j2sdk1.4.0_01libdt.jar;C:j2sdk1.4.0_01jrelibrt.jar;D:project,1.運行環(huán)境,怎樣運行 javac *.java 生成 *.class 文件 make runreg 注冊端口號 make runserver 運行Server端 ma

8、ke runclient 運行Client端 Ctrl + c to kill the server,2.RMI與Thread,RMI (Remote Method Invocation) rebind(name, obj) 和 bind(name, obj) lookup(name),2.RMI與Thread,Thread run() 定義線程體 sleep(long millis) 睡眠millis毫秒 start() 啟動線程,3.Lock Manager (lockmgr包),lock(xid, thingBeingLocked, read|write) throws Deadlock

9、Exception ; unlockAll(xid),4.ITE和TAE,ITE - InvalidTransactionException 注意：記錄可用的事務(wù)號 TAE - TransactionAbortedException e.g. deadlock,5.事務(wù)可以掛起嗎?,掛起 - 不commit,也不abort 可以掛起,真正的RM用超時機制強制abort此類事務(wù) 程序中可以不考慮,6.怎樣實現(xiàn)多粒度鎖?,粒度 tables和tuples 意向鎖(IS和IX) lm不直接提供,但可以實現(xiàn): read S,S update S,X insert/delete X,X,7.讀/寫磁盤,

10、readObject() writeObject(Object) e.g. public class FlightsItem implements java.io.Serializable ,8.Customers和Reservations表可以合并嗎?,可以合并 Reservations不含主鍵,但通常按custName查詢 Reservations(String custName, List resv) resv(int resvType, String resvKey),9.測試與異常,測試(Test) shutdown(), dieNow(), dieBeforePointerSwit

11、ch(), dieAfterPointerSwitch(),9.測試與異常,異常處理 InvalidTransactionException, TransactionAbortedException, DeadlockException IOException和RemoteException可以暫時不考慮,10.原子性的實現(xiàn),10.原子性的實現(xiàn) Shadow思想,成果提交,兩實驗分組相同 每一小組最后提交： 系統(tǒng)設(shè)計報告 程序演示報告 小組各成員的任務(wù)分工 源程序（需要詳細注釋，注明所使用的JDK版本）,提交方式,5 ，“分布式數(shù)據(jù)庫實驗”目錄下 用戶名：addb 密碼：addb06 該目錄只有上傳權(quán)限，請先在本地將所要提交