迁移Spring cloud stream应用-将Spring cloud stream应用程序-把Spring cloud stream迁移到Horsham

Question

我正在尝试将Spring Cloud Stream应用程序Chelsea.SR1迁移到Horsham。此项目没有绑定器，但使用spring消息传递和集成来集成自定义源和接收器。

看起来AggregateApplicationBuilder不再可用了。如何在没有AggregateApplicationBuilder的情况下绑定源代码、转换器和接收器？

或者有没有更好的方法在Horsham中实现这一点？我唯一的限制是，我需要使用可轮询的源/消费者。

提前感谢！

pom.xml

  <modelVersion>4.0.0</modelVersion>
  <artifactId>example-info-processor</artifactId>
  <groupId>com.example.streams</groupId>
  <version>1.2-SNAPSHOT</version>
  <packaging>jar</packaging>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
    <relativePath />
  </parent>
  <properties>
    <spring-cloud.version>Chelsea.SR1</spring-cloud.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-stream</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-messaging</artifactId>
      <version>4.3.17.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>4.3.15.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-web</artifactId>
      <version>4.3.20.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>4.3.24.RELEASE</version>
    </dependency>
  </dependencies>
  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-dependencies</artifactId>
        <version>${spring-cloud.version}</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
</project>

应用程序

@SpringBootApplication
@ComponentScan(basePackages = {
        "com.example.streams",
})
public class ExampleInfoProcessorApplication extends SpringBootServletInitializer {
    public static void main(String[] args) {
        new AggregateApplicationBuilder(ExampleInfoProcessor.class, args)
                .from(ExampleInfoConsumer.class).via(ExampleInfoTransformer.class)
                .to(ExampleInfoSink.class).run(args);
    }
}

来源

@EnableBinding(Source.class)
public class ExampleInfoConsumer {
    @Autowired
    private MyConsumer customConsumer;

    @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "30"))
    public List<ExampleRecord> consume() {
      //Read the available chunk from the source location
            .....
        return exampleRecordsList;
    }
}

变压器

@EnableBinding(Processor.class)
public class ExampleInfoTransformer {

    @Transformer(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
    public Map<String, List<ExampleInfo>> transform(List<ExampleRecord> exampleRecords) {
        //transform the consumer records, store the list of ExampleInfo objects in a map using ExampleInfo key
        return map;
    }
}

水槽

@EnableBinding(Sink.class)
public class ExampleInfoSink {

    @ServiceActivator(inputChannel = Sink.INPUT)
    public void sink(Map<String, List<ExampleInfo>>  exampleInfoMap) {
        //Read from map and write to destination.
    }
}

Answer 1

如果你只使用spring集成和spring消息传递，那么为什么要把spring-cloud-stream作为依赖，而不是只使用spring集成，这是一个顶级框架？我如何绑定源代码，转换器和接收器。。。- Source有输出通道，transformer有输入通道。只要输出和输入是相同的通道，您的组件就会连接起来。但这与spring-cloud-stream没有任何关系。这是纯粹的spring集成。

Chelsea是一个非常老的版本(1.x)。我们在2.x中弃用了AggregateApplicationBuilder，并在3.x中删除了它，以支持函数组合。我们也不再提倡基于注释的spring-cloud-stream配置模型，而是支持基于函数的编程模型。

请阅读我们最近发布的以下帖子：

• https://spring.io/blog/2019/10/14/spring-cloud-stream-demystified-and-simplified
• https://spring.io/blog/2019/10/17/spring-cloud-stream-functional-and-reactive
• https://spring.io/blog/2019/10/25/spring-cloud-stream-and-spring-integration
• https://spring.io/blog/2019/10/31/spring-cloud-stream-event-routing