當前位置：首頁 > 前端技术 > javascript >内容正文

javascript

ESB学习笔记（Spring Integration实战）

發布時間：2024/4/17 javascript 45 豆豆

生活随笔收集整理的這篇文章主要介紹了 ESB学习笔记（Spring Integration实战）小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

http://wangleifire.iteye.com/blog/351749

介紹
Spring Integration是Spring公司的一套ESB框架。
前面ESB介紹中我也做了一定了解。我們來看一下它主要做什么的。
Spring Integration is motivated by the following goals:
- Provide a simple model for implementing complex enterprise integration solutions.(暫時相信它吧，誰讓它搞個Spring框架，的確給人方便一把。)
- Facilitate asynchronous, message-driven behavior within a Spring-based application.(這個不談，Spring框架就是它玩的。再說這一點與它競爭只有Mule啦。)
- Promote intuitive, incremental adoption for existing Spring users. (也暫時相信它，別人都只說給用戶提升。)
Spring Integration is guided by the following principles:
- Components should be loosely coupled for modularity and testability.（松耦合，好像很早很早就聽說過。像做夢一樣）
- The framework should enforce separation of concerns between business logic and integration logic.（分開程度要取決業務吧。）
- Extension points should be abstract in nature but within well-defined boundaries to promote reuse and portability.（美妙現實世界產品）
源碼下載打開它的網頁，http://www.springsource.org/spring-integration
主頁上也沒有東東，但有個下源代碼的地方，svn開工啦。
Java代碼
svn?co?https://src.springframework.org/svn/spring-integration/trunk??springintegration???
下載完后，進入build-spring-integration目錄執行ant.完成后，導入到Eclipse中。
導入項目會有很多，先添加時會有報錯。這里需要添加一個變量。
IVY_CACHE＝<checkout-dir>/ivy-cache/repository

這里要注意的事，也是我遇到問題。執行ant時，他會去下載lvy，如果你本身在%ANT_HOME%\lib里有lvy.jar包，由于我暫時找不到如何處理，我就直接將Ant中的jar刪除掉后就沒有問題。
另外在ant過程中，測試步驟可能會在file模塊中出現問題，可以將相關test類中代碼注釋掉。
HelloWorld源碼分析在samples項目中，打開helloworld包里面有三個文件。
Java代碼
package?org.springframework.integration.samples.helloworld; ??
??
/** ?
?*?@author?Mark?Fisher ?
?*/??
public?class?HelloService?{ ??
??
????public?String?sayHello(String?name)?{ ??
????????return?"Hello?"?+?name; ??
????} ??
??
}??

<?xml?version="1.0"?encoding="UTF-8"?>??
<beans:beans?xmlns="http://www.springframework.org/schema/integration"??
????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"??
????xmlns:beans="http://www.springframework.org/schema/beans"??
????xsi:schemaLocation="http://www.springframework.org/schema/beans ??
????????????http://www.springframework.org/schema/beans/spring-beans-2.5.xsd ??
????????????http://www.springframework.org/schema/integration ??
????????????http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">??
??
????<channel?id="inputChannel"/>??
??
????<channel?id="outputChannel">??
????????<queue?capacity="10"/>??
????</channel>??
??
????<service-activator?input-channel="inputChannel"??
???????????????????????output-channel="outputChannel"??
???????????????????????ref="helloService"??
???????????????????????method="sayHello"/>??
??
????<beans:bean?id="helloService"?class="org.springframework.integration.samples.helloworld.HelloService"/>??
</beans:beans>??

HelloWorldDemo.java

package?org.springframework.integration.samples.helloworld; ??
??
import?org.springframework.context.support.AbstractApplicationContext; ??
import?org.springframework.context.support.ClassPathXmlApplicationContext; ??
import?org.springframework.integration.channel.BeanFactoryChannelResolver; ??
import?org.springframework.integration.channel.ChannelResolver; ??
import?org.springframework.integration.channel.PollableChannel; ??
import?org.springframework.integration.core.MessageChannel; ??
import?org.springframework.integration.message.StringMessage; ??
??
/** ?
?*?Demonstrates?a?basic?message?endpoint.? ?
?*? ?
?*?@author?Mark?Fisher ?
?*/??
public?class?HelloWorldDemo?{ ??
??
????public?static?void?main(String[]?args)?{ ??
????????AbstractApplicationContext?context?=?new?ClassPathXmlApplicationContext("helloWorldDemo.xml",?HelloWorldDemo.class); ??
????????ChannelResolver?channelResolver?=?new?BeanFactoryChannelResolver(context); ??
????????MessageChannel?inputChannel?=?channelResolver.resolveChannelName("inputChannel"); ??
????????PollableChannel?outputChannel?=?(PollableChannel)?channelResolver.resolveChannelName("outputChannel"); ??
????????inputChannel.send(new?StringMessage("World")); ??
????????System.out.println(outputChannel.receive(0).getPayload()); ??
????????context.stop(); ??
????} ??
??
}??

Cafe源碼分析 Cafe示例描述的是星巴克的訂單處理故事。
其示例描述在：http://www.enterpriseintegrationpatterns.com/ramblings/18_starbucks.html
這里簡單描述一下，以免大家看英文太累
文章講在星巴克喝咖啡時，收銀員可能只有一個，而沖咖啡員工會有多個，如何讓收銀員產生訂單異步發送給沖咖啡員工。并且沖咖啡員工可能是競爭上崗的，就當他們是計件工吧。
這里要考慮問題：
1，沖咖啡員工使用不同設備，不同咖啡沖調時間可能不同。　
2，沖咖啡員工可能會將相同類型的咖啡同時一起沖調。
星巴克如何處理這個問題？
就當他解決了這個問題，它是如何把每個咖啡又送回給每個客戶呢？當然，星巴克采用“標識關系模式”，將每個咖啡杯上標上名稱，并通過叫喊方式。
但并不是每天都是美好的，總有出錯的時候。例如，收銀員無法支付？沖調一杯你不喜歡的咖啡，你要換一杯？沖咖啡的設備壞了，星巴克要退你錢...這些異常情況如何處理。
因此就會有以下三種方式異常處理：
1,關閉交易，什么都不做。
2,重做，重新發起行為。
3,修正行為,相當于退錢這種行為。
因此，這里這篇文章后面討論一下兩階段提交為什么不適合星巴克，如果你讓收銀員、沖咖啡員工，買單的人需要在一個“事務”中，交易所有完成后，再進行下一個業務。估計星巴克會馬上倒閉啦。因此星巴克采用“Conversation pattern”模式。

好啦，業務了解清楚，我們再來看一下完整XML文件。在這里我沒有采用示例詳細的xml方式，而沒有采用annotation方式。

<?xml?version="1.0"?encoding="UTF-8"?>??
<beans:beans?xmlns="http://www.springframework.org/schema/integration"??
????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"??
????xmlns:beans="http://www.springframework.org/schema/beans"??
????xmlns:stream="http://www.springframework.org/schema/integration/stream"??
????xsi:schemaLocation="http://www.springframework.org/schema/beans ??
????????????http://www.springframework.org/schema/beans/spring-beans-2.5.xsd ??
????????????http://www.springframework.org/schema/integration ??
????????????http://www.springframework.org/schema/integration/spring-integration-1.0.xsd ??
????????????http://www.springframework.org/schema/integration/stream ??
????????????http://www.springframework.org/schema/integration/stream/spring-integration-stream-1.0.xsd">??
??
????<gateway?id="cafe"?service-interface="org.springframework.integration.samples.cafe.Cafe"/>??
??
????<channel?id="orders"/>??
????<splitter?input-channel="orders"?ref="orderSplitter"?method="split"?output-channel="drinks"/>??
??
????<channel?id="drinks"/>??
????<router?input-channel="drinks"?ref="drinkRouter"?method="resolveOrderItemChannel"/>??
??
????<channel?id="coldDrinks">??
????????<queue?capacity="10"/>??
????</channel>??
????<service-activator?input-channel="coldDrinks"?ref="barista"??
???????????????????????method="prepareColdDrink"?output-channel="preparedDrinks"/>??
??
????<channel?id="hotDrinks">??
????????<queue?capacity="10"/>??
????</channel>??
????<service-activator?input-channel="hotDrinks"?ref="barista"??
???????????????????????method="prepareHotDrink"?output-channel="preparedDrinks"/>??
??
????<channel?id="preparedDrinks"/>??
????<aggregator?input-channel="preparedDrinks"?ref="waiter"??
????????????????method="prepareDelivery"?output-channel="deliveries"/>??
??
????<stream:stdout-channel-adapter?id="deliveries"/>??
??
????<beans:bean?id="orderSplitter"??
????????????????class="org.springframework.integration.samples.cafe.xml.OrderSplitter"/>??
??
????<beans:bean?id="drinkRouter"??
????????????????class="org.springframework.integration.samples.cafe.xml.DrinkRouter"/>??
??
????<beans:bean?id="barista"?class="org.springframework.integration.samples.cafe.xml.Barista"/>??
??
????<beans:bean?id="waiter"?class="org.springframework.integration.samples.cafe.xml.Waiter"/>??
??
????<poller?id="poller"?default="true">??
????????<interval-trigger?interval="1000"/>??
????</poller>??
??
</beans:beans>??

以下是參考文檔中的示例描述圖：

CafeDemo代碼創建了訂單。這家咖啡店有兩種飲料，一種是熱的，一種是冷的，消息將這訂單包裝到一個"orders"的channel（頻道）。一個endpoint偵聽到訂單頻道并根據訂單情況進行分開處理。

完成分開處理后，程序交給DrinksRouter經過drink頻道。而DrinkRouter一個職責就是將訂單內容中的熱咖啡和冷咖啡交給不同的channel處理。

<gateway?id="cafe"?service-interface="org.springframework.integration.samples.cafe.Cafe"/>??

這里Gateway主要是根據接口生成代理類。

Cafe?cafe?=?(Cafe)?context.getBean("cafe"); ??
????????????????DrinkOrder?order?=?new?DrinkOrder(); ??
????????????????Drink?hotDoubleLatte?=?new?Drink(DrinkType.LATTE,?2,?false); ??
????????????????Drink?icedTripleMocha?=?new?Drink(DrinkType.MOCHA,?3,?true); ??
????????????????order.addDrink(hotDoubleLatte); ??
????????????????order.addDrink(icedTripleMocha); ??
????????????????for?(int?i?=?0;?i?<?100;?i++)?{ ??
????????????????????????cafe.placeOrder(order); ??
????????????????}?
@MessageEndpoint(input="orders",?output="drinks") ??
public?class?OrderSplitter?{ ??
??
????????@Splitter??
????????public?List<Drink>?split(Message<DrinkOrder>?orderMessage)?{ ??
????????????????return?orderMessage.getPayload().getDrinks(); ??
????????} ??
??
}??
@MessageEndpoint(input="drinks") ??
public?class?DrinkRouter?{ ??
??
????????@Router??
????????public?String?resolveDrinkChannel(Drink?drink)?{ ??
????????????????return?(drink.isIced())???"coldDrinks"?:?"hotDrinks"; ??
????????} ??
??
}??
<handler-endpoint?handler="coldBarista"?input-channel="coldDrinks"??
????????method="prepareColdDrink">??
</handler-endpoint>??
??
<handler-endpoint?handler="hotBarista"?input-channel="hotDrinks"??
????????method="prepareHotDrink">??
</handler-endpoint>??
public?void?prepareColdDrink(Message<Drink>?drinkMessage)?{ ??
????????????????Drink?drink?=?drinkMessage.getPayload(); ??
????????????????//no?changes?to?the?rest?of?the?code ??
????????}??

總結

以上是生活随笔為你收集整理的ESB学习笔记（Spring Integration实战）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： Sybase时间日期函数
下一篇： Common BeanUtils组件的使