JavaScript對(duì)象間基于Message的同步/異步通信（一）

hoodng

  一、需求分析

 

    在JavaScript里采用OO編程思想后，和其它語(yǔ)言一樣(Java, C/C++等)通常都會(huì)面臨對(duì)象間通信的問(wèn)題。我們知道一般意義上的對(duì)象間通信，就是對(duì)象方法的調(diào)用，比如對(duì)象A要驅(qū)動(dòng)對(duì)象B完成某一任務(wù)，那么對(duì)象A會(huì)調(diào)用對(duì)象B的一個(gè)方法，并傳入相應(yīng)的參數(shù)。如圖：

不過(guò)這種通信方式有一個(gè)前提，就是對(duì)象A可以直接訪問(wèn)到對(duì)象B，也就是說(shuō)對(duì)象A和對(duì)象B之間是緊密耦合的。然而，在有些時(shí)候（也許是很多時(shí)候），對(duì)象A也許不能直接訪問(wèn)對(duì)象B，甚至于對(duì)象A可能都不知道對(duì)象B的存在。那么這種情況下如果對(duì)象A還要驅(qū)動(dòng)對(duì)象B完成某一任務(wù)，就只有借助所謂的Message系統(tǒng)來(lái)傳遞信息了。如圖：

當(dāng)然這種通信方式也有一個(gè)前提，就是對(duì)象A，對(duì)象B都需要知道Messenger，不過(guò)這不是問(wèn)題，因?yàn)镸essenger通常都是作為系統(tǒng)服務(wù)提供。

  

  二、 用例設(shè)計(jì)

         在JavaScript里如何實(shí)現(xiàn)Messenger服務(wù)呢，方法很多，這里提供一種常見(jiàn)的，基于訂閱/發(fā)布模式（subscribe/publish）的簡(jiǎn)單實(shí)現(xiàn)。所謂訂閱/發(fā)布模式很好理解，就像你從郵局訂閱某種期刊，當(dāng)期刊的發(fā)行者有新的期刊時(shí)，他會(huì)把期刊交給郵局，而郵局負(fù)責(zé)把期刊投送到你手里�？梢杂孟旅孢@個(gè)用例圖來(lái)描述這個(gè)郵局：

用JavaScript如何描述這個(gè)郵局呢，既然是OO編程，我們自然還是用對(duì)象來(lái)定義這個(gè)郵局，由于比較偏向Java的風(fēng)格，所以就沿用了Java的類(lèi)名字java.awt.EventQueue(其實(shí)，我本人從未用過(guò)這個(gè)類(lèi)，但大概能猜出它的含義)，我們?yōu)檫@個(gè)郵局的類(lèi)定義如下：

1. /**
   
2.  * Define the EventQueue class based on subscribe/publish mode
   
3.  */
   
4. js.awt.EventQueue = function(){
   
5.     /**
   
6.      * Subscribe a message from EventQueue
   
7.      *
   
8.      * @param msgId, what
   
9.      * @param listener, who
   
10.      * @param handler, where
    
11.      */
    
12.     this.register = function(msgId, listener, handler){
    
13.         // TODO: Register to DB
    
14. 
    
15.     };
    
16.     
    
17.     /**
    
18.      * Schedule system use this method to dispatch a message to
    
19.      * listeners
    
20.      *
    
21.      * @param msg
    
22.      */
    
23.     this.dispatch = function(msg){
    
24.         // TODO: Dispatch message to listeners
    
25.         
    
26.     };
    
27. 
    
28.     /**
    
29.      * Message sender use this method to post a message and
    
30.      * return immediately
    
31.      *
    
32.      * @param msg
    
33.      */
    
34.     this.post = function(msg){
    
35.         // TODO: Put this message to the message queue.
    
36. 
    
37.     };
    
38. 
    
39.     /**
    
40.      * Message sender use this method to send a message and
    
41.      * blocked till to all receivers process this message completely
    
42.      *
    
43.      * @param msg
    
44.      */
    
45.     this.send = function(msg){
    
46.         // TODO: Deliver this message to receiver directly
    
47. 
    
48.     };
    
49.     
    
50. }.$extend(ls.lang.Object);

上面的代碼中， register 方法對(duì)應(yīng) Subscribe 用例， dispatch 方法對(duì)應(yīng) Deliver 用例， post/send 方法對(duì)應(yīng) Publish 用例，這里還需要對(duì)這個(gè)“郵局”的功能再注釋一下：

• Subscribe 用例， 對(duì)應(yīng) register 方法，用于消息接收者向“郵局”注冊(cè)自己的 what, who, where 三要素。

1. what  可以理解為消息的種類(lèi)標(biāo)示；
2. who   在OO編程中自然是指消息接收者對(duì)象本身； 
3. where 是指消息接收者使用什么方法來(lái)處理消息。

• Publish 用例, 有兩個(gè)方法 post 和 send。

1. post 方法用于異步消息的發(fā)送，也就是消息的發(fā)送者在 post 消息后， post 方法會(huì)立即返 回，而消息交由調(diào)度系統(tǒng)發(fā)送。
2. send 方法用于同步消息的發(fā)送， 即消息的發(fā)送者在 send 消息后， send 方法將會(huì)被阻塞直到消息的接收者處理完消息。

• Deliver 用例， 對(duì)應(yīng) dispatch 方法，這個(gè)方法由調(diào)度系統(tǒng)調(diào)用。同時(shí)當(dāng)使用 send 方法發(fā)送消息時(shí)，消息不通過(guò)調(diào)度系統(tǒng)發(fā)送。
• 不限制任何對(duì)象既作為消息的發(fā)布者又作為消息的接收者。
• 不限制對(duì)象發(fā)送何種消息，任何對(duì)象都可以發(fā)送其業(yè)務(wù)規(guī)定的多種type的消息，一種消息就是一種type的 what。
• 不限制對(duì)象接收何種消息，任何對(duì)象都可以接收其業(yè)務(wù)規(guī)定的多種type的消息，一種消息就對(duì)應(yīng)一個(gè) where 來(lái)處理這個(gè)消息。

 

未完待續(xù)...