Jafka类为整个程序的入口类,
这个类本身没有什么特别的,里面有两个小的知识点需要注意下。
这个类本身没有什么特别的,里面有两个小的知识点需要注意下。
- 在启动的时候注册了shutdownhook,虽然在杀死进程后所有的资源会得以释放,但是添加hook实现了程序终止时候的资源释放工作,可以看出作者的严谨。
具体的细节就不讲了,从main函数入口,创建对象,依次调用ServerStartable的启动,ServerStable里面包含Server,其实就是Server的startUp,初始化LogManager和SocketServer。
从这个地方可以看出,作者的设计意图,ServerStartable就是Server类的管理类,这个里面有一个逻辑就是如果传递了ConsumerConfig,那么就会启动一个EmbeddedConsumer.
相关推荐
#A快速分布式消息传递系统(MQ) Jafka mq是从克隆的分布式发布-订阅消息系统。 因此它具有以下功能: 具有O(1)磁盘结构的持久消息传递即使在存储大量TB消息的情况下也能提供恒定的时间性能。 高吞吐量:即使使用...
jafka, 一种快速简单的分布式发布订阅消息系统( mq ) #A 快速分布式邮件系统( MQ ) Jafka是一个分布式发布订阅消息系统,从 Apache 克隆。因此,它具有以下特性:具有 O(1) 磁盘结构的持久消息传递,即使有大量的...
kafka 的 wiki 是徆丌错的学习文档: https://cwiki.apache.org/confluence/display/KAFKA/Index 接下来就是一系列文章,文章都是循序渐迕的方式带你了览 kafka: 关亍 kafka 的基本知识,分布式的基础:《分布式消息...
Kafka是Apache下的一个子项目,是一个高性能跨语言分布式发布/订阅消息队列系统,而Jafka是在 Kafka之上孵化而来的,即Kafka的一个升级版。具有以下特性:快速持久化,可以在O(1)的系统开销下 进行消息持久化;高...
常见的开源技术有Fluentd、Flume、Apollo、Chukwa、Sqoop、DataX、MySQLStreamer、Canal、Scribe、ZeroMQ、ActiveMQ、Logstash、RabbitMQ、Jafka、Storm、Samza、Heron、Spark、Flink等。这些技术都有其优缺点,需要...
zeromq的作者之一用C语言重写的通信框架, OpenMQ Open-MQ 是一个开源的消息中间件,类似IBM的 WebSphere MQ(MQSeries),采用 C++ 和 Qt 库编写的,支持Windows、Unix 以及 Mac OS 平台,支持 JMS。 ZeroMQ ZeroMQ...
- **Jafka/Kafka**:LinkedIn开源的分布式消息队列,具备高性能和高吞吐量,适合大数据和实时流处理场景。 选择哪种消息中间件取决于具体的应用需求,如数据规模、性能需求、平台兼容性和持久化要求。在评估和选择...
海尔电器公司在实时计算平台的建设中选择了多种开源技术,包括Fluentd、Flume、Apollo、Chukwa、Sqoop、DataX、MySQL Streamer、Canal、Scribe、ZeroMQ、ActiveMQ、Logstash、RabbitMQ、Jafka、Storm、Samza、Heron...
- **Jafka**:基于Kafka早期版本发展而来,但非官方项目,活跃度较低。 #### Kafka的数据文件分段与索引 - **数据文件分段**:Kafka通过将数据文件分段来提高查询效率。每个Partition被分成多个Segment File,每个...