原文地址： http://www.theserverside.com/tt/articles/article.tss?l=CaseStudyMule
面向服務(wù)架構(gòu)的關(guān)鍵字之一就是ESB。以前很多廠商靠買消息服務(wù)器來提供集成交互的方案，然后出現(xiàn)了SOAP和REST。
早期的嘗試基本上都是通過定一個(gè)固定的消息格式，例如xml來讓各個(gè)系統(tǒng)交換。但是這些消息格式本身經(jīng)常需要修訂，就給集成帶來了很大的麻煩。
最好的解決方案就是每個(gè)應(yīng)用還是用自己支持的接口，例如EDI或者SOAP，然后構(gòu)建一個(gè)可以集成各種結(jié)構(gòu)的聚合器，每一個(gè)應(yīng)用的接口就開發(fā)成聚合器的一個(gè)端口。這樣一個(gè)cobol寫的應(yīng)用就可以和一個(gè)j2me的應(yīng)用交互，而不需要知道彼此的技術(shù)細(xì)節(jié)。
常見ESB供應(yīng)商比較
|
Product |
Vendor |
Connects with... |
|
Matrix BusinessWorks |
TIBCO |
SOAP, EMS, JMS, Rendezvous, MQ, BPEL |
|
Mule ESB |
Open-source, MuleSource, Inc. |
SOAP, REST, JMS, MQ, JBI, AQ, Caching, JavaSpaces, GigaSpaces, Email, IM, JCA, AS400 Data Queues, System I/O. |
|
OpenESB |
Open-source, Sun Microsystems |
JBI, JCA, JAX-RPC, JAX-WS |
|
Sonic ESB |
Progress Software |
JMS, SOAP, JMX |
|
Websphere ESB |
IBM |
JMS, MQ, SOAP; requires additional adapters to interface with other products and legacy protocols; requires Websphere to work |
這里少了一個(gè)ServiceMix。
下面是這個(gè)案例的細(xì)節(jié)：
本案例用到的程序包括：
假設(shè)有一個(gè)項(xiàng)目要集成很多企業(yè)級(jí)應(yīng)用程序，出于開發(fā)周期的壓力，我們選擇集成而非重新構(gòu)建的策略。也就是說order capture, inventory management, order management, fulfillment, and reporting 這些都購買現(xiàn)成的廠商的，我們只需要集中開發(fā)一個(gè)內(nèi)容管理系統(tǒng)。
通過和其它六家廠商的協(xié)商，他們都提供了JMS和SOAP的接口。因此我們需要一個(gè)專業(yè)的JMS服務(wù)器。
下面我們來看看配置文件：
connector name ="jmsConnector" className ="org.mule.providers.jms.JmsConnector" >
properties >
property name ="jndiProviderUrl"
value ="bitjmsnaming://172.28.63.209:7222" />
property name ="connectionFactoryJndiName"
value ="QueueConnectionFactory" />
map name ="jndiProviderProperties" >
property name ="java.naming.factory.initial"
value ="com.bitco.bitjms.naming.bitjmsInitialContextFactory" />
property name ="java.naming.security.principal" value ="admin" />
property name ="java.naming.security.credentials" value ="" />
map >
property name ="username" value ="admin" />
property name ="password" value ="" />
properties >
connector >
然后定義一些端點(diǎn)，每個(gè)端點(diǎn)都是一個(gè)外部供應(yīng)商程序的接口
global-endpoints >
endpoint name ="inJMSGTA" address ="jms://q.gta.in" connector ="jmsConnector" />
endpoint name ="inJMSSeebelle" address ="jms://q.seebelle.in" connector ="jmsConnector" />
endpoint name ="inJMSYenta" address ="jms://q.yenta.in" connector ="jmsConnector" />
endpoint name ="inJMSCatwire" address ="jms://q.catwire.in" connector ="jmsConnector" />
endpoint name ="inJMSBitco" address ="jms://q.bitco.in" connector ="jmsConnector" />
endpoint name ="outJMSGTA" address ="jms://q.gta.out" connector ="jmsConnector" />
endpoint name ="outJMSSeebelle" address ="jms://q.seebelle.out" connector ="jmsConnector" />
endpoint name ="outJMSYenta" address ="jms://q.yenta.out" connector ="jmsConnector" />
endpoint name ="outJMSCatwire" address ="jms://q.catwire.out" connector ="jmsConnector" />
endpoint name ="outJMSBitco" address ="jms://q.bitco.out" connector ="jmsConnector" />
endpoint name ="console" address ="stream://System.out" />
global-endpoints >
transformers >
transformer name ="JMSMessageToObject"
className ="org.mule.providers.jms.transformers.JMSMessageToObject" />
transformer name ="ObjectToString"
className ="org.mule.transformers.simple.ObjectToString" />
transformers >
model name ="Enterprise-Applications-Mashup-JMS" >
mule-descriptor name ="JMSMessageSwitchboard"
implementation ="org.mule.components.simple.PassThroughComponent" >
系統(tǒng)只有一個(gè)inbound，也就是進(jìn)入系統(tǒng)消息的定義，端口名稱叫做outJMSBitco，也就是說outJMSBitco發(fā)出一個(gè)指令，進(jìn)入總線，然后Mule把這個(gè)消息轉(zhuǎn)換后發(fā)送給其它所有的outbound-router，離開總線，進(jìn)入別的應(yīng)用程序。
inbound-router >
global-endpoint name ="outJMSBitco" />
inbound-router >
outbound-router match-all ="true" >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter"
expression ="OrderHistoryRequest" />
router >
這條路由的意思是，將消息通過JMS發(fā)送給Siebel，JMS的頭要標(biāo)上OrderHistoryResonse，這樣Siebel的消息隊(duì)列受到一條這個(gè)消息，Siebel知道對方要做什么操作，將OrderHistory查詢出來。
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSSiebel" />
filter className ="org.mule.samples.jms.JMSHeaderFilter"
expression ="OrderHistoryResponse" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSCatwire" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="item" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSCatwire" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="item_mapping" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="PAMInventoryUpdate" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSGTA" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="CustomerSearchRequest" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSSiebel" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="CustomerSearchResponse" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="OrderDetailsRequest" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSSiebel" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="OrderDetailsResponse" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="OrderAddUpdRequest" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSSiebel" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="OrderAddUpdResponse" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="catwireCreateItem" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSGTA" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="catalogupdate" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSGTA" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="productupdate" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSGTA" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="skuupdate" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="gtaCreateOrder" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSYenta" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="gtaGetOrderDetails" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="openJmsOutbound" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="XXXOrderUpdate" />
router >
router className ="org.mule.routing.outbound.FilteringOutboundRouter" >
global-endpoint name ="inJMSBitco" />
filter className ="org.mule.samples.jms.JMSHeaderFilter" expression ="OrderRelease" />
router >
這個(gè)端口的意思是把消息打印在DOS窗口上
router className ="org.mule.routing.outbound.OutboundPassThroughRouter" >
endpoint address ="stream://System.out" transformers ="ObjectToString" />
router >
outbound-router >
mule-descriptor >
model >
mule-configuration >
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1484134
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫作最大的動(dòng)力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長非常感激您！手機(jī)微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
