侧边栏壁纸
博主头像
落叶人生博主等级

走进秋风,寻找秋天的落叶

  • 累计撰写 130562 篇文章
  • 累计创建 28 个标签
  • 累计收到 9 条评论
标签搜索

目 录CONTENT

文章目录

Jafka源码粗略解读之一

2022-06-25 星期六 / 0 评论 / 0 点赞 / 70 阅读 / 1395 字

##相关资料Jafka是sohu的adyliu开源的Kafka的完整Java实现(Kafka本身是用Scala的)。没有学习Scala的计划,又想研究研究MQ,那就不妨从Jafka入手了。关于Jafk

##相关资料

Jafka是sohu的adyliu开源的Kafka的完整Java实现(Kafka本身是用Scala的)。没有学习Scala的计划,又想研究研究MQ,那就不妨从Jafka入手了。

关于Jafka有个slides,地址:https://www.slideshare.net/slideshow/embed_code/12795614

##包结构

  • api

    封装了消息等C/S通讯的对象。

  • cluster

    将zk中的配置信息封装为对象。Partition=>Broker=>Cluster

  • common

    定义了一些异常和注解。几个注解@ThreadSafeServerSide等都是表示型的注解,没有特殊功能。

  • console

    各种从控制台的启动方法。

  • log

    log就是log了,没啥好说的。不过DailyRollingStrategy这些都是Log4j已有的功能,可以细看一下有什么更改。

  • mx

    JMX相关。

  • message

    消息体存储、压缩相关类。

  • network

    网络传输相关。

  • producer

    就是producer。

  • server

    就是server。应该是对应broker。

  • consumer

    就是consumer。

待续。

广告 广告

评论区