netty中事件的传播主要包含inBound事件和outBound事件 首先我们看下ChannelInboundHandler接口,主要包含以下...
1.pipeline的初始化 之前我们分析过,每构造一个channel的时候会通过newChannelPipeline初始化一个pipeline...
昨天已经看到NioEventLoop的执行是在SingleThreadEventExecutor.this.run(); 这个地方调用执行的,那...
通过以下这行代码创建SubReactor线程组,也就是NioEventLoop线程组; 构造一个SelectorProvider.provide...
以netty源码中的为EchoServer例,分析netty服务端启动的流程 首先在ServerBootstrap调用group方法的时候会传进...
本小节我们来讨论Kafka生产者是如何发送消息到Kafka的, Kafka项目有一个生产者客户端,我们可以通过这个客户端的API来发送消息。生产...
为了便于说明问题,假设这里只有一个Kafka集群,集群中只有一个Kafka节点,也就是只有一台物理机。在这个Kafka broker实例的 $...
写这篇文章的目的主要是为了记录下自己在zookeeper 锁上踩过的坑,以及踩坑之后自己的一点认识; 从zk分布式锁原理说起,原理很简单,大家也...
本文,你将阅读到以下内容: 如何应对缓存击穿和缓存雪崩的问题; Redis 的过期策略以及内存淘汰机制; 1.如何应对缓存击穿和缓存雪崩的问题?...