Spring Integration概述与怎么使用详解

目录

• 一、Spring Integration是什么？
• 二、为什么要用Spring Integration？
• 三、怎么使用
• 总结

一、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

消息通道表示管道和过滤器体系结构的“管道”。生产者向通道发送消息，消费者从通道接收消息。因此，消息通道对消息传递组件进行了解耦，并提供了一个方便的点来拦截和监视消息。

（1）MessageChannel顶级接口

public interface MessageChannel {
boolean send(Message message);
boolean send(Message message, long timeout);
}

发送消息时，返回值是true消息发送成功。如果发送呼叫超时或被中断，它将返回false。

（2）PollableChannel，MessageChannel的子接口

public interface PollableChannel extends MessageChannel {
    Message<?> receive();
    Message<?> receive(long timeout);
}

此消息通道会缓存消息（可轮询），与send方法一样，当接收到消息时，如果发生超时或中断，则返回值为null。

（3）SubscribableChannel，MessageChannel的子接口

public interface SubscribableChannel extends MessageChannel {
    boolean subscribe(MessageHandler handler);
    boolean unsubscribe(MessageHandler handler);
}

因为SubscribableChannel基本接口是由将消息直接发送到其订阅的频道实施MessageHandler的实例，因此消息通道不会缓存消息。

3.Message Endpoint

（1）Message Router

 路由器，用来管理一个消息应该被发送到哪个channel中。相当于JAVA里面的switch case语句吧。判断条件很多，可是使用header里面的参数具体值（比如header里面有个定义为testRouter的参数，数值为A，那么消息经过路由会发送到判断为A的通道内，后面使用中再详细讲解）

（2）Message Filter

过滤器，用来判断一个消息是否应该被传输。

（3）Service Activator

服务激活器是用于将服务实例连接到消息传递系统的通用端点。必须配置输入消息通道，并且，如果要调用的服务方法能够返回值，则还可以提供输出消息通道。

（4）Message Transformer

消息转换器负责转换消息的内容或结构并返回修改后的消息。可能最常见的一种转换器是将消息的有效负载从一种格式转换为另一种格式（例如，从XML转换为java.lang.String）的一种。同样，转换器可以添加，删除或修改消息的标头值。

（5） Channel Adapter

通道适配器是将消息通道连接到其他系统或传输的终结点。通道适配器可以是入站的或出站的。通常，通道适配器在消息与从其他系统接收或发送到其他系统的任何对象或资源（文件，HTTP请求，JMS消息等）之间进行一些映射。根据传输情况，通道适配器还可以填充或提取消息头值。

入站通道适配器端点将源系统连接到MessageChannel。

出站通道适配器端点将a连接MessageChannel到目标系统。

总结