Zookeeper与Kafka Kafka Kafka SocketServer是基于Java NIO开发的，采用了Reactor的模式(已被大量实践证明非常高效，在Netty和Mina中广泛使用)。Kafka Reactor的模式包含三种角色：Acceptor;Processor ；Handler ...
分类：
其他好文 时间：
2019-11-03 10:18:46
阅读次数：
98
本文从网络模型、数据结构和内存管理、持久化和多机协作四个角度对redis的设计思路进行分析。一.网络模型Redis是典型的基于Reactor的事件驱动模型，单进程单线程，高效的框架总是类似的。网络模型与spp的异步模型几乎一致。Redis流程上整体分为接受请求处理器、响应处理器和应答处理器三个同步模块，每一个请求都是要经历这三个部分。Redis集成了libevent/epoll/kqueue/se
分类：
其他好文 时间：
2019-10-29 17:02:05
阅读次数：
93
简介：Reactor 设计模式是一种事件驱动的设计模式，将一个或者多个客户端请求分发到不同的处理器上，来提升事件处理的效率。主要的应用场景就是java NIO当中用户处理网络请求。使用的是异步非阻塞IO 在接受Reactor 模式之前，需要先了解常见的几种IO网络模型。 1、BIO(阻塞IO模型) ...
分类：
其他好文 时间：
2019-10-25 16:13:02
阅读次数：
79
1.3.2 ReactorReactor与Spring是兄弟项目，侧重于Server端的响应式编程，主要 artifact 是 reactor-core，这是一个基于 Java 8 的实现了响应式流规范 （Reactive Streams specification）的响应式库。本文对Reactor ...
分类：
其他好文 时间：
2019-10-23 13:36:24
阅读次数：
87
NIO:同步非阻塞IO 来源：BIO是同步阻塞IO操作，当线程在处理任务时，另一方会阻塞着等待该线程的执行完毕，为了提高效率，，JDK1.4后，引入NIO来提升数据的通讯性能 NIO中采用Reactor设计模式，注册的汇集点为Selector，NIO有三个主要组成部分：Channel（通道）、Buf ...
分类：
编程语言 时间：
2019-10-17 01:35:31
阅读次数：
134
这里会介绍：
1. Sentinel会使用多线程的方式实现一个类Reactor的IO模型
2. Sentinel会使用心跳检测来观察控制台是否正常 ...
分类：
其他好文 时间：
2019-09-28 00:56:27
阅读次数：
115
本章节介绍：Flux和Mono操作符 和其他主流的响应式编程一样，Reactor框架的设计目标也是为了简化相应式流的使用方法。为此Reactor框架提供了大量操作符用于操作Flux和Mono对象。 本节不打算全面详细介绍，我们的思路是将这些操作符分类，然后对每一类中具有代表性的操作符展开讨论。 在本 ...
分类：
编程语言 时间：
2019-09-27 15:18:40
阅读次数：
124
前言：我们知道，Netty是基于NIO开发的一套框架，在学习Netty之前，我们先学习下Java NIO。 一、IO多路复用模型 IO多路复用模型使用了Reactor设计模式，主要有三种实现：Reacotr单线程、Reactor多线程、Reactor主从模式。 1. Reactor单线程 在Reac ...
分类：
编程语言 时间：
2019-09-25 16:06:31
阅读次数：
86
我看同步阻塞 “你知道什么是同步阻塞吗”，当然知道了。“那你怎么看它呢”，这个。。。在同步阻塞的世界里，代码执行到哪里，数据就跟到哪里。如果数据很慢跟不上来，代码就停在那里等待数据的到来，然后再带着数据一起往下执行。可以说是，代码执行和数据是结伴而行，不离不弃。执子之手与子偕老。让人老感动了。如果还 ...
分类：
其他好文 时间：
2019-09-23 09:53:20
阅读次数：
69
APM监控--（四）Pinpoint扩展报警--超详细，各种问题解决之后的顺畅版本https://blog.csdn.net/xvshu/article/details/79814549 pinpoint web报警机制源码解析https://www.cnblogs.com/langshiquan/ ...
分类：
其他好文 时间：
2019-09-22 23:14:01
阅读次数：
238
