Kafka集成SpringBoot，轻松开启消息队列之旅

后端

2023-06-17 22:31:53

轻松集成 Kafka：开启消息队列之旅

准备就绪

踏上 Kafka 之旅的第一步是确保你的开发环境已配备 Java 8、Apache Kafka 和 SpringBoot。

创建 SpringBoot 项目

使用 Spring Initializr 创建一个新的 SpringBoot 项目，开启你的消息队列之旅。

引入 Kafka 依赖

在项目的 pom.xml 文件中，添加 Kafka 依赖项，以便与消息代理进行通信：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-kafka</artifactId>
</dependency>

配置 Kafka 连接

在 application.properties 文件中，指定 Kafka 连接信息，告诉 SpringBoot 在何处找到 Kafka 代理：

spring.kafka.bootstrap-servers=localhost:9092

打造消息生产者

为了向 Kafka 发送消息，你需要创建一个生产者。这个类负责将消息推送到消息代理：

@Service
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

构建消息消费者

在接收端，你需要一个消费者来从 Kafka 中拉取消息。该类将处理从消息代理收到的消息：

@Service
public class KafkaConsumer {

    @KafkaListener(topics = "myTopic")
    public void receiveMessage(String message) {
        System.out.println("收到了消息：" + message);
    }
}