快速导览
我们将快速介绍Apache Pulsar的Spring Boot应用示例，它能生成并消耗数据。
这是一个完整的应用程序，只要你在默认位置运行一个Pulsar集群，就不需要额外配置——本地主持：6650.
1. 依赖关系
Spring Boot 应用程序只需Spring靴Starters脉冲星Dependency。以下列表展示了如何分别定义Maven和Gradle的依赖关系：
-
Maven
-
Gradle
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-pulsar</artifactId>
<version>4.0.0</version>
</dependency>
</dependencies>dependencies {
implementation 'org.springframework.boot:spring-boot-starter-pulsar:4.0.0'
}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 会自动配置我们的应用中的多个组件。
它会自动提供脉冲星客户端，生产者和消费者都使用，用于应用。
Spring Boot还能自动配置脉冲星模板我们会在应用程序中注入，并开始向Pulsar主题发送记录。
应用程序向名为你好，脉冲星.
请注意，应用程序并未指定任何模式信息，因为 Spring for Apache Pulsar 库会自动根据你发送的数据类型推断模式类型。
我们使用脉冲星听者从中取用的注释你好，脉冲星我们发布数据的主题。脉冲星听者是一个方便注释，将消息监听器容器基础设施包裹在 Apache Pulsar 的 Spring 中。
在幕后，它创建了一个消息监听器容器，用于创建和管理 Pulsar 消费者。
与普通Pulsar用户一样，使用时默认订阅类型脉冲星听者是独家模式。
随着记录被发布到......你好，脉冲星主题，脉冲监听器消耗它们并在控制台上打印。
该框架还从数据类型推断所使用的模式类型脉冲星听者方法作为有效载荷的使用——字符串，在这种情况下。