跳到主要内容

使用 Spring 集成 Apache Pulsar

Apache Pulsar 是一个高性能、分布式的消息传递系统，广泛用于构建实时数据管道和流处理应用。Spring 是一个流行的 Java 开发框架，提供了丰富的功能和模块，帮助开发者快速构建企业级应用。通过将 Spring 与 Apache Pulsar 集成，开发者可以更轻松地在 Spring 应用中实现消息的生产和消费。

1. 配置 Spring 项目​

首先，确保你的 Spring 项目已经配置了 Apache Pulsar 的依赖。你可以在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.apache.pulsar</groupId>
    <artifactId>pulsar-client</artifactId>
    <version>2.10.0</version>
</dependency>
xml

2. 创建 Pulsar 客户端​

在 Spring 中，你可以通过配置类来创建和管理 Pulsar 客户端。以下是一个简单的配置类示例：

@Configuration
public class PulsarConfig {

    @Bean
    public PulsarClient pulsarClient() throws PulsarClientException {
        return PulsarClient.builder()
                .serviceUrl("pulsar://localhost:6650")
                .build();
    }
}
java

3. 生产消息​

在 Spring 中，你可以使用 PulsarTemplate 来生产消息。以下是一个简单的生产者示例：

@Service
public class PulsarProducerService {

    @Autowired
    private PulsarClient pulsarClient;

    public void sendMessage(String topic, String message) throws PulsarClientException {
        Producer<String> producer = pulsarClient.newProducer(Schema.STRING)
                .topic(topic)
                .create();
        producer.send(message);
        producer.close();
    }
}
java

4. 消费消息​

在 Spring 中，你可以使用 @PulsarListener 注解来消费消息。以下是一个简单的消费者示例：

@Service
public class PulsarConsumerService {

    @PulsarListener(topics = "my-topic")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}
java

5. 配置 Pulsar 监听器​

你可以在 Spring 配置文件中配置 Pulsar 监听器，以指定更多的消费选项。以下是一个简单的配置示例：

pulsar:
  listener:
    topics:
      - my-topic
    subscription-name: my-subscription
    consumer:
      name: my-consumer
yaml

6. 运行 Spring 应用​

完成上述配置后，你可以运行 Spring 应用，并通过生产者发送消息，消费者将自动接收并处理这些消息。

7. 总结​

通过将 Spring 与 Apache Pulsar 集成，开发者可以更轻松地在 Spring 应用中实现高效的消息传递和处理。Spring 提供了丰富的功能和模块，帮助开发者快速构建企业级应用，而 Apache Pulsar 则为这些应用提供了高性能、分布式的消息传递能力。

希望本文能帮助你快速上手使用 Spring 集成 Apache Pulsar。如果你有任何问题或建议，欢迎在评论区留言讨论。

前言​

备注

我们建议为基于 Spring for Apache Pulsar 的应用程序采用 Spring-Boot-First 方法，因为这样可以极大地简化操作。为此，你可以将 spring-boot-starter-pulsar 模块添加为依赖项。

备注

本参考文档的大部分内容假定读者正在使用 starter，并基于此提供了大部分的配置指导。然而，在说明特定于 Spring Boot starter 使用的指令时，我们会特别指出。

章节摘要​

📄️ 消息消费

当谈到 Pulsar 消费者时，我们建议最终用户应用程序使用 PulsarListener 注解。要使用 PulsarListener，你需要使用 @EnablePulsar 注解。当你使用 Spring Boot 支持时，它会自动启用这个注解，并配置 PulsarListener 所需的所有组件，例如消息监听器基础设施（负责创建 Pulsar 消费者）。PulsarMessageListenerContainer 使用 PulsarConsumerFactory 来创建和管理 Pulsar 消费者，即它用来消费消息的底层 Pulsar 消费者。