介绍一下Spring Cloud Stream主要概念

本节将详细介绍如何使用Spring Cloud Stream。它涵盖了建立和运行流应用程序等主题。 介绍Spring Cloud Stream Spring Cloud Stream是构建消息驱动的微服务应用程序的框架。Spring Cloud Stream基于Spring Boot创建独立的生产级Spring应用程序，并使用Spring Integration提供与消息代理的链接。它提供了来自几家供应商的中间件的意见配置，介绍了持久发布订阅语义，消费者组和分区的概念。

您能够将@EnableBinding注释添加到应用程序，以便当即链接到消息代理，而且能够将@StreamListener添加到方法中，以使其接收流处理的事件。如下是接收外部消息的简单接收器应用程序。

@SpringBootApplication @EnableBinding(Sink.class) public class VoteRecordingSinkApplication {

public static void main(String[] args) { SpringApplication.run(VoteRecordingSinkApplication.class, args); }

@StreamListener(Sink.INPUT) public void processVote(Vote vote) { votingService.recordVote(vote); } } @EnableBinding注释须要一个或多个接口做为参数（在这种状况下，该参数是单个Sink接口）。接口声明输入和/或输出通道。Spring Cloud Stream提供了接口Source，Sink和Processor; 您还能够定义本身的界面。

如下是Sink接口的定义：

public interface Sink { String INPUT = "input";

@Input(Sink.INPUT) SubscribableChannel input(); } @Input注释标识输入通道，经过该输入通道接收到的消息进入应用程序; @Output注释标识输出通道，发布的消息将经过该通道离开应用程序。@Input和@Output注释能够使用频道名称做为参数; 若是未提供名称，将使用注释方法的名称。

Spring Cloud Stream将为您建立一个界面的实现。您能够在应用程序中经过自动链接来使用它，以下面的测试用例示例。

@RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = VoteRecordingSinkApplication.class) @WebAppConfiguration @DirtiesContext public class StreamApplicationTests {

@Autowired private Sink sink;

@Test public void contextLoads() { assertNotNull(this.sink.input()); } } 主要概念 Spring Cloud Stream提供了一些简化了消息驱动的微服务应用程序编写的抽象和原语。本节概述了如下内容：

Spring Cloud Stream的应用模型

Binder抽象

持续的发布 - 订阅支持

消费者群体支持

分区支持

一个可插拔的Binder API

源码来源：http://minglisoft.cn/honghu/technology.html