一開始，接觸Spring Inategration，“額，新東西”，記得在學校的時候，只學過Spring，而且學得很淺，馬丹，有點小後悔以前沒有吃透這一塊。（而且做其他專案，能用C++，表示沒用過Java，大概C++比較順手吧）

現在切入正題。

Spring Integration (後面簡稱SI）

SI就是Spring大類的一種，其實還有Spring Boot，Spring For Andoria,Spring Batch等等。。。現在發現這世界真大，原來以前只是接觸而已，並沒發現裡面的廣博，以後還要任重而道遠。

SI是一個功能強大的EIP（Enterprise Intergration Patterns，即企業整合模式）。目前截止2017年11月底，SI5.0釋出了。

介紹一些SI的實體。

1.Message

主要分成兩部分，分別是header和payload。

package org.springframework.integration;
public interface Message<T> {
MessageHeaders getHeaders();
T getPayload();
}

package org.springframework.integration;
public final class MessageHeaders
implements Map<String, Object>, Serializable {
/* implementation omitted */
}
 

那麼如何建立Message呢？

Message<String> helloMessage =
MessageBuilder.withPayload("Hello, world!")
.setHeader("custom.header", "Value")
.setHeaderIfAbsent("custom.header2", "Value2")
.build();

2.Message Channel

主要用於傳遞message。

那麼message如何進入channel呢？

package org.springframework.integration;
public interface MessageChannel {
boolean send(Message<?> message);
boolean send(Message<?> message, long timeout);
}
 

對於PublishSubscribeChannel，用於釋出訂閱

package org.springframework.integration.core;
public interface SubscribableChannel extends MessageChannel {
boolean subscribe(MessageHandler handler);
boolean unsubscribe(MessageHandler handler);
}

對於PollableChannel，用於接收message

public interface PollableChannel extends MessageChannel {

    Message<?> receive();

    Message<?> receive(long timeout);

}

3.Message Point

3.1channel adapter

用於與外部資料交換的介面卡。連線應用與訊息系統。

3.2message gateway

用於與外部資料的雙向傳輸。

3.3service activator

根據傳入的訊息呼叫服務，根據其返回值，調用出站訊息呼叫服務