發(fā)簡信
IP屬地：陜西
-
2026-04-16 TCP粘包/拆包問題與 Netty 解決方案
一、為什么會有粘包/拆包問題 1.1 根本原因：TCP 是面向流的協(xié)議 TCP 是一個面向字節(jié)流（byte-stream）的協(xié)議，不是面向消息的...
-
2019-05-24 pipeline 事件及異常的傳播netty中事件的傳播主要包含inBound事件和outBound事件 首先我們看下ChannelInboundHandler接口，主要包含以下...
-
2019-05-19 pipeline 初始化、新增、刪除操作
1.pipeline的初始化 之前我們分析過，每構(gòu)造一個channel的時候會通過newChannelPipeline初始化一個pipeline...
-
2019-05-19 NioEventLoop的執(zhí)行昨天已經(jīng)看到NioEventLoop的執(zhí)行是在SingleThreadEventExecutor.this.run(); 這個地方調(diào)用執(zhí)行的，那...
-
2019-05-18 NioEventLoop的初始化通過以下這行代碼創(chuàng)建SubReactor線程組,也就是NioEventLoop線程組； 構(gòu)造一個SelectorProvider.provide...
-
2019-05-16 netty 服務(wù)端啟動以netty源碼中的為EchoServer例，分析netty服務(wù)端啟動的流程 首先在ServerBootstrap調(diào)用group方法的時候會傳進...
-
[kafka系列]之producer端消息發(fā)送本小節(jié)我們來討論Kafka生產(chǎn)者是如何發(fā)送消息到Kafka的， Kafka項目有一個生產(chǎn)者客戶端，我們可以通過這個客戶端的API來發(fā)送消息。生產(chǎn)...
-
[kafka系列]之指定了一個offset,怎么查找到對應(yīng)的消息？為了便于說明問題,假設(shè)這里只有一個Kafka集群,集群中只有一個Kafka節(jié)點，也就是只有一臺物理機。在這個Kafka broker實例的 $...
-
[zookeeper 系列] curator 分布式鎖InterProcessMutex
寫這篇文章的目的主要是為了記錄下自己在zookeeper 鎖上踩過的坑,以及踩坑之后自己的一點認識; 從zk分布式鎖原理說起,原理很簡單,大家也...