SpringBoot集成kafka全面实战记录

下面我将为大家详细讲解SpringBoot集成Kafka全面实战记录的完整攻略。

1. 环境搭建

在开始之前，我们需要先完成环境搭建，包括安装JDK、安装Kafka、创建Kafka集群等操作。具体的步骤可以参考Kafka官方文档，这里不再赘述。

2. SpringBoot集成Kafka

2.1 引入依赖

首先，在SpringBoot项目中引入Kafka相关的依赖：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.8.0</version>
</dependency>

2.2 配置Kafka

在application.properties中加入Kafka的配置：

spring.kafka.bootstrap-servers=127.0.0.1:9092
spring.kafka.consumer.group-id=myGroup

2.3 发送消息

发送消息的示例代码如下：

@Service
public class KafkaProducerService {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

}

2.4 接收消息

接收消息的示例代码如下：

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "myTopic", groupId = "myGroup")
    public void receiveMessage(String message) {
        System.out.println("received message: " + message);
    }

}

其中，@KafkaListener注解指定了要消费的topic和groupId，方法参数为接收到的消息。

3. 示例

3.1 发送消息示例

在Controller中添加以下代码：

@Autowired
private KafkaProducerService producerService;

@GetMapping("/send")
public String sendMessage(@RequestParam String message) {
    producerService.sendMessage("myTopic", message);
    return "success";
}

通过访问/send?message=test，即可发送一条消息到myTopic中。

3.2 接收消息示例

在启动类中添加以下代码：

@EnableKafka
@SpringBootApplication
public class KafkaDemoApplication {

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

    @Bean
    public NewTopic myTopic() {
        return TopicBuilder.name("myTopic").build();
    }

}

同时，在KafkaConsumerService中加入以下代码：

@KafkaListener(id = "myContainer", topics = "myTopic")
public void receiveMessages(List<String> messages) {
    System.out.println("received messages: " + messages);
}

通过访问/send?message=test发送一条消息后，即可在控制台看到接收到的消息。

4. 总结

通过以上的步骤和示例，我们成功地实现了SpringBoot集成Kafka的全面实战，包括环境搭建、引入依赖、配置Kafka、发送消息、接收消息等操作，前后端代码均已提供，方便开发者进行学习和参考。