① 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分區越多，理論上整個集群所能達到的吞吐量就越大。