快速入门

1. 依赖项
2. 应用代码

我们将通过展示一个生产和消费的 Spring Boot 应用示例来快速了解 Spring for Apache Pulsar。这是一个完整的应用，不需要任何额外的配置，只要您在默认位置（localhost:6650）运行一个 Pulsar 集群。

1. 依赖项

Spring Boot 应用只需要 spring-boot-starter-pulsar 依赖项。以下列表分别展示了如何在 Maven 和 Gradle 中定义依赖项。

Maven
Gradle

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-pulsar</artifactId>
        <version>3.3.6-SNAPSHOT</version>
    </dependency>
</dependencies>

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-pulsar:3.3.6-SNAPSHOT'
}

2. 应用代码

以下列表显示了示例中的 Spring Boot 应用案例。

@SpringBootApplication
public class PulsarBootHelloWorld {

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

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

    @PulsarListener(subscriptionName = "hello-pulsar-sub", topics = "hello-pulsar-topic")
    void listen(String message) {
        System.out.println("Message Received: " + message);
    }
}

让我们快速浏览一下此应用的高级细节。在后面的文档中，我们将更详细地了解这些组件。

在前面的示例中，我们大量依赖 Spring Boot 自动配置。Spring Boot 为我们的应用自动配置了多个组件。它自动提供了一个 PulsarClient，该客户端被生产者和消费者都用于应用。

Spring Boot 还自动配置了 PulsarTemplate，我们在应用中注入它并开始向 Pulsar 主题发送记录。该应用将消息发送到名为 hello-pulsar 的主题。请注意，该应用未指定任何模式信息，因为 Spring for Apache Pulsar 库会根据您发送的数据类型自动推断模式类型。

我们使用 PulsarListener 注解从我们发布数据的 hello-pulsar 主题进行消费。PulsarListener 是一个便捷注解，它封装了 Spring for Apache Pulsar 中的消息监听器容器基础设施。在幕后，它创建一个消息监听器容器来创建和管理 Pulsar 消费者。与常规 Pulsar 消费者一样，使用 PulsarListener 时默认的订阅类型为 Exclusive 模式。当记录发布到 hello-pulsar 主题时，Pulsarlistener 会消费它们并在控制台上打印它们。框架还会根据 PulsarListner 方法用作有效负载的数据类型（在本例中为 String）推断使用的模式类型。