摘要：一言以蔽之，被修饰的变量能够保证每个线程能够获取该变量的最新值，从而避免出现数据脏读的现象。为了实现内存语义时，编译器在生成字节码时，会在指令序列中插入内存屏障来禁止特定类型的处理器重排序。volatile原理volatile简介Java内存模型告诉我们，各个线程会将共享变量从主内存中拷贝到工作内存，然后执行引擎会基于工作内存中的数据进行操作处理。 线程在工作内存进行操作后何时会写到主内存中...
番茄西红柿
发布于
摘要：中使用那一套，线程的速度，你知道的而对于分布式数据流来说，本来就是并行的，这种参数意义就不大了。函数种类一般作用在数据流上的函数，会分为两类。中的程序是实现在数据流上的。可以看作是的更新日志，数据流中的每一个记录对应数据库中的每一次更新。最近入职一个有趣的年轻同事，提交了大量大量的代码。翻开git记录一看，原来是用了非常多的java8的语法特性，重构了代码。用的最多的，就是map、flatM...
番茄西红柿
发布于
摘要：公平锁为了保证时间上的绝对顺序，需要频繁的上下文切换，而非公平锁会降低一定的上下文切换，降低性能开销。因此，默认选择的是非公平锁，则是为了减少一部分上下文切换，保证了系统更大的吞吐量。ReentrantLock简介ReentrantLock重入锁，是实现Lock接口的一个类，也是在实际编程中使用频率很高的一个锁， 支持重入性，表示能够对共享资源能够重复加锁，即当前线程获取该锁再次获取不会被阻...
番茄西红柿
发布于
摘要：主题和分区的悄息通过主题进行分类。在给定的分区里，每个悄息的偏移量都是唯一的。消费者把每个分区最后读取的悄息偏移量保存在或上，如果悄费者关闭或重启，它的读取状态不会丢失。主题可以配置自己的保留策略，可以将悄息保留到不再使用它们为止。发布与订阅消息系统 在正式讨论Apache Kafka (以下简称Kafka)之前，先来了解发布与订阅消息系统的概念， 并认识这个系统的重要性。数据(消息)的发送...
番茄西红柿
发布于
摘要：本文这里主要来讲述的三个版本的消息格式的演变，文章偏长，建议先关注后鉴定。消息格式版本号，此版本的值为。表示消息的的长度。实际消息体的长度。外层消息保存了内层消息中最后一条消息的绝对位移，绝对位移是指相对于整个而言的。 摘要 对于一个成熟的消息中间件而言，消息格式不仅关系到功能维度的扩展，还牵涉到性能维度的优化。随着Kafka的迅猛发展，其消息格式也在不断的升级改进，从0.8.x版本开始到现...
番茄西红柿
发布于
