在我最近的文章中，我提到过 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”模式作为主要命名空间）。

<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 建议，以将任何带注解方法的返回值异步发送到通道。

简单路由

路由示例具有一个每 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 编程模型提供一个不错的介绍。请随时检出代码并亲自尝试这些示例。我目前正在编写一个“入门”指南，我将在假期后提供。如果您确实检出了代码，请务必经常更新。代码不断发展，特别是，我正在重构许多核心消费者/调度程序代码，目标是为添加轮询或事件驱动的消息源提供尽可能简单的扩展点。在下一篇博文中，我计划展示“spring-integration-samples”中的一些新增功能，这些功能将包含这些扩展点。