SPRING BOOT+KAFKA 发送和接收message信息的实现

一时失言乱红尘 2022-10-03 00:47 137阅读 0赞

转自：  [https://blog.csdn.net/lin000\_0/article/details/91884684][https_blog.csdn.net_lin000_0_article_details_91884684]

在kafka资料中有说明支持类同于rabbitmq的功能，通过查阅资料，kafka的通讯机制想必不用我写都知道，看到下图就能直接明白：

具体在project中操刀过程如下：

1.在发送和接收PROJECT中的MAVEN增加以下依赖包

2.在接收PROJECT里系统配置文件中增加以下配置信息，主要是为了consumer连接kafka server的topic及group

3.在接收prodject里增加以下组件，主要是为了接收信息，其中KafkaListener为监听topic为zll中信息

import org.springframework.kafka.annotation.KafkaListener;  
import org.springframework.stereotype.Component;

@Component  
public class ListenerMsg \{  
      
    @KafkaListener(topics = "zll")  
    public void processMessage(String content) \{  
        // ...  
        System.out.println("recieve msg:" + content);  
    \}

4.在发送的project里springboot配置文件中增加如下内容

5.在发送的project里增加以下component

import org.apache.commons.logging.Log;  
import org.apache.commons.logging.LogFactory;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.beans.factory.annotation.Value;  
import org.springframework.kafka.core.KafkaTemplate;  
import org.springframework.kafka.support.SendResult;  
import org.springframework.stereotype.Component;  
import org.springframework.util.concurrent.ListenableFuture;

@Component  
public class SendMsg \{  
      
    private Log log = LogFactory.getLog(SendMsg.class);

private final KafkaTemplate kafkaTemplate;  
      
    @Value("$\{spring.kafka.topic\}")  
    private String topic;

@Autowired  
    public SendMsg(KafkaTemplate kafkaTemplate) \{  
        this.kafkaTemplate = kafkaTemplate;  
          
          
        for(int i=0;i<100;i++) \{  
            this.SendMessge("hello "+i);  
        \}  
    \}  
      
    public void SendMessge(String msg) \{  
          
          
        log.info("send send msg :"+msg);  
          
        this.kafkaTemplate.send("zll", msg);  
           
    \}

7.先开启接收project在开发送project就能看到两边日志

发送方日志：

接收方日志：

\---------------------   
作者：lin000\_0   
来源：CSDN   
原文：https://blog.csdn.net/lin000\_0/article/details/91884684   
版权声明：本文为博主原创文章，转载请附上博文链接！

[https_blog.csdn.net_lin000_0_article_details_91884684]: https://blog.csdn.net/lin000_0/article/details/91884684