AbstractApplicationContext#refresh() AbstractApplicationContext#obtainFr...

順序消息的實現(xiàn) 順序消息進(jìn)行消費時哲银，若是第一次消費失敗孟害，可以返回SUSPEND_CURRENT_QUEUE_A_MOMENT妨马，下一次會繼續(xù)消費此...

提出疑問 第一次pullMessage時是不是根據(jù)offset去獲取呢 offset從遠(yuǎn)程獲取到還是存在本地呢 consumer端在啟動時會開啟...

客戶端管理Channel 因為客戶端要主動發(fā)起請求，以consumer為例啥繁，在對topic進(jìn)行消費時，不同的topic可能在不同的broker上...

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

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

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

幾個重要的類 DubboNamespaceHandler印叁。該類繼承NamespaceHandlerSupport被冒，即通過spring對擴(kuò)展標(biāo)簽的...

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