SpringBoot整合Kafka中间件,上篇

小编的上篇文章,介绍了Kafka的一些基本概念,这些概念对于理解和使用Kafka非常重要。学会了概念还不行,我们还要实战操作一下。接下来,小编就给大家演示如何快速搭建基于SpringBoot工程的Kafka消息生产者。

第一步、创建SpringBoot基础工程

工程名称: springboot-kafka-producer

工程类型: Maven 工程

第二步、编辑工程maven配置文件

添加Kafka工程依赖

pom.xml

第三步、创建一个消息实体类

这个消息实体类,只是作为演示使用。包含两个属性,一个UUID,一个日期。

消息实体类

第四步、创建消息生产者配置信息类

记得一定不要忘记添加@Configuration注解。

BOOTSTRAP_SERVERS_CONFIG值没有采用硬编码的形式,而是读取资源配置注入的方式。

这个类的最主要作用就是初始化了KafkaTemplate实例,消息的发送就是通过kafka模板实例完成的。

配置信息类

第五步、创建消息生产者业务类

这个类不是必须的,他只是对kafka模板实例做了一个封装,把发送消息的业务封装了起来,真正起到发送消息作用的,还是kafka模板实例。

消息生产业务类

第六步、创建消息生产者控制器类

这个类的作用,主要是通过Restful服务请求的方式创建消息类实例,然后通过调用消息生产者业务类,发送消息。

消息生产控制器

第七步、修改入口启动类

添加开启kafka注解@EnableKafka

入口启动类

第八步、修改工程资源配置文件

资源配置文件

第九步、开启zookeeper服务,开启kafka服务,执行消息消费监听

示例是windows版的,linux版的命令差不多,只不过是执行的sh脚本

开启zookeeper

启动kafka

监听消息消费

第十步、运行工程

工程启动成功后,通过浏览器,访问消息生产者Restful服务

访问Restful服务生产消息

查看消息消费监控台

消息监听消费成功

消息成功发送到了kafka服务器,并成功进行了消费

结束

下一篇,小编就给大家演示如何快速搭建基于SpringBoot工程的Kafka消息消费者。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181206A0KMG100?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券