Spring 带有反应流的云流

Question

我的目标是使用 Spring 云流和 Kafka 创建一个应用程序，并发现 "reactive" 世界。我有一些有用的东西。这是我的消费者的一部分。在我的 pom 中，我声明：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-kafka</artifactId>
        </dependency>

这是我使用的 1.0。0.RELEASE。
我已经声明了我的频道

public interface MyChannels {

    public static final String TOPIC_NAME = "myTopicName";

    @Input(TOPIC_NAME)
    MessageChannel receive();
}

然后是我的服务

@MessageEndpoint
@EnableBinding(MyChannels.class)
public class MyConsumer {

    @Autowired
    private MyChannels channels;

    @ServiceActivator(inputChannel=MyChannels.TOPIC_NAME)
    public void receive(MyObject object) {
        //apply my business logic
        //like save my object in a database
    }
}

我收到我的消息很好。我在我的依赖项中看到 spring-integration-kafka 依赖于 reactor-core。是否足以让我的应用 "reactive" ？我应该怎么做才能应用响应式编程风格？

我是否必须使用@EnableRxJavaProcessor，如果是，我不明白如何。

如果我不清楚，请不要犹豫，在评论中写出来。谢谢

Answer 1

Reactor 的使用是项目内部的，不会使您的应用程序具有反应性（现在还不行:)）。

此处的参考文档涵盖了 RxJava 支持的使用：http://docs.spring.io/spring-cloud-stream/docs/current/reference/htmlsingle/#_rxjava_support

我们确实打算在 Spring Cloud Stream 1.1 中提供更广泛的支持：https://github.com/spring-cloud/spring-cloud-stream/issues/458

干杯，马吕斯

Spring 带有反应流的云流

Spring cloud stream with reactive streams

spring

spring-integration

apache-kafka

reactive-programming

spring-cloud-stream