AbstractApplicationContext#refresh() AbstractApplicationContext#obtainFr...

順序消息的實(shí)現(xiàn) 順序消息進(jìn)行消費(fèi)時(shí)，若是第一次消費(fèi)失敗安券，可以返回SUSPEND_CURRENT_QUEUE_A_MOMENT义钉，下一次會(huì)繼續(xù)消費(fèi)此...

提出疑問(wèn) 第一次pullMessage時(shí)是不是根據(jù)offset去獲取呢 offset從遠(yuǎn)程獲取到還是存在本地呢 consumer端在啟動(dòng)時(shí)會(huì)開(kāi)啟...

客戶端管理Channel 因?yàn)榭蛻舳艘鲃?dòng)發(fā)起請(qǐng)求昧绣，以consumer為例，在對(duì)topic進(jìn)行消費(fèi)時(shí)捶闸，不同的topic可能在不同的broker上...

項(xiàng)目地址使用和rocket相似 后期準(zhǔn)備做的 完善客戶端channel管理夜畴。 broker分布式。這依賴于客戶端的負(fù)載均衡删壮，將topic分片存儲(chǔ)...

netty在rocket中的使用 client和server都是使用netty通信 client在創(chuàng)建BootStrap時(shí)的簡(jiǎn)化代碼如下 在處理...

raincat項(xiàng)目地址 源碼分析 本地事務(wù)部分依賴于spring事務(wù) @TxTransactional注解和spring自帶的Transacti...

幾個(gè)重要的類 DubboNamespaceHandler贪绘。該類繼承NamespaceHandlerSupport，即通過(guò)spring對(duì)擴(kuò)展標(biāo)簽的...

首先定義公共的接口 服務(wù)提供者進(jìn)行接口的實(shí)現(xiàn)部分 實(shí)現(xiàn)rpc醉锅，主要為socket通信和協(xié)議的商定 服務(wù)提供者暴露需要調(diào)用的方法實(shí)現(xiàn) 服務(wù)消費(fèi)者調(diào)...