ESB在實際項目中的應用
－－WebSphere Message Broker
【趙斌原創(chuàng)，保留一切權(quán)利，轉(zhuǎn)載請保留引用：www.blogjava.net/zhaobin，謝謝！】
1、 WebSphere Message Broker Introduction
a) ESB Overview
b) Message Broker Overview
c) Message Broker Performance Report
2、 ESB Project Sharing
1、 Message Broker是建立在MQ基礎之上的?！菊f明消息中間件對于MB是何等的重要，可靠的傳輸是前提、是基礎?！?p>2、 Business Integration Reference Architecture
上面是IBM的業(yè)務集成參考架構(gòu)，而下面的圖則用IBM的產(chǎn)品充滿了整個架構(gòu)。
3、 ESB所處的位置，作為連接層，組織服務請求方和服務提供方之間的信息
4、 ESB解決連接性問題
a) Decouple interfaces from application.【ESB可以從應用中解耦接口。注意：當前的項目中，總是在對付接口】
b) Enable all applications to communicate with each other regardless of
i. Programming languages
ii. System Platforms
iii. Programming models
iv. Protocols
v. Data formats
可以在以上5層無關性的前提下，應用程序互相通訊。
5、 What is Enterprise Service Bus (ESB)?
c) A flexible connectivity infrastructure for integrating applications and services.【一個柔性聯(lián)通基礎架構(gòu)，用于集成應用程序和服務?！?p>d) Used to reduce the number, size, and complexity of interfaces.【用于減少接口的數(shù)量、大小、復雜性】
6、 ESB的功能
e) Matches & routes (message between services)【原來應用系統(tǒng)是直連的，相互之間是知道對方存在的，是依賴于接口的】
f) Converts (transport protocols between requestor and service)【協(xié)議轉(zhuǎn)換】
g) Transforms (message format between requestor and service)【消息格式轉(zhuǎn)換】
h) Distributes (business events from/to disparate sources)【分發(fā)事件】
7、 ESB提供的通訊服務
i) 傳輸 （包括JMS消息和異步協(xié)議）
j) 事件
k) 中轉(zhuǎn)
8、 什么是Brokering ? （注意：數(shù)據(jù)的格式不一樣）
Broker愿意是經(jīng)紀人的意思，在這里可以理解為代理。
使用Message Broker之后，還可以很方便連接新的應用。
9、 Message Broker 產(chǎn)品家族
IBM劃分基礎產(chǎn)品和高端產(chǎn)品的方式可以學習。
10、 Message Broker核心概念
l) 消息處理（Message processing）
i. 處理消息中的獨立項
ii. 物理和邏輯消息模型
m) 轉(zhuǎn)換和路由（Transformation and Routing）
i. 消息操縱（Message Manipulation）【我理解為各種處理，類似于handle】
ii. 基于內(nèi)容的路由（Content based routing）
n) 簡單的，清晰的編程模式
i. 可視化編程模式：消息流
11、 Message Broker概況
從這個處理流程中，可以看出MB的基本功能：
1） 收到并路由消息
2） 轉(zhuǎn)換消息到另一格式，或者到多個其他格式
3） 給訂閱者發(fā)布一個消息
4） 訪問外部數(shù)據(jù)庫處理增量消息或存儲
5） 應答事件和錯誤
12、 MB的組件――部署時
Broker 有Domain的概念，另外Message sets和Message flow都運行在Broker之內(nèi)，多個Broker部署在同一個Broker Domain內(nèi)，在同一個Domain內(nèi)通過Configuration來進行配置。
13、 MB的組件――運行時
1） Broker（消息代理）：是MB的消息處理引擎，它提供MB的所有運行時服務。
2） Configuration Manager（配置管理器）：CM是工作臺，配置存儲庫和Broker之間的一個接口，它維護Broker Domain的配置信息，向Broker提供初始化配置信息以及之后的變化信息。配置管理器是MB用于管理那些組成Broker Domain的全部部件和資源的核心運行時部件。
3） Broker Domain（消息代理域）：共享相同配置的若干Broker組成一個消息代理域，每個消息代理域由一個唯一的配置管理器來控制，在一個消息代理域中，可以創(chuàng)建、啟動一個或多個Broker，和一個可選的User Name Server。
4） Execution Group（執(zhí)行組）：執(zhí)行組是若干消息流的組合，是消息流運行引擎。每個執(zhí)行組是一個獨立的進程，這樣，在同一個執(zhí)行組中的消息流可以做到在運行時相互獨立。在一個執(zhí)行組內(nèi)部，消息流在不同的線程池內(nèi)運行，為了提高性能，我們可以通過設置每個消息流的運行實例的個數(shù)來指定每個消息流的線程池的大小。
5） User Name Server（用戶名稱服務器）：任何關鍵系統(tǒng)的一個重要的組成部分就是通過提供一個有效的安全機制來確保資產(chǎn)安全的能力。用戶名稱服務器是可選的運行時組件，它提供Publish/Subscribe操作相關的用戶和組的安全控制。
6） Message Flow（消息流）：在MB中對消息的運算處理、格式轉(zhuǎn)換和路由等功能是通過消息流實現(xiàn)的，每個消息從輸入MB到從MB中輸出，都將被一個消息流處理，然后發(fā)往目的應用系統(tǒng)。消息流由各種消息處理節(jié)點（Message Processing Node）組成，消息處理節(jié)點可對消息進行各種處理操作，節(jié)點與節(jié)點相連，便組成了一個消息流。
7） Message Processing Node（消息處理節(jié)點）：在MB中，對消息的所有計算和處理是通過消息節(jié)點實現(xiàn)的，消息節(jié)點實際上是被Broker運行環(huán)境調(diào)用的動態(tài)鏈接庫（DLL），通過ESQL語句對消息進行操作，通過對消息節(jié)點屬性的客戶華處理，將使節(jié)點能夠?qū)α鹘?jīng)自己的消息執(zhí)行特定的功能。
8） ESQL：在MB中，消息流開發(fā)使用的使ESQL語言。ESQL是對SQL V3的擴展，除了用于數(shù)據(jù)庫的操作之外，它還可以操作消息數(shù)據(jù)，包括Generic XML和MRM格式的消息。
14、 Message Flows【簡直就是針對消息的工作流】
15、 Message Processing Nodes （6.0在此基礎上又有增加）
從我的觀點來分析，最重要的節(jié)點：
a) MQInput & MQOutput
b) HttpInput 可以做WS服務，HttpRequest可以去訪問WS
c) Publication 用于發(fā)布
d) ESQL語句節(jié)點，可以用于手工寫ESQL，屬于萬能的節(jié)點。
e) Mapping，消息到消息和消息到DB的映射
f) Filter， 實現(xiàn)if-else。返回4種狀態(tài)：failer，true，false，unknow。
g) RouteToLaber配合Label，相當與case語句。
h) TryCatch 和Throw
i) Trace，用于打印調(diào)試信息。MB也提供命令行調(diào)試方式。
j) Aggregate Request、Reply、Control，聚合
新版本中增加了
a) Timer節(jié)點
b) JMS節(jié)點
16、 MB Toolkit
17、 ESQL editor
18、 Message Set Development
19、 Mapping editor
20、 Deployment
MB需要打包成bar包，這具有更強的靈活性，更高的性能，當然要稍微麻煩一些。自己開發(fā)的產(chǎn)品，打包、部署一定要簡單，最好能支持熱部署。
21、 mqsideploy 命令行部署工具，較大型的項目，需要做開發(fā)環(huán)境、測試環(huán)境、聯(lián)調(diào)環(huán)境、生產(chǎn)環(huán)境等。生成腳本可以多次執(zhí)行。這就是大型軟件和一般軟件的區(qū)別之一。
22、 MB性能報告
4160 個 1KB的包/秒，建議交易用的包在1—2K。
MQ消息持久，是指寫文件，保證服務宕機的情況下消息的完整性。而非持久性能更高。
比如：銀行ATM最大等待時間60妙，超時后消息本身就沒有意義，可以選擇非持久。
23、 MQInput/MQOutput消息流的基準值
24、 Parallel Processing Option
MB可以通過多instance或者多執(zhí)行組來并行，具體哪個效果更好，看具體應用的情況。
【趙斌原創(chuàng)，保留一切權(quán)利，轉(zhuǎn)載請保留引用：www.blogjava.net/zhaobin，謝謝！】
