kafka 的安装部署及整合springboot

Kafka 的简介:   Kafka 是一款分布式消息发布和订阅系统,具有高性能、高吞吐量的特点而被广泛应用与大数据传输场景。它是由 LinkedIn 公司开发,使用 Scala 语言编写,之后成为 Apache 基金会的一个顶级项...

kafka消息的分发与消费

关于 Topic 和 Partition:   Topic: 在 kafka 中,topic 是一个存储消息的逻辑概念,可以认为是一个消息集合。每条消息发送到 kafka 集群的消息都有一个类别。物理上来说,不同的 topic...

kafka消息存储与partition副本原理

消息的存储原理:   消息的文件存储机制:   前面我们知道了一个 topic 的多个 partition 在物理磁盘上的保存路径,那么我们再来分析日志的存储方式。通过 ll /tmp/kafka-logs/testTopic-...

初识dubbo(2.5.3)及常用配置

1. 为什么需要 Dubbo(摘自http://dubbo.apache.org/zh-cn/docs/user/quick-start.html) 随着互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务...

Dubbo(2.5.3)核心源码阅读(SPI.Extension)

关于 Dubbo SPI:   在Dubbo中,SPI是一个非常核心的机制,贯穿在几乎所有的流程中。Dubbo是基于Java原生SPI机制思想的一个改进,所以,先从JAVA SPI机制开始了解什么是SPI以后再去学习Dub...

dubbo(2.5.3)源码之服务发布与注册

服务端发布流程:   dubbo 是基于 spring 配置来实现服务的发布的,对于dubbo 配置文件中看到的<dubbo:service>等标签都是服务发布的重要配置 ,对于这些提供可配置化的支持,spring功不可...

dubbo(2.5.3)源码之服务消费

消费端启动初始化过程:   消费端的代码解析也是从配置文件解析开始的,服务发布对应的<dubbo:service,解析xml的时候解析了一个ServiceBean,并且调用ServiceConfig进行服务的发布。服务的消费对...

dubbo(2.5.3)源码之Directory与LoadBalance

Directory: 集群目录服务Directory, 代表多个Invoker, 可以看成List<Invoker>,它的值可能是动态变化的比如注册中心推送变更。集群选择调用服务时通过目录服务找到所有服务 Stati...

org.apache.dubbo 2.7.x 再聚首

Dubbo 版本 :   Dubbo 社区目前主力维护的有 2.6.x 和 2.7.x 两大版本,其中, 2.6.x 主要以 bugfix 和少量 enhancements 为主,因此能完全保证稳定性 2.7.x...

org.apache.dubbo 2.7.7 服务发布注册源码

org.apache.dubbo 服务注册原理源码分析:   本文主要针对 dubbo-spring-boot-starter   2.7.7版本, 对应的 org.apache.dubbo 2.7.7...