kafka作为消息中间件的一款产品，她比较轻量级，在吞吐量方面很优秀，默认消息持久化到硬盘当中 168小时=7天，log.retention.hours=168，比较适合来做运营的统计。其他的不多讲，先看看pom依赖吧

这里我使用的版本为：

kafka.version=2.2.0.RELEASE

kafka-client.version=2.0.0

|| 消息提供方

消息提供者的application.properties配置（接口层）：

消息提供者发送消息：

|| 消息消费方

消息消费者者的application.properties配置（服务层）：

监听消息：

Kafka消息测试：

狂点几下请求接口后，查看redis缓存情况：

大家不难看到，我使用Kafka对搜索的商品次数做了统计（仅仅是测试代码）。先在接口层，每请求一个商品查询接口，就把查询的商品ID发送到Kafka消息队列，再在服务层监听统计查询次数。

到现在为止，项目的基本配置和一些服务集成接入已经实现，接下来我会更深入的讲述项目中经常遇到的坑和怎么防止不跳坑，以及分布式任务调度管理，分布式事务一致性处理等。

获取项目源代码，请扫码关注公众号，并发送Springboot获取。

最新文章

1. 【手记】为windows2008建个睡眠快捷方式
2. Bootstrap <基础二十一>徽章（Badges）
3. Ceph剖析：数据分布之CRUSH算法与一致性Hash
4. web自定义控件UserControl
5. [AngularJS] Introduction to ui-router
6. javascript笔记——图片大小检测
7. drag and drop
8. 委托与Lambda-浅谈
9. netcat
10. 解决 Visual Studio 2012 有时不能调试的问题
11. A框架第一步,传递不同参数.主程序执行对应方法
12. sqlserver低版本生成插入脚本
13. phpexcl导出数据
14. 运用jQuery写的验证表单
15. SAS中常见的数组函数
16. Linux多线程实践(2) --线程基本API
17. 《团队作业第三、第四周》五小福团队作业--Scrum 冲刺阶段--Day7
18. 如何伪造IP(转）
19. maven构建ssh工程
20. 利用 ImageAI 在 COCO 上学习目标检测

热门文章

1. Django安装和使用---python（3）
2. 微信小程序 + thinkjs + mongoDB 实现简单的前后端交互
3. Hystrix完整配置列表
4. [ASP.NET Core 3框架揭秘] 配置[1]：读取配置数据[上篇]
5. maven本地仓库路径和修改
6. 简单易学的机器学习算法——决策树之ID3算法
7. java前端与后端怎么选？？
8. Python报错ERROR: Command errored out with exit status 1:
9. python数据挖掘第二篇-爬虫
10. [TimLinux] JavaScript 阻止父节点接收子节点事件的方法