zoukankan      html  css  js  c++  java
  • 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...

    最后注意:光理论是不够的。在此顺便送大家十套2020最新JAVA架构项目实战教程及大厂面试题库,进我扣裙 :七吧伞吧零而衣零伞 (数字的谐音)转换下可以找到了,还可以跟老架构师交流
    本文的文字及图片来源于网络加上自己的想法,仅供学习、交流使用,不具有任何商业用途,版权归原作者所有,如有问题请及时联系我们以作处理

  • 相关阅读:
    js创建json对象
    redis命令行清缓存
    查询某个用户所有新增的用户,本月新增用户,上个月新增的用户
    js处理el表达式
    调用上一个页面的js方法
    生成唯一code
    jeeplus中两个项目redis冲突问题
    $ 与 #
    字典表的维护
    将html文档转成pdf
  • 原文地址:https://www.cnblogs.com/chengxuyuanaa/p/12884851.html
Copyright © 2011-2022 走看看