SpringBoot 和 Kafka 集群

前言

市面上消息队列中间件管理有蛮多的,如:ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ,但我最先接触的可能就是Kafka了,不过那时候为了用,只知道部分实用性的东西,这两天稍稍花了点时间看了看。

消息队列

在我看来,消息队列的出现更多的是解耦合,我们不需关心数据的来处和出处,生产者和消费者可能都不知道对方是一种什么样的存在方式,而且解决了突发的数据剧增现象.我在例子中曾这样实验过

  1. 线程跑一会睡眠20ms
  2. 线程一直在跑

KafkaTool的Consumers

实验1的处理速度可以跟的上生产速度,offset一直指向end,但实验2生产速度大幅上升,处理速度明显跟不上,我停止生产后,几毫秒再去看,offset才指向end。

例子

通过例子了解的可能会更加的快,这里我使用docker-compose搭建的kafka集群

SpringBoot和kafka生产者
https://github.com/tokeneros/kafka_produce...

SpringBoot和kafka消费者
https://github.com/tokeneros/kafka_consumt...

本作品采用《CC 协议》,转载必须注明作者和本文链接
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

请勿发布不友善或者负能量的内容。与人为善,比聪明更重要!
未填写
文章
1
粉丝
0
喜欢
0
收藏
0
排名:1615
访问:221
私信
所有博文
博客标签