logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

ESB学习笔记（Spring Integration实战）

 gyb98 2011-03-16
ESB学习笔记（Spring Integration实战）
 

2009-11-23 来源：网络

 
  • 介绍 
    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./spring-integration 
    主页上也没有东东，但有个下源代码的地方，svn开工啦。 
    　
    Java代码 复制代码
    1. svn co https://src./svn/spring-integration/trunk  springintegration   
    svn co https://src./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代码 复制代码
    1. package org.springframework.integration.samples.helloworld;   
    2.   
    3. /**  
    4.  * @author Mark Fisher  
    5.  */  
    6. public class HelloService {   
    7.   
    8.     public String sayHello(String name) {   
    9.         return "Hello " + name;   
    10.     }   
    11.   
    12. }  
    package org.springframework.integration.samples.helloworld;

/**
 * @author Mark Fisher
 */
public class HelloService {

	public String sayHello(String name) {
		return "Hello " + name;
	}

}

    helloworldDemo.xml 
    　
    Xml代码 复制代码
    1. <?xml version="1.0" encoding="UTF-8"?>  
    2. <beans:beans xmlns="http://www./schema/integration"  
    3.     xmlns:xsi="http://www./2001/XMLSchema-instance"  
    4.     xmlns:beans="http://www./schema/beans"  
    5.     xsi:schemaLocation="http://www./schema/beans   
    6.             http://www./schema/beans/spring-beans-2.5.xsd   
    7.             http://www./schema/integration   
    8.             http://www./schema/integration/spring-integration-1.0.xsd">  
    9.   
    10.     <channel id="inputChannel"/>  
    11.   
    12.     <channel id="outputChannel">  
    13.         <queue capacity="10"/>  
    14.     </channel>  
    15.   
    16.     <service-activator input-channel="inputChannel"  
    17.                        output-channel="outputChannel"  
    18.                        ref="helloService"  
    19.                        method="sayHello"/>  
    20.   
    21.     <beans:bean id="helloService" class="org.springframework.integration.samples.helloworld.HelloService"/>  
    22. </beans:beans>  
    <?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www./schema/integration"
	xmlns:xsi="http://www./2001/XMLSchema-instance"
	xmlns:beans="http://www./schema/beans"
	xsi:schemaLocation="http://www./schema/beans
			http://www./schema/beans/spring-beans-2.5.xsd
			http://www./schema/integration
			http://www./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 
    　
    Java代码 复制代码
    1. package org.springframework.integration.samples.helloworld;   
    2.   
    3. import org.springframework.context.support.AbstractApplicationContext;   
    4. import org.springframework.context.support.ClassPathXmlApplicationContext;   
    5. import org.springframework.integration.channel.BeanFactoryChannelResolver;   
    6. import org.springframework.integration.channel.ChannelResolver;   
    7. import org.springframework.integration.channel.PollableChannel;   
    8. import org.springframework.integration.core.MessageChannel;   
    9. import org.springframework.integration.message.StringMessage;   
    10.   
    11. /**  
    12.  * Demonstrates a basic message endpoint.   
    13.  *   
    14.  * @author Mark Fisher  
    15.  */  
    16. public class HelloWorldDemo {   
    17.   
    18.     public static void main(String[] args) {   
    19.         AbstractApplicationContext context = new ClassPathXmlApplicationContext("helloWorldDemo.xml", HelloWorldDemo.class);   
    20.         ChannelResolver channelResolver = new BeanFactoryChannelResolver(context);   
    21.         MessageChannel inputChannel = channelResolver.resolveChannelName("inputChannel");   
    22.         PollableChannel outputChannel = (PollableChannel) channelResolver.resolveChannelName("outputChannel");   
    23.         inputChannel.send(new StringMessage("World"));   
    24.         System.out.println(outputChannel.receive(0).getPayload());   
    25.         context.stop();   
    26.     }   
    27.   
    28. }  
    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./ramblings/18_starbucks.html 
    这里简单描述一下，以免大家看英文太累 
    文章讲在星巴克喝咖啡时，收银员可能只有一个，而冲咖啡员工会有多个，如何让收银员产生订单异步发送给冲咖啡员工。并且冲咖啡员工可能是竞争上岗的，就当他们是计件工吧。 
    这里要考虑问题： 
    1，冲咖啡员工使用不同设备，不同咖啡冲调时间可能不同。　 
    2，冲咖啡员工可能会将相同类型的咖啡同时一起冲调。 
    星巴克如何处理这个问题？ 
    就当他解决了这个问题，它是如何把每个咖啡又送回给每个客户呢？当然，星巴克采用“标识关系模式”，将每个咖啡杯上标上名称，并通过叫喊方式。 
    但并不是每天都是美好的，总有出错的时候。例如，收银员无法支付？冲调一杯你不喜欢的咖啡，你要换一杯？冲咖啡的设备坏了，星巴克要退你钱...这些异常情况如何处理。 
    因此就会有以下三种方式异常处理： 
    1,关闭交易，什么都不做。 
    2,重做，重新发起行为。 
    3,修正行为,相当于退钱这种行为。 
    因此，这里这篇文章后面讨论一下两阶段提交为什么不适合星巴克，如果你让收银员、冲咖啡员工，买单的人需要在一个“事务”中，交易所有完成后，再进行下一个业务。估计星巴克会马上倒闭啦。因此星巴克采用“Conversation pattern”模式。 

    好啦，业务了解清楚，我们再来看一下完整XML文件。在这里我没有采用示例详细的xml方式，而没有采用annotation方式。 
    　
    以下是参考文档中的示例描述图： 

     

    CafeDemo代码创建了订单。这家咖啡店有两种饮料，一种是热的，一种是冷的，消息将这订单包装到一个"orders"的channel（频道）。一个endpoint侦听到订单频道并根据订单情况进行分开处理。 

    完成分开处理后，程序交给DrinksRouter经过drink频道。而DrinkRouter一个职责就是将订单内容中的热咖啡和冷咖啡交给不同的channel处理。 

    　
    Xml代码 复制代码
    1. <gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe"/>  
    	<gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe"/>

    这里Gateway主要是根据接口生成代理类。 

    　
    Java代码 复制代码
    1. Cafe cafe = (Cafe) context.getBean("cafe");   
    2.                 DrinkOrder order = new DrinkOrder();   
    3.                 Drink hotDoubleLatte = new Drink(DrinkType.LATTE, 2, false);   
    4.                 Drink icedTripleMocha = new Drink(DrinkType.MOCHA, 3, true);   
    5.                 order.addDrink(hotDoubleLatte);   
    6.                 order.addDrink(icedTripleMocha);   
    7.                 for (int i = 0; i < 100; i++) {   
    8.                         cafe.placeOrder(order);   
    9.                 }  
    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);
                }
    　
    Java代码 复制代码
    1. @MessageEndpoint(input="orders", output="drinks")   
    2. public class OrderSplitter {   
    3.   
    4.         @Splitter  
    5.         public List<Drink> split(Message<DrinkOrder> orderMessage) {   
    6.                 return orderMessage.getPayload().getDrinks();   
    7.         }   
    8.   
    9. }  
    @MessageEndpoint(input="orders", output="drinks")
public class OrderSplitter {

        @Splitter
        public List<Drink> split(Message<DrinkOrder> orderMessage) {
                return orderMessage.getPayload().getDrinks();
        }

}
    　
    Java代码 复制代码
    1. @MessageEndpoint(input="drinks")   
    2. public class DrinkRouter {   
    3.   
    4.         @Router  
    5.         public String resolveDrinkChannel(Drink drink) {   
    6.                 return (drink.isIced()) ? "coldDrinks" : "hotDrinks";   
    7.         }   
    8.   
    9. }  
    @MessageEndpoint(input="drinks")
public class DrinkRouter {

        @Router
        public String resolveDrinkChannel(Drink drink) {
                return (drink.isIced()) ? "coldDrinks" : "hotDrinks";
        }

}
    Xml代码 复制代码
    1. <handler-endpoint handler="coldBarista" input-channel="coldDrinks"  
    2.         method="prepareColdDrink">  
    3. </handler-endpoint>  
    4.   
    5. <handler-endpoint handler="hotBarista" input-channel="hotDrinks"  
    6.         method="prepareHotDrink">  
    7. </handler-endpoint>  
    <handler-endpoint handler="coldBarista" input-channel="coldDrinks"
        method="prepareColdDrink">
</handler-endpoint>

<handler-endpoint handler="hotBarista" input-channel="hotDrinks"
        method="prepareHotDrink">
</handler-endpoint>
    　
    Java代码 复制代码
    1. public void prepareColdDrink(Message<Drink> drinkMessage) {   
    2.                 Drink drink = drinkMessage.getPayload();   
    3.                 //no changes to the rest of the code   
    4.         }  
    		•

      本站是提供个人知识管理的网络存储空间，所有内容均由用户发布，不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息，谨防诈骗。如发现有害或侵权内容，请点击一键举报。
      转藏 分享 献花（0）

      来自： gyb98 > 《J2EE》

      举报/认领

      0条评论

      发表

      请遵守用户 评论公约

      类似文章 更多