在前面的關鍵組件中我們提到了Messages。當兩個應用想要交換數據,他們將數據包裝在一個message中。但是一個Message Channel不能傳輸原始數據,它只能傳輸包含在一個message中的數據(即傳輸特定格式的數據)。
Message在消息系統中處于信息載體的位置,而在ESB中,還消息識別、序列以及生存周期等職責。
Message的結構涉及以下幾個模式:
l Command Message
l Document Message
l Event Message
l Request-Reply
l Return Address
l Correlation Identifier
l Message Sequence
l Message Expiration
l Format Indicator
創建和發送一個Message產生以下幾個問題:
消息意圖 - Message最終是為了運送一些數據,但是發送者可能有其他目的,比如它希望接受者使用消息做些事情。它可以發送一個Command Message,指定它希望調用的接受者上的函數或方法。發送者告訴接受者運行那些代碼。發送者可以發送一個Document Message來傳送它的數據結構到接受者。發送者發送數據到接受者,但是不指定接受者應該做什么。
或者它可以發送一個Event Message,通知接受者發送者那里有一個改變。發送者不應告訴接受者應該怎樣適應這個改變,而只應提供通知。
返回一個應答 - 當一個應用發送一個消息,它通常期望得到一個回應來確定消息被處理并提供一個結果。這是一個Request-Reply場景。Request通常是一個Command Message,而應答是一個包含返回值或異常的Document Message。請求者應該在請求中指定一個Return Address來告訴應答者使用哪個通道來傳回應答。請求者可能在一個處理過程中發送多個請求,所以應答應該包含一個Correlation Identifier來指出這個應答對應哪個請求。
有兩個Request-Reply場景需要注意;它們都包含了一個Command Message請求和一個對應的Document Message應答。在第一個場景中,Message RPC,請求不但要調用應答者的函數,而且期望一個返回值。這是RPC。另一個場景中,Message Query,請求者執行一個查詢;應答者執行查詢并在應答中返回結果。這是遠程查詢。
大量的數據 - 有時應用想要傳送大量的數據結構,放入一個單獨的message里面不是很合適。在這種情況下,將他們分解成可管理的消息塊并將他們作為Message Sequence發送。這些消息必須按順序發送,以便接受者能夠充足原始數據結構。
慢速消息 - 消息系統的一個問題是發送者通常不知道接受者要多久才能接受到消息。然而,消息的內容可能是時間敏感的,所以如果消息在某一時間內沒有被接受,它將被忽略并取消。在這種情況下,sender應該使用Message Expiration來指定一個到期時間。如果消息系統在規定時間內無法傳輸一個消息,應該將它取消并刪除到Dead Letter Channel中。同樣的一個receiver接受到一個超出該時間點的消息,也要取消該消息。
總之,只選擇使用消息是不夠的。使一個消息工作的其他決定性因素來自于消息所要完成的任務。