Spring?Integration概述與怎么使用詳解

更新時間：2023年02月24日 09:17:49 作者：產(chǎn)教Code

公司項目需要用到spring integration,而網(wǎng)上關于spring integration的有價值的參考資料比較少,下面這篇文章主要給大家介紹了關于Spring?Integration概述與怎么使用的相關資料,需要的朋友可以參考下

一、Spring Integration是什么？

spring-integration是一個功能強大的EIP(Enterprise Integration Patterns)，即企業(yè)集成模式。多個系統(tǒng)或者功能，少不了消息交互，Spring intergration的出現(xiàn)解決了系統(tǒng)與系統(tǒng)之間的功能之間消息交互的問題。

二、為什么要用Spring Integration？

目標和原則

Spring集成的動機是以下目標：

為實現(xiàn)復雜的企業(yè)集成解決方案提供一個簡單的模型。
在基于Spring的應用程序中促進異步、消息驅動的行為。

促進對現(xiàn)有Spring用戶的直觀、增量采用。

Spring集成遵循以下原則：

為了模塊化和可測試性，組件應該是松散耦合的。
框架應該執(zhí)行業(yè)務邏輯和集成邏輯之間的關注點分離。
擴展點在本質上應該是抽象的(但在定義良好的邊界內)，以促進重用和可移植性。

三、怎么使用

我們首先看一下它的核心api

1. Message

Message，用來傳輸消息體的對象，所有的流程都圍繞著Message運轉。Message分為兩部分，header和payload。header是頭部信息通常用來保存如Id，時間戳，相關Id和返回地址等信息。payload是用來裝載數(shù)據(jù)的，它可以攜帶的任何類型對象。

2.MessageChannel

消息通道表示管道和過濾器體系結構的“管道”。生產(chǎn)者向通道發(fā)送消息，消費者從通道接收消息。因此，消息通道對消息傳遞組件進行了解耦，并提供了一個方便的點來攔截和監(jiān)視消息。

（1）MessageChannel頂級接口

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

發(fā)送消息時，返回值是true消息發(fā)送成功。如果發(fā)送呼叫超時或被中斷，它將返回false。

（2）PollableChannel，MessageChannel的子接口

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

此消息通道會緩存消息（可輪詢），與send方法一樣，當接收到消息時，如果發(fā)生超時或中斷，則返回值為null。

（3）SubscribableChannel，MessageChannel的子接口

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

因為SubscribableChannel基本接口是由將消息直接發(fā)送到其訂閱的頻道實施MessageHandler的實例，因此消息通道不會緩存消息。

3.Message Endpoint

（1）Message Router

路由器，用來管理一個消息應該被發(fā)送到哪個channel中。相當于JAVA里面的switch case語句吧。判斷條件很多，可是使用header里面的參數(shù)具體值（比如header里面有個定義為testRouter的參數(shù)，數(shù)值為A，那么消息經(jīng)過路由會發(fā)送到判斷為A的通道內，后面使用中再詳細講解）

（2）Message Filter

過濾器，用來判斷一個消息是否應該被傳輸。

（3）Service Activator

服務激活器是用于將服務實例連接到消息傳遞系統(tǒng)的通用端點。必須配置輸入消息通道，并且，如果要調用的服務方法能夠返回值，則還可以提供輸出消息通道。

（4）Message Transformer

消息轉換器負責轉換消息的內容或結構并返回修改后的消息。可能最常見的一種轉換器是將消息的有效負載從一種格式轉換為另一種格式（例如，從XML轉換為java.lang.String）的一種。同樣，轉換器可以添加，刪除或修改消息的標頭值。

（5） Channel Adapter

通道適配器是將消息通道連接到其他系統(tǒng)或傳輸?shù)慕K結點。通道適配器可以是入站的或出站的。通常，通道適配器在消息與從其他系統(tǒng)接收或發(fā)送到其他系統(tǒng)的任何對象或資源（文件，HTTP請求，JMS消息等）之間進行一些映射。根據(jù)傳輸情況，通道適配器還可以填充或提取消息頭值。