1、ICE系列培訓(xùn)(二),黃亮 統(tǒng)一網(wǎng)管平臺(tái)專(zhuān)項(xiàng),培訓(xùn)內(nèi)容,ICE中的異步程序設(shè)計(jì)方法(AMD,AMI) 1.AMI:Asynchronous Method Invocation 異步方法調(diào)用 2.AMD:Asynchronous Method Dispatch 異步方法派發(fā),1. 概述,1.1 同步模型與異步模型區(qū)別 1.2 AMI概述 1.3 AMD概述 1.4 元數(shù)據(jù)(metadata)與AMI，AMD,1.1 同步模型與異步模型區(qū)別,兩者的區(qū)別： 同步模型中發(fā)出調(diào)用的線(xiàn)程會(huì)阻塞到操作返回。異步模型則正好相反，發(fā)出調(diào)用的線(xiàn)程不會(huì)阻塞的等待調(diào)用結(jié)果的返回。 Ice 在本質(zhì)上是一個(gè)異步的中間件平

2、臺(tái)，出于對(duì)應(yīng)用 （及其程序員）的考慮而模擬了同步的行為。當(dāng) Ice 應(yīng)用通過(guò)代理、向遠(yuǎn)地對(duì)象發(fā)出同步的雙向調(diào)用時(shí)，發(fā)出調(diào)用的線(xiàn)程會(huì)阻塞起來(lái)，以模擬同步的方法調(diào)用。在此期間， Ice run time在后臺(tái)運(yùn)行，處理消息，直到收到所需的答復(fù)為止，然后發(fā)出調(diào)用的線(xiàn)程就可以解除阻塞并解編結(jié)果。,1.2 AMI概述,AMI： 異步方法調(diào)用這個(gè)術(shù)語(yǔ)描述的是客戶(hù)端的異步編程模型支持。 使用 AMI發(fā)出遠(yuǎn)地調(diào)用，在 Ice run time 等待答復(fù)的同時(shí)，發(fā)出調(diào)用的線(xiàn)程不會(huì)阻塞。相反，發(fā)出調(diào)用的線(xiàn)程可以繼續(xù)進(jìn)行各種活動(dòng)，當(dāng)答復(fù)最終到達(dá)時(shí)， Ice run time會(huì)通知應(yīng)用。通過(guò)回調(diào)發(fā)給應(yīng)用對(duì)象通知,1.

3、3 AMD概述,AMD: 使用 AMD 時(shí)，服務(wù)器可以接收一個(gè)請(qǐng)求，然后掛起其處理，以盡快釋放分派線(xiàn)程。當(dāng)處理恢復(fù)、結(jié)果已得出時(shí)，服務(wù)器要使用 Ice run time 提供的回調(diào)對(duì)象，顯式地發(fā)送響應(yīng)。 AMD 操作通常會(huì)把請(qǐng)求數(shù)據(jù) （也就是，回調(diào)對(duì)象和 操作參數(shù)）放入隊(duì)列 ，供應(yīng)用的某個(gè)線(xiàn)程 （或線(xiàn)程池）隨后處理用。這樣，服務(wù)器就使分派線(xiàn)程的使用率降到了最低限度，能夠高效地支持?jǐn)?shù)千并發(fā)客戶(hù)。,1.3 AMD概述,為什么要使用AMD： （1）默認(rèn)情況下：一個(gè)服務(wù)器在同一時(shí)刻所能支持的同步請(qǐng)求數(shù)受到 Ice run time的服務(wù)器線(xiàn)程池的尺寸限制 。如果所有線(xiàn)程都在忙于分派長(zhǎng)時(shí)間運(yùn)行的操作，那

4、么就沒(méi)有線(xiàn)程可用于處理新的請(qǐng)求，客戶(hù)就會(huì)體驗(yàn)到不可接受的無(wú)響應(yīng)狀態(tài)。 （2）Ice run time的服務(wù)器線(xiàn)程池尺寸受限于主機(jī)的CPU數(shù)。,1.4 元數(shù)據(jù)與AMI，AMD,1）ICE自3.4以后，提供了一套全新的AMI(異步調(diào)用方式)的API，新的API已不需要在slice文件中標(biāo)記“ami”這樣的元數(shù)據(jù)。 2）ICE提供向下兼容性，支持“ami”的語(yǔ)言標(biāo)記，但已標(biāo)注為deprecated. 3) 服務(wù)端使用AMD異步派發(fā)方式編程，仍然必須在slice文件中，對(duì)slice定義標(biāo)注“amd”元數(shù)據(jù)。 Tips: 給客戶(hù)提供某個(gè)調(diào)用方法的同步和異步版本是有益的，但如果在服 務(wù)器中這樣做，程序員就

5、必須實(shí)現(xiàn)兩種版本的分派方法，并不能帶來(lái)切實(shí)的好處，而且還會(huì)帶來(lái)若干潛在的缺陷。,1.4 元數(shù)據(jù)與AMI，AMD,AMD元數(shù)據(jù)標(biāo)記方式： 1）接口級(jí)(interface) amd interface I bool isValid(); float computeRate(); ; 2) 操作級(jí)(operation) interface J amd void startProcess(); int endProcess(); ;,1.4 元數(shù)據(jù)與AMI，AMD,AMD元數(shù)據(jù)的標(biāo)記方式 Tips: 在操作層面、而不是接口或類(lèi)的層面指定元數(shù)據(jù)，不僅能使所生成的代碼的數(shù)量降到最低限度，而且，更重要的是，

6、它還能使復(fù)雜度降到最低限度。盡管異步模型更為靈活，它的使用也更復(fù)雜。因此，最好只把它用于那些能從中獲得某種好處的操作；對(duì)其他操作則使用更簡(jiǎn)單的同步模型。,2. AMI編程,2.1 基本API 2.2 AsynResult類(lèi) 2.3 輪詢(xún)方式的完成通知(Polling for Completion) 2.4 通用的完成通知回調(diào)函數(shù)(Generic Completion Callbacks) 2.5 類(lèi)型安全的回調(diào)(Type-Safe Completion Callbacks) 2.6 單路調(diào)用(Oneway Invocations) 2.7 流量控制(Flow Control) 2.8 批量請(qǐng)求

7、(Batch Requests) 2.9 并發(fā)(Concurrency) 2.10 限制(Limitations) 2.11 示例,2.1 Slice介紹,（1）Slice是什么 Slice（Specification Language for Ice)是分離對(duì)象接口和實(shí)現(xiàn)的重要抽象機(jī)制。Slice建立了客戶(hù)和服務(wù)器之間的契約，這些契約描述了應(yīng)用所需的類(lèi)型及對(duì)象接口。這些描述是中立與語(yǔ)言的，所以客戶(hù)端和服務(wù)端可以使用不同的實(shí)現(xiàn)語(yǔ)言。 Slice提供編譯工具將Slice定義編譯為具體語(yǔ)言的實(shí)現(xiàn)代碼，即客戶(hù)端的Proxy code和服務(wù)端的Skeleton,這樣用戶(hù)只用把注意力放在業(yè)務(wù)邏輯的處理上

8、。,2.1 Basic Asynchronous API,1.異步方法通知(AMI)API ICE從3.4開(kāi)始采用新的AMI API： module Demo interface Employees string getName(int number); ; ; 1）不必再顯式的注明“ami”元數(shù)據(jù)，slice工具會(huì)自動(dòng)的生產(chǎn)同步調(diào)用與異步調(diào)用的stub代碼。 Ice:AsyncResultPtr begin_getName(Ice:Int number); Ice:AsyncResultPtr begin_getName(Ice:Int number, const Ice:Context,2

9、.1 Basic Asynchronous API,(2）begin_xxxMethod負(fù)責(zé)向隊(duì)列中插入一個(gè)調(diào)用的請(qǐng)求，當(dāng)請(qǐng)求插入到隊(duì)列后，便可立即返回，不必阻塞的等待調(diào)用完成。 (3)end_xxxMethod負(fù)責(zé)收集異步調(diào)用的結(jié)果。當(dāng)異步調(diào)用的結(jié)果還未處理完成時(shí)，調(diào)用end_xxxMethod方法會(huì)阻塞到異步調(diào)用完成處理結(jié)果。換句話(huà)說(shuō)，如果結(jié)果已完成，調(diào)用end_xxxMethod方法會(huì)立即返回。 示例： EmployeesPrx e = .; Ice:AsyncResultPtr r = e-begin_getName(99); / Continue to do other things

10、 here. string name = e-end_getName(r); Tips： AsyncResultPtr是AsynResult的智能指針，存儲(chǔ)了ICE運(yùn)行時(shí)對(duì)于異步調(diào)用的狀態(tài)追蹤的信息。在調(diào)用begin_xxxMethod方法相關(guān)的end_xxxMethod方法時(shí)，必須傳入相應(yīng)的AsyncResultPtr對(duì)象,2.1 Basic Asynchronous API,（4）異步方法調(diào)用中的參數(shù) Slice定義的方法參數(shù)在AMI的begin_,end_方法中有相應(yīng)的變化： double op(int inp1, string inp2, out bool outp1, out lon

11、g outp2); AMI： Ice:AsyncResultPtr begin_op(Ice:Int inp1, const :std:string 注意： 1）slice定義中的輸入?yún)?shù)轉(zhuǎn)移為begin_op中的唯一輸入?yún)?shù)。 2）slice定義中的輸出參數(shù)作為end_op的輸出參數(shù)，end_op的返回值為原slice定義的返回值。 3）Begin_op返回AsyncResultPtr作為end_op的輸入?yún)?shù)。,2.1 Basic Asynchronous API,（5）異常處理(Exception Handling) 1)通常情況下，當(dāng)異步調(diào)用過(guò)程中發(fā)生異常，在end_xxxMethod

12、中拋出，即使異常發(fā)生在begin_xxxMethod中。 2）但有2種例外的情況： 當(dāng)銷(xiāo)毀了當(dāng)前的Communicator后，再調(diào)用異步方法，會(huì)拋出CommunicatorDestroyedException異常。 當(dāng)調(diào)用方式出錯(cuò)時(shí)，拋出IceUtil:IllegalArgumentException異常（begin_,end_配對(duì)錯(cuò)誤，調(diào)用的方法參數(shù)錯(cuò)誤）,2.2AsynResult類(lèi),（1）AsynResult類(lèi)聲明 class AsyncResult : virtual public IceUtil:Shared, private IceUtil:noncopyable public:

13、virtual bool operator=(const AsyncResult,AsyncResult類(lèi)由begin_op方法返回，封裝了異步調(diào)用的有關(guān)信息,2.2AsynResult類(lèi),(2) 方法說(shuō)明 bool operator=(const AsyncResult ; /同步發(fā)送 FileHandle file = open(.); FileTransferPrx ft = .; const int chunkSize = .; Ice:Int offset = 0; while (!file.eof() ByteSeq bs; / Read a chunk bs = file.rea

14、d(chunkSize); / Send the chunk ft-send(offset, bs); offset += bs.size(); ,FileHandle file = open(.); FileTransferPrx ft = .; const int chunkSize = .; Ice:Int offset = 0; list results; const int numRequests = 5; while (!file.eof() ByteSeq bs; bs = file.read(chunkSize); / Send up to numRequests + 1 ch

15、unks asynchronously. Ice:AsyncResultPtr r = ft-begin_send(offset, bs); offset += bs.size(); / 等待請(qǐng)求完成發(fā)送 r-waitForSent(); results.push_back(r); /超過(guò)了水位標(biāo)則阻塞等待. while (results.size() numRequests) Ice:AsyncResultPtr r = results.front(); results.pop_front(); r-waitForCompleted(); /等待剩余的請(qǐng)求完成. while (!result

16、s.empty() Ice:AsyncResultPtr r = results.front(); results.pop_front(); r-waitForCompleted(); ,2.6 完成通知,1.輪詢(xún)方式的完成通知 1）同步方式與異步方式效率上的差距 2）異步方式AsyncResult隊(duì)列控制 提高傳輸效率 控制內(nèi)存占用,2.6 完成通知,2.通用回調(diào)函數(shù)方式的完成通知 相對(duì)于輪詢(xún)方式的優(yōu)點(diǎn)： 解除應(yīng)用邏輯與異步調(diào)用機(jī)制的耦合性。利用Ice 運(yùn)行時(shí)完成客戶(hù)端的異步處理邏輯。 Slice提供的重載方法，紅色高亮部分是回調(diào)完成通知的特征。 Ice:AsyncResultPtr beg

17、in_getName( Ice:Int number, const Ice:CallbackPtr Ice:CallbackPtr: Ice運(yùn)行時(shí)提供的回調(diào)函數(shù)智能指針，存儲(chǔ)了自定義的回調(diào)函數(shù)實(shí)例。 當(dāng)發(fā)生回調(diào)時(shí)，Ice運(yùn)行時(shí)會(huì)執(zhí)行回調(diào)函數(shù)對(duì)象上綁定的方法。,2.6 完成通知,3.自定義的回調(diào)對(duì)象示例： class MyCallback : public IceUtil:Shared public: void finished(const Ice:AsyncResultPtr 回調(diào)對(duì)象封裝了異步調(diào)用實(shí)質(zhì)的業(yè)務(wù)邏輯，異步調(diào)用本身是發(fā)出非阻塞的調(diào)用請(qǐng)求，但重要的是發(fā)出了請(qǐng)求以后，應(yīng)用邏輯該如何執(zhí)行

18、。,/ 應(yīng)用程序AMI調(diào)用示例： EmployeesPrx e = .; MyCallbackPtr cb = new MyCallback; Ice:CallbackPtr d = Ice:newCallback(cb, ,2.6 完成通知,4.回調(diào)對(duì)象的編寫(xiě)要點(diǎn) 1）繼承IceUtil:Shared 2) 回調(diào)對(duì)象中的回調(diào)方法，必須符合以下聲明方式： void callback_method(AsyncResultPtr 5)回調(diào)方法必須捕獲所有可能由end_xxxMethod拋出的異常，如果遺漏了某異常，Ice運(yùn)行時(shí)默認(rèn)會(huì)在日志中記錄，但也會(huì)忽略這個(gè)異常(設(shè)置Ice.Warn.AMICa

19、llback屬性為0，可以不記錄日志)。,2.6 完成通知,5.應(yīng)用程序AMI調(diào)用示例： EmployeesPrx e = .; MyCallbackPtr cb = new MyCallback; Ice:CallbackPtr d = Ice:newCallback(cb, 注意: 1)Ice:newCallback輔助函數(shù)，將自定義的回調(diào)對(duì)象智能指針與回調(diào)方法綁定后，返回Ice:CallbackPtr類(lèi)型的對(duì)象。 2)begin_xxxMethod，需要輸入一個(gè)Ice:CallbackPtr對(duì)象。,2.6 完成通知,6.回調(diào)中的Cookie Ice:AsyncResultPtr begi

20、n_getName( Ice:Int number, const Ice:CallbackPtr Cookie對(duì)象在異步方法調(diào)用中用于begin_xxxMethod與end_xxxMethod之間傳遞信息。 應(yīng)用場(chǎng)景： 用戶(hù)在界面上點(diǎn)擊產(chǎn)生大量的異步調(diào)用，當(dāng)這些異步調(diào)用完成后，每個(gè)調(diào)用需要更新不同用戶(hù)界面組件。在這種情景下，每個(gè)調(diào)用需要攜帶它所需要更新的組件信息才能完成操作。 在這種異步調(diào)用與回調(diào)函數(shù)之間需要交互的情況下，可以通過(guò)Cookie在應(yīng)用中綁定相關(guān)信息。,2.6 完成通知,7.Cookie的編寫(xiě) 為了滿(mǎn)足不同的應(yīng)用場(chǎng)景，Cookie對(duì)象可以自定義。 Cookie編寫(xiě)的唯一要求就是要繼

21、承Ice:LocalObject 示例： class Cookie : public Ice:LocalObject public: Cookie(WidgetHandle h) : _h(h) WidgetHandle getWidget() return _h; private: WidgetHandle _h; ; typedef IceUtil:Handle CookiePtr; / CookiePtr cookie1 = new Cookie(widgetHandle1); / Make cookie for call to getName(42); CookiePtr cookie

22、2 = new Cookie(widgetHandle2); / Invoke the getName operation with different cookies. e-begin_getName(99, getNameCB, cookie1); e-begin_getName(24, getNameCB, cookie2);,void MyCallback:getName(const Ice:AsyncResultPtr 1)在應(yīng)用邏輯中創(chuàng)建了Cookie對(duì)象 2)將Cookie對(duì)象傳遞給begin_getName方法 3)在對(duì)應(yīng)的回調(diào)方法中重新獲得Cookie(需要向下轉(zhuǎn)型) 4)從

23、Cookie對(duì)象中獲得需要的信息,2.6 完成通知,8.類(lèi)型安全回調(diào)函數(shù)方式的完成通知 (1)通用回調(diào)方法存在一些類(lèi)型安全方面的隱患 在回調(diào)方法中調(diào)用end_xxxMethod前必須將代理對(duì)象向下轉(zhuǎn)型為正確的代理對(duì)象類(lèi)型 EmployeesPrx e = EmployeesPrx:uncheckedCast(r-getProxy(); 調(diào)用的end_xxxMethod必須與begin_xxxMethod配對(duì) 如果使用了Cookie，那么也需要將Cookie向下轉(zhuǎn)型為正確的Cookie類(lèi)型。 CookiePtr cookie = CookiePtr:dynamicCast(r-getCookie

24、(); 在調(diào)用end_xxxMethod方法時(shí)，必須要捕獲所有可能的異常。否則無(wú)法獲知調(diào)用在何時(shí)失敗 Slice工具提供了一套Callback類(lèi)API解決上述類(lèi)型安全問(wèn)題。,2.6 完成通知,8.類(lèi)型安全回調(diào)函數(shù)方式的完成通知 （2）Slice工具與類(lèi)型安全的回調(diào) Slice工具在編譯slice文件時(shí)，生成一系列相關(guān)的回調(diào)函數(shù)類(lèi)別，在這些自動(dòng)生成的代碼中，將類(lèi)型轉(zhuǎn)換，調(diào)用end_xxxMethod等通用回調(diào)方法中的程式化方法以自動(dòng)生成的方式代替手工編程。（C+中是以模板的方式實(shí)現(xiàn)不同回調(diào)函數(shù)的模板實(shí)例）,2.6 完成通知,8.類(lèi)型安全回調(diào)函數(shù)方式的完成通知 （3）類(lèi)型安全的回調(diào)函數(shù)實(shí)現(xiàn)要點(diǎn) S

25、lice工具為slice定義的接口中的接口方法自動(dòng)生成類(lèi)型安全的回調(diào)類(lèi)型。 自定義回調(diào)類(lèi)型實(shí)現(xiàn)具體的回調(diào)操作，處理業(yè)務(wù)邏輯。 必須聲明一個(gè)正常情況下處理回調(diào)的方法，該方法返回void類(lèi)型，參數(shù)列表與slice定義一致。當(dāng)slice返回類(lèi)型不是void的時(shí)候，則第一個(gè)參數(shù)用于返回值，后續(xù)參數(shù)與slice定義中的參數(shù)列表一致。 必須聲明一個(gè)異常情況下，處理異常的方法（無(wú)返回值，只有一個(gè)const Ice:Exception MyCallbackPtr cb = new MyCallback; Ice:CallbackPtr d = Ice:newCallback(cb, ,2.6 完成通知,10.

26、類(lèi)型安全的Cookie調(diào)用方式 MyCallbackPtr cb = new MyCallback; Callback_Employees_getNamePtr getNameCB = newCallback_Employees_getName( cb, ,class MyCallback : public IceUtil:Shared public: void getNameCB(const string ,2.6 完成通知,11.類(lèi)型安全回調(diào)方式使用總結(jié) 聲明自定義回調(diào)對(duì)象實(shí)例 聲明類(lèi)型安全的回調(diào)對(duì)象實(shí)例 聲明類(lèi)型安全回調(diào)對(duì)象實(shí)例時(shí)，利用輔助函數(shù)構(gòu)造回調(diào)對(duì)象實(shí)例 輔助函數(shù)中需要傳遞： 自定

27、義回調(diào)對(duì)象實(shí)例 回調(diào)方法 失敗處理的回調(diào)方法,2.7 單路調(diào)用,1）通用的回調(diào)方式由于回調(diào)類(lèi)別中回調(diào)函數(shù)具有輸入?yún)?shù)， void callback_method(AsyncResultPtr,2.8 流量控制,1.流量控制的起因： 客戶(hù)端并發(fā)請(qǐng)求非常頻繁，服務(wù)端處理能力趕不上客戶(hù)端發(fā)送異步請(qǐng)求的速度?？蛻?hù)端將請(qǐng)求發(fā)往客戶(hù)端Ice運(yùn)行時(shí)請(qǐng)求隊(duì)列，隊(duì)列不斷增長(zhǎng)，在不加流量控制的情況下，最終耗盡內(nèi)存。 2.流量控制的功能： Ice提供了一套流量控制管理的API，應(yīng)用了流量管理的api后，當(dāng)客戶(hù)端的請(qǐng)求數(shù)超過(guò)了限定的閾值，則阻塞客戶(hù)端發(fā)起的新的操作請(qǐng)求直到隊(duì)列中完成部分請(qǐng)求的處理，有剩余的空間容納入隊(duì)

28、的請(qǐng)求。,2.8 流量控制,4.流量控制回調(diào)函數(shù)定義 1）通用回調(diào)方式 void sent(const Ice:AsyncResult 調(diào)用情景1與情景2的判斷由Ice運(yùn)行時(shí)傳遞的sendSynchronously參數(shù)判斷。,2.8 流量控制,3.流量控制的編程要點(diǎn)： 流量控制的基本思想是自定義流量控制的方法。 class MyCallback : public IceUtil:Shared public: void finished(const Ice:AsyncResultPtr 情景1：當(dāng)Ice運(yùn)行時(shí)將請(qǐng)求發(fā)送到客戶(hù)端的發(fā)送端上后，由調(diào)用begin_xxxMethod的方法的線(xiàn)程接著調(diào)用

29、send方法。 情景2：當(dāng)Ice運(yùn)行時(shí)將請(qǐng)求入隊(duì)時(shí)，則由另一線(xiàn)程在Ice運(yùn)行時(shí)將隊(duì)列中請(qǐng)求發(fā)送到發(fā)送端后，調(diào)用send方法。 以上2種情況調(diào)用send的const Ice:AsyncResultPtr Ice:ObjectPrx ice_batchDatagram() const; void ice_flushBatchRequests(); / . ; ,2.9 批量調(diào)用,3.顯式調(diào)用與隱式調(diào)用 ： 顯式同步調(diào)用： ice_flushBatchRequests 顯式異步調(diào)用： begin_ice_flushBatchRequests end_ice_flushBatchRequests 隱式

30、調(diào)用： Ice.BatchAutoFlush=1（默認(rèn)） Ice.MessageSizeMax=1MB(默認(rèn)),2.10 AMI的并發(fā),Ice運(yùn)行時(shí)通常情況下由獨(dú)立的線(xiàn)程調(diào)用異步回調(diào)方法中的回調(diào)函數(shù)。因此在回調(diào)函數(shù)中可以使用非遞歸鎖而不怕出現(xiàn)死鎖的情況。 但如果定義了流量控制回調(diào)函數(shù)，則如前所述的規(guī)則，在不同的情景下，有不同的線(xiàn)程選擇規(guī)則。,2.11 AMI的限制,采用了AMI異步回調(diào)，則不能采用collocated optimization優(yōu)化。否則拋出CollocationOptimizationException。 collocated optimization優(yōu)化 參見(jiàn)ICE手冊(cè)32.

31、21節(jié),2.12 示例1,slice文件： #ifndef HELLO_ICE #define HELLO_ICE module Demo exception RequestCanceledException ; interface Hello / 注意元數(shù)據(jù)定義 ami, amd idempotent void sayHello(int delay) throws RequestCanceledException; void shutdown(); ; ; #endif,2.12 示例1,int AsyncClient:run(int argc, char* argv) if(argc 1)

32、 cerr propertyToProxy(Hello.Proxy); if(!hello) cerr argv0 : invalid proxy endl; return EXIT_FAILURE; menu(); CallbackPtr cb = new Callback(); char c;,do try cout ; cin c; if(c = i) hello-sayHello(0); else if(c = d) hello-begin_sayHello(5000, newCallback_Hello_sayHello(cb, ,3. AMD編程,3.1元數(shù)據(jù)標(biāo)記 3.2 AMD語(yǔ)

33、言映射（C+） 3.3 AMD方式下的異常 3.4示例,3. AMD編程,回顧AMD概述 (1.3節(jié)） AMD: 使用 AMD 時(shí)，服務(wù)器可以接收一個(gè)請(qǐng)求，然后掛起其處理，以盡快釋放分派線(xiàn)程。當(dāng)處理恢復(fù)、結(jié)果已得出時(shí)，服務(wù)器要使用 Ice run time 提供的回調(diào)對(duì)象，顯式地發(fā)送響應(yīng)。 AMD 操作通常會(huì)把請(qǐng)求數(shù)據(jù) （也就是，回調(diào)對(duì)象和 操作參數(shù)）放入隊(duì)列 ，供應(yīng)用的某個(gè)線(xiàn)程 （或線(xiàn)程池）隨后處理用。這樣，服務(wù)器就使分派線(xiàn)程的使用率降到了最低限度，能夠高效地支持?jǐn)?shù)千并發(fā)客戶(hù)。,3. 2 AMD方式的語(yǔ)言映射,2. AMD的語(yǔ)言映射(C+) C+ 代碼生成器為每個(gè)AMD 操作生成以下代碼：

34、一個(gè)抽象的回調(diào)類(lèi):實(shí)現(xiàn)用它來(lái)通知 Ice run time，操作已完成。 類(lèi)名規(guī)則:AMD_class_op 例如，對(duì)于在接口I 中定義的名叫foo 的操作 ，對(duì)應(yīng)的類(lèi)的名字是 AMD_I_foo。 void ice_response(); 服務(wù)器可以用 ice_response 方法報(bào)告操作已成功完成。如果操作的返回類(lèi)型不是 void， ice_response 的第一個(gè)參數(shù)就是返回值。與操作的out 參數(shù)對(duì)應(yīng)的參數(shù)跟在返回值后面，其次序是聲明時(shí)的次序。 void ice_exception(const Ice:Exception ; 下面是為操作foo 生成的回調(diào)類(lèi)： class AMD_

35、I_foo : public . public: void ice_response(Ice:Int, Ice:Long); void ice_exception(const Ice:Exception ,3. 3 AMD的異常傳遞,在兩種處理上下文中， AMD 操作的邏輯實(shí)現(xiàn)可能需要報(bào)告異常：分派線(xiàn)程 ( 也就是，接收調(diào)用的線(xiàn)程)，以及響應(yīng)線(xiàn)程 (也就是，發(fā)送響應(yīng)的線(xiàn)程 )。 盡管建議你用回調(diào)對(duì)象來(lái)把所有異常報(bào)告給客戶(hù)，實(shí)現(xiàn)拋出異常也是合法的，但只能在分派線(xiàn)程中拋出。 Ice run time 無(wú)法捕捉從響應(yīng)線(xiàn)程拋出的異常；應(yīng)用 的運(yùn)行時(shí)環(huán)境將決定怎樣處理這樣的異常。因此，響應(yīng)線(xiàn)程必須確保抓

36、住所有異常，并用回調(diào)對(duì)象發(fā)送適當(dāng)?shù)捻憫?yīng)。否則，如果響應(yīng)線(xiàn)程被未捕捉的異常終止，請(qǐng)求就可能不會(huì)完成，客戶(hù)將無(wú)限期地等待響應(yīng)。,3. 4 示例,Slice定義 interface Hello ami, amd idempotent void sayHello(int delay) throws RequestCanceledException; void shutdown(); ;,3. 4 示例,服務(wù)端聲明文件代碼： #include #include class HelloI : virtual public Demo:Hello public: HelloI(const WorkQueueP

37、tr,3. 4 示例,服務(wù)端實(shí)現(xiàn)文件代碼： HelloI:HelloI(const WorkQueuePtr ,void HelloI:shutdown(const Ice:Current ,3. 4 示例,服務(wù)端實(shí)現(xiàn)文件代碼： int AsyncServer:run(int argc, char* argv) if(argc 1) cerr createObjectAdapter(Hello); _workQueue = new WorkQueue(); Demo:HelloPtr hello = new HelloI(_workQueue); /定義服務(wù)端servrant adapter-add(hello, communicator()-stringToIdentity(“hello”)