##相关资料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
定义了一些异常和注解。几个注解
@ThreadSafe
、ServerSide
等都是表示型的注解,没有特殊功能。console
各种从控制台的启动方法。
log
log就是log了,没啥好说的。不过
DailyRollingStrategy
这些都是Log4j已有的功能,可以细看一下有什么更改。mx
JMX相关。
message
消息体存储、压缩相关类。
network
网络传输相关。
producer
就是producer。
server
就是server。应该是对应broker。
consumer
就是consumer。
待续。