快捷導(dǎo)航

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

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

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

一、Spring Integration是什么？

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

二、為什么要用Spring Integration？

目標(biāo)和原則

Spring集成的動(dòng)機(jī)是以下目標(biāo)：

為實(shí)現(xiàn)復(fù)雜的企業(yè)集成解決方案提供一個(gè)簡(jiǎn)單的模型。
在基于Spring的應(yīng)用程序中促進(jìn)異步、消息驅(qū)動(dòng)的行為。

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

Spring集成遵循以下原則：

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

三、怎么使用

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

1. Message

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

2.MessageChannel

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

（1）MessageChannel頂級(jí)接口

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

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

（2）PollableChannel，MessageChannel的子接口

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

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

（3）SubscribableChannel，MessageChannel的子接口

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

因?yàn)镾ubscribableChannel基本接口是由將消息直接發(fā)送到其訂閱的頻道實(shí)施MessageHandler的實(shí)例，因此消息通道不會(huì)緩存消息。

3.Message Endpoint

（1）Message Router

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

（2）Message Filter

過濾器，用來(lái)判斷一個(gè)消息是否應(yīng)該被傳輸。

（3）Service Activator

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

（4）Message Transformer

消息轉(zhuǎn)換器負(fù)責(zé)轉(zhuǎn)換消息的內(nèi)容或結(jié)構(gòu)并返回修改后的消息?？赡茏畛Ｒ姷囊环N轉(zhuǎn)換器是將消息的有效負(fù)載從一種格式轉(zhuǎn)換為另一種格式（例如，從XML轉(zhuǎn)換為java.lang.String）的一種。同樣，轉(zhuǎn)換器可以添加，刪除或修改消息的標(biāo)頭值。

（5） Channel Adapter

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