Spring系列学习之Spring Cloud Stream流式消息传递-CFANZ编程社区

推荐使用spring-cloud-stream的方法是使用Spring Initializr。只需按照这些说明操作您还可以使用依赖关系管理系统在项目中开始使用它 - 下面的代码段可以复制并粘贴到您的构建中。需要帮忙？请参阅我们的Maven和Gradle构建入门指南。（导航到英文原文可以选择版本和依赖方式）

Maven

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-dependencies</artifactId>
            <version>Fishtown.RC4</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId> <!-- or '*-stream-kafka' -->
    </dependency>
</dependencies><repositories>
    <repository>
        <id>spring-milestones</id>
        <name>Spring Milestones</name>
        <url>https://repo.spring.io/libs-milestone</url>
        <snapshots>
            <enabled>false</enabled>
        </snapshots>
    </repository>
</repositories>

Gradle

buildscript {
    dependencies {
        classpath "io.spring.gradle:dependency-management-plugin:0.5.2.RELEASE"
    }
}

apply plugin: "io.spring.dependency-management"

dependencyManagement {
     imports {
          mavenBom 'org.springframework.cloud:spring-cloud-stream-dependencies:Fishtown.RC4'
     }
}

dependencies {
    compile 'org.springframework.cloud:spring-cloud-stream'
    compile 'org.springframework.cloud:spring-cloud-starter-stream-kafka'
}repositories {
    maven {
        url 'https://repo.spring.io/libs-milestone'
    }
}

只要Spring Cloud Stream和Spring Cloud Stream Binder依赖项在类路径上，任何带有@EnableBinding的Spring Boot应用程序都会绑定到外部消息传递系统（例如Rabbit MQ或Apache Kafka，具体取决于选择的binder实现）。

有关更全面的逐步入门体验，请参阅用户指南的“快速入门”部分。

以下是功能齐全的Spring Cloud Stream应用程序，它接收数据并将数据记录到控制台。

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

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

	@StreamListener(Sink.INPUT)
	public void handle(Person person) {
		System.out.println("Received: " + person);
	}

	public static class Person {
		private String name;
		public String getName() {
			return name;
		}
		public void setName(String name) {
			this.name = name;
		}
		public String toString() {
			return this.name;
		}
	}
}

从前面的例子可以看出：

我们使用@EnableBinding（Sink.class）启用了Sink绑定（input-no-output）。这样做是向框架发出信号以启动与消息传递系统的绑定，它自动创建绑定到Sink.INPUT通道的目标（即队列，主题和其他）。
我们添加了一个处理程序方法来接收Person类型的传入消息。这样做可以让您看到框架的核心功能之一：它尝试自动将传入的消息有效负载转换为Person类型。

您只需运行main（…）方法即可启动应用程序。