我们将通过展示一个以反应式方式生产和使用的示例 Spring Boot 应用程序，快速浏览 Spring 对 Apache Pulsar 的响应式支持。 这是一个完整的应用程序，不需要任何额外的配置，只要您在默认位置 - 上运行一个 Pulsar 集群。localhost:6650

1. 依赖关系

Spring Boot 应用程序只需要依赖项。以下列表分别显示了如何定义 Maven 和 Gradle 的依赖项：spring-boot-starter-pulsar-reactive

  • Maven

  • Gradle

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-pulsar-reactive</artifactId>
        <version>3.3.1-SNAPSHOT</version>
    </dependency>
</dependencies>
dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-pulsar-reactive:3.3.1-SNAPSHOT'
}

2. 申请代码

以下是应用程序源代码：

@SpringBootApplication
public class ReactiveSpringPulsarHelloWorld {

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

    @Bean
    ApplicationRunner runner(ReactivePulsarTemplate<String> pulsarTemplate) {
        return (args) -> pulsarTemplate.send("hello-pulsar-topic", "Hello Reactive Pulsar World!").subscribe();
    }

    @ReactivePulsarListener(subscriptionName = "hello-pulsar-sub", topics = "hello-pulsar-topic")
    Mono<Void> listen(String message) {
        System.out.println("Reactive listener received: " + message);
        return Mono.empty();
    }
}

就是这样，只需几行代码，我们就有一个可以工作的 Spring Boot 应用程序，它以响应式方式生成和使用来自 Pulsar 主题的消息。

启动后，应用程序使用 a 向 . 然后，它从使用 .ReactivePulsarTemplatehello-pulsar-topichello-pulsar-topic@ReactivePulsarListener

简单性的关键要素之一是 Spring Boot 启动器，它可以自动配置并为应用程序提供所需的组件
简单性的关键要素之一是 Spring Boot 启动器，它可以自动配置并为应用程序提供所需的组件