ThreadLocalRandomProbe 有时常会去思考一个问题，传统的 hash值对 key进行哈希而得，然后会对此哈希值进行路由得到目标地址；但有时，我们可能会从另一个维度去思考问题，如果目标数据本身不变 (并非数据本身不发生改变，而是地址)，当多个线程想要对该数据进行操作，即多线程针对同一维度的数据进行争抢时，此时便有可能出现占用上的冲突，此时传统的 hash便不管用了，我们需要的便是对线程本身进行哈希，这一实现其实在 LongAdder、ForkJoinPool中也都有体现：Thread#ThreadL…

FluxCreate解读 // FluxSink具有消费数据的能力, 结合 accept(T t) // 参数可以理解为 逻辑上的一个动作 - 懒加载, 出于机器性能考虑 public static <T> Flux<T> create(Consumer< ? super FluxSink<T>> emitter) { return create(emitter, OverflowStrategy.BUFFER); } // 参数一：FluxSink emitter …

AtomicXXXFieldUpdater技巧 考虑一种情况，假如我们的类中需要假如定义两个或者更多的原子类型，仅仅将类本身去定义为原子类型去操作它是远远不够的，通常把我们可能会去使用 AtomicReference的方式使其变成原子类，然后我们再去进行相关的原子操作 实际上，这是一种比较糟糕的做法，最直观的便是内存上的问题，因此这里介绍下 AtomicXXXReferenceUpdater的玩法 以 Reactor#LambdaSubscriber为例： // 底层 volatile Subscription s…

对于可控的事情，要保持谨慎；对于不可控的事情，要保持冷漠；人只能做自己能力范围内的事情，需要接受这个事实，并且以乐观的心态去看待这一切 ——法外狂徒张三

RemotingServer 这是一个网络层的封装对象，封装着网络连接的细节 我们知道，Netty底层封装着 NIO的细节，因此我们便可以通过对启动器进行相关的配置以来达到连接的建立以及相关的初始化，那么对于 remotingServer而言，其便是对 Netty连接实现等再进行了一层封装，当然，我们知道本来 Netty连接已经是够简易的了，so，单纯的封装并没有太大一样，因此，这块做了很多的扩展 字段 剖析 remotingServer，可以从其字段引入讲起，进而细节剖析其实现 public class Nett…

RocketMQ启动源码(上) NamesrvStartup 这是 RocketMQ启动类入口 // RocketMQ启动入口 public class NamesrvStartup { private static InternalLogger log; private static Properties properties = null; private static CommandLine commandLine = null; public static void main(String[] args) …

Rpc框架 Remote Process Call，远程过程调用 说起 Rpc，我第一想到的便是 "微服务"，即实现的便是像调用本地方法一样进行远程调用 大多大型应用，随着自身规模的不断扩大，都会逐渐向 "微服务化"进行演变，即，演进后的大型应用系统，都是由多个微服务构成的，而微服务间不是独立的，即会进行通信，因此，我个人也是比较赞同 Rpc是微服务的基础这一说辞的 实际上，但凡涉及到网络通信的，我们都有可能会使用到 Rpc 即，Rpc是解决分布式系统间通信的一大利器；Rpc…

Java1.0至Java8，其内置的类有四千多余，对应的便是在 rt.jar包中，但实际上，并没有任何一个应用程序，会将这些 Class全部都使用到；so，我们需要做的便是将rt.jar分解成更加易于管理的部分，这也便是 Module模块化的含义 这四千多类实际上是需要一些内部封装的类配合才能后起作用的，这些内部封装的类通常是不建议我们直接去使用，即，对使用者透明，如：sun.misc.Unsafe 因为很多的框架和库的开发人员，会通过这些东西来提高框架和库的性能和使用底层功能 模块化的关键优势，些许列举： ​ …

外在所有的声音， 如果能够影响你， 是因为你内心没有自己的主见； 因此就是要学会， 跟不同的声音共存， 始终是那句老话， 我不同意你说话的内容， 但是我维护你说话的权利， 活成自己， 并不容易， 如果你想要按别人的期待， 去活着， 你就活不好自己的一生！ ——白岩松

分布式系统：核心便是通过网络使一群计算机相互通信来完成一些连贯的任务 本次，关注于 some examples，如大型网站的存储或大数据计算（比如 MapReduce），以及诸如点到点文件间共享这类的奇特的事 通常而言，我们不会在一开始便去考虑使用分布式，源于分布式需要考虑的问题过多 可以说，多数情况下，人们都是被迫使用大量计算机进行协作的，源于以此来获得高性能，即大量的 cpu，大量的内存，大量的硬盘，大量的并行等 其实，还有一层更为重要的原因：容错，即对应多台计算机去干着相同的事，存在计算机本身发生故障时，检测…

论述 NIO与 Netty间的点点滴滴 说起 Netty，我们脑海里第一印象便是 异步非阻塞的高性能 NIO框架，那 Netty究竟对 NIO进行了哪些改造，为什么 Netty始终是网络通信里的王者？ 可以先从 NIO开始讲起，都说 Java程序员是生活在甜蜜罐里，实际上我们去使用的关于网络流编程相关的类都是经过封装的，Socket、FileDescription实际上都是抽象的东西，底层都是对 os层面的封装，比如说 Socket本身就是抽象的，SocketImpl是其具体实现，而我们常说的 Socket在 os…

已经来杭州几天了，不得不说，杭州真的是在大搞建筑，到处都在装修；初来杭州时的激动，此时心情已经平淡下来；客栈体验生活很不错，一个人独居体验起来十分不赖；已经找到了一个较为不错的房子，过几天搬进去，但不得不说，杭州短租真的不易，自己算是吃了很多亏，也算是涨经验了吧；明天就要入职了，希望一切能稳定下来，好好沉淀一段时间； en，就先到这样，杭漂生活要开始了！

Netty 4如何做到的 reduce garbage？ reduce garbage本质上便是去 eliminate GC，Netty中通过 directmethod的调用去替换事件对象来去消除 GC 我们知道，在每次做网络操作时 (可读，可写，等)，都要去创建一个 POJO对象，更不要说还是数据处理、数据转换等操作了，这样感觉很笨重，尤其是在有很多并发连接下 so，Netty引入了一个 非常轻量级的对象池，用于大量分配的 Object (如 ByteBuf实例) 但是不建议，除非真的需要，不要去把所有的对象都池…

对 Netty的些许思考： 内存池为什么会引入 Arena？Arena又解决了什么问题？ 开辟多个 Arena，让尽可能少的线程去共享同一个 Arena，那么这也就能够去缓解在同一块内存上操作的带来的无法并行需要进行同步的问题 这怎么理解？ 现代 cpu多核心，当实际去读取数据时，cpu并不会只去读你想要的数据，出于缓存 (局部性原理，L1，L2，L3)，别的数据也会被读取 假设 core1、core2上分别运行着 thread-1，thread-2，而这两个线程分别对应的 ByteBuf 16b数据的读取，那么 …