一、Spring Integration是什么?
spring-integration是一个功能强大的EIP(Enterprise Integration Patterns),即企业集成模式。多个系统或者功能,少不了消息交互 ,Spring intergration的出现解决了系统与系统之间的功能之间消息交互的问题。
二、为什么要用Spring Integration?
目标和原则
Spring集成的动机是以下目标:
为实现复杂的企业集成解决方案提供一个简单的模型。
在基于Spring的应用程序中促进异步、消息驱动的行为。
促进对现有Spring用户的直观、增量采用。
Spring集成遵循以下原则:
为了模块化和可测试性,组件应该是松散耦合的。
框架应该执行业务逻辑和集成逻辑之间的关注点分离。
扩展点在本质上应该是抽象的(但在定义良好的边界内),以促进重用和可移植性。
三、怎么使用
我们首先看一下它的核心api
1. Message
Message,用来传输消息体的对象,所有的流程都围绕着Message运转。Message分为两部分,header和payload。header是头部信息通常用来保存如Id,时间戳,相关Id和返回地址等信息。payload是用来装载数据的,它可以携带的任何类型对象。
2.MessageChannel
消息通道表示管道和过滤器体系结构的“管道”。生产者向通道发送消息,消费者从通道接收消息。因此,消息通道对消息传递组件进行了解耦,并提供了一个方便的点来拦截和监视消息。
public interface MessageChannel {
boolean send(Message message);
boolean send(Message message, long timeout);
}
public interface PollableChannel extends MessageChannel {
Message<?> receive();
Message<?> receive(long timeout);
}
public interface SubscribableChannel extends MessageChannel {
boolean subscribe(MessageHandler handler);
boolean unsubscribe(MessageHandler handler);
}
路由器,用来管理一个消息应该被发送到哪个channel中。相当于JAVA里面的switch case语句吧。判断条件很多,可是使用header里面的参数具体值(比如header里面有个定义为testRouter的参数,数值为A,那么消息经过路由会发送到判断为A的通道内,后面使用中再详细讲解)