版權(quán)歸本人所有，如果轉(zhuǎn)載請聯(lián)系本人 這篇大致說一下消息從寫入到讀取在Apache Pulsar服務(wù)端是怎么串起來的。( 這篇不會詳細說明每個邏輯...
投稿
收錄了8篇文章 · 5人關(guān)注
-
Apache Pulsar 源碼走讀（五）服務(wù)端消息流轉(zhuǎn)邏輯概述
-
Apache Pulsar 源碼走讀（四）TopicLookup請求處理（二）
上一篇說到實際的核心邏輯是這2行代碼 這里傳遞的參數(shù)將loadTopicsInBundle 設(shè)置了成true。我們看下在處理lookup請求過程...
-
Apache Pulsar 源碼走讀（三）TopicLookup 請求處理（一）
簡單邏輯說明通過topic名字確定namespace查找這個namespace的bundle分配信息根據(jù)bundle分配信息來確認這個topic...
-
Apache Pulsar 源碼走讀（一）啟動
1.啟動入口 PulsarStandaloneStarter在standalone模式下，主要啟動了以下幾個服務(wù) PulsarService P...
-
Apache Pulsar 源碼走讀（二）二進制協(xié)議pulsar 使用protocolBuf 作為二進制協(xié)議編寫的工具 本文主要說明其中幾個主要的RPC 的作用。并大致說一下這個幾個RPC會被使用...
-
Apache Bookkeeper —— SingleDirectoryDBLedgerStorage
主要成員變量 主要作用 可以讀寫ledger，維護ledger的位置（index） 保存ledger相關(guān)的metadata 支持checkpoi...
-
Apache Bookkeeper —— Journal 源碼分析
簡單梳理一下這個類的作用和邏輯。 主要功能 充當WAL 寫請求處理：首先在Bookkeeper服務(wù)端收到了寫Entry的請求之后會交給Booki...
-
PulsarClient 解析(一）PulsarClient 讓我們看一下這個類的主要方法 創(chuàng)建producer/consumer/reader 元數(shù)據(jù)信息相關(guān) transacti...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1936212/%E6%88%AA%E5%B1%8F2021-01-04_%E4%B8%8B%E5%8D%888.45.14.png', '推薦專題《Apache Pulsar 指南》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/e1e50598059b?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認gb2312'));){kind=link}