① springboot整合kafka实现消息推送
本篇文章主要介绍的是springboot整合kafka。
1.使用docker安装kafka，移步 https://www.jianshu.com/p/89b19f5b28ec
创建一个名为springboot-kafka-common的微服务，打包方式为jar，存放一些公共配置和公共类，如util等
1.配置pom文件
pom文件中以父工程作为父依赖，就不需要额外引入依赖了
2.新建一个user实体类
3.创建application-common.yml配置文件，主要添加kafka的公共配置
1.pom文件配置
2.application.yml配置文件，配置端口，设置微服务名称，引入公共服务模块中的application-common.yml
3.controller层
创建UserController
4.service层
创建UserService
创建UserServiceImpl
5.创建启动类
1.pom文件
2.创建yml配置文件
3.创建consumer消费者类
4.启动类
启动procer和consumer两个服务模块
访问procer微服务中的接口 http://localhost:8081/api/user/getUser
会发现consumer微服务中的控制台打印了procer中创建并推送过来的的user实体
本文GitHub源码： https://github.com/lixianguo5097/springboot/tree/master/springboot-kafka
CSDN： https://blog.csdn.net/qq_27682773
： https://www.jianshu.com/u/e99381e6886e
博客园： https://www.cnblogs.com/lixianguo
个人博客： https://www.lxgblog.com `
② 如何将kafka数据推送到web前端
Kafka的生产者和消费者都可以多线程地并行操作，而每个线程处理的是一个分区的数据。因此分区实际上是调优Kafka并行度的最小单元。对于procer而言，它实际上是用多个线程并发地向不同分区所在的broker发起Socket连接同时给这些分区发送消息；而consumer呢，同一个消费组内的所有consumer线程都被指定topic的某一个分区进行消费(具体如何确定consumer线程数目我们后面会详细说明)。所以说，如果一个topic分区越多，理论上整个集群所能达到的吞吐量就越大。