在我最近的帖子中，我提到 Spring Integration 的 Subversion 儲存庫很快就會公開訪問，我很高興現在提供該連結。您可以使用以下命令檢出該專案

svn co https://anonsvn.springframework.org/svn/spring-integration/base/trunk spring-integration

如果檢出成功，您應該看到以下目錄結構

spring-integration/
  +--build-spring-integration/
  +--spring-build/
  +--spring-integration-core/
  +--spring-integration-samples/

我想借此機會介紹一下 'spring-integration-samples' 中的幾個示例。 請記住，此專案絕對是一個正在進行中的工作（目前是 0.5 SNAPSHOT），但這些示例應該讓您瞭解程式設計模型是如何形成的，我非常期待收到一些反饋。

Hello World

第一個示例是強制性的“Hello World”演示。 這演示了主要元件：訊息通道和訊息端點。 此演示還揭示了 Spring Integration 方法是如何非侵入性的 - 在業務邏輯和訊息傳遞之間提供完全的分離。 在這種情況下，“業務邏輯”是一個簡單的 HelloService

public class HelloService {

    public String sayHello(String name) {
        return "Hello " + name;
    }
}

此示例使用基於 XML 的配置來配置訊息端點（我們接下來將看到註解方法）

<endpoint input-channel="inputChannel"
               default-output-channel="outputChannel"
               handler-ref="helloService"
               handler-method="sayHello"/>

您會看到“handler-ref”只是指向一個 Spring 管理的 bean。 如果您已經使用 Spring 的 MessageListenerAdapter 進行非同步 JMS 接收，那麼這應該看起來很熟悉 - 特別是如果您正在使用 Spring 2.5 的新 jms 名稱空間和“jms:listener”元素。 最後，HelloWorldDemo 啟動應用程式上下文，然後與通道互動

ChannelRegistry channelRegistry = (ChannelRegistry) context.getBean(MessageBusParser.MESSAGE_BUS_BEAN_NAME);
MessageChannel inputChannel = channelRegistry.lookupChannel("inputChannel");
MessageChannel outputChannel = channelRegistry.lookupChannel("outputChannel");
inputChannel.send(new StringMessage(1, "World"));
System.out.println(outputChannel.receive().getPayload());

該示例涉及查詢 MessageBus bean - 它實現了 ChannelRegistry 介面。 但是，在非演示“真實世界”場景中，任何訪問通道的元件都可以透過依賴注入提供登錄檔。 它所需要做的就是實現 ChannelRegistryAware（或使用 @Autowired）。 這與 Spring 中其他地方使用的方法相同 - 例如 ApplicationEventPublisherAware。

註解驅動的端點和訂閱者

下一個示例展示瞭如何使用註解配置訊息端點。 事實上，這個特定的端點甚至提供了資料，這些資料（在幕後）使用 @Polled 方法註解轉換為訊息有效負載內容。 它可以選擇為非同步接收訊息提供輸入通道。

@MessageEndpoint(defaultOutput="quotes")
public class QuotePublisher {

    @Polled(period=300)
    public Quote getQuote() {
        BigDecimal price = new BigDecimal(new Random().nextDouble() * 100);
        return new Quote(generateTicker(), price.setScale(2, RoundingMode.HALF_EVEN));
    }

    private String generateTicker() {
        // randomly generates 3-letter tickers
    }
}

在接收端，有一個 @Subscriber 註解

public class QuoteSubscriber {

    @Subscriber(channel="quotes")
    public void log(Object o) {
        System.out.println(o);
    }
}

這是註冊註解後處理器和 2 個 Spring 管理的 bean 的 XML（請注意，此示例使用 'spring-integration' schema 作為主要名稱空間。

<beans:beans xmlns="http://www.springframework.org/schema/integration"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:beans="http://www.springframework.org/schema/beans"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
                http://www.springframework.org/schema/integration
                http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">

    <message-bus/>

    <annotation-driven/>

    <channel id="quotes"/>

    <beans:bean id="publisher" class="org.springframework.integration.samples.quote.QuotePublisher"/>

    <beans:bean id="subscriber" class="org.springframework.integration.samples.quote.QuoteSubscriber"/>

</beans:beans>

順便說一句，“annotation-driven”元素還啟用了 @Publisher 註解，該註解觸發 AOP advice 的建立，用於將任何帶註解的方法的返回值非同步傳送到通道。

簡單路由

路由示例的特點是訊息端點每 3 秒生成一個遞增的整數，以及一個路由器解析目標通道名稱（請注意，路由器方法也可以返回多個結果，並且可以返回實際的 MessageChannel 例項，而不是名稱）。

@MessageEndpoint
public class Counter {

    private AtomicInteger count = new AtomicInteger();

    @Polled(period=3000)
    public int getNumber() {
        return count.incrementAndGet();
    }

    @Router
    public String resolveChannel(int i) {
        if (i % 2 == 0) {
            return "even";
        }
        return "odd";
    }
}

在這些通道的接收端，我們有 2 個不同的方法，它們只是記錄訊息有效負載

@Component
public class NumberLogger {

    @Subscriber(channel="even")
    public void even(int i) {
        System.out.println("even: " + i);
    }

    @Subscriber(channel="odd")
    public void odd(int i) {
        System.out.println("odd:  " + i);
    }
}

順便說一句，請注意 NumberLogger 使用 Spring 的 @Component 進行註解。 @MessageEndpoint 註解還包含 @Component 作為元註解。 因此，兩者都是“原型”，並且有資格使用 Spring 2.5 的類路徑掃描進行自動檢測。 此示例的 XML 非常簡單

<context:component-scan base-package="org.springframework.integration.samples.oddeven"/>

<message-bus auto-create-channels="true"/>

<annotation-driven/>

---

希望這能對 Spring Integration 程式設計模型提供一個不錯的介紹。 隨意檢出程式碼並親自嘗試這些示例。 我目前正在編寫“入門”指南，我將在假期後提供該指南。 如果您檢出程式碼，請務必經常更新。 程式碼在不斷發展，特別是，我正在重構許多核心的 consumer/dispatcher 程式碼，目的是為新增輪詢或事件驅動的訊息源提供儘可能簡單的擴充套件點。 在下一篇部落格文章中，我計劃展示一些新增到“spring-integration-samples”的新內容，這些新內容具有這些擴充套件點。