快速導覽

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）推斷使用的綱要類型。