IP屬地：江蘇
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)...