這篇文章主要講解了“Receiver怎么啟動”,文中的講解內容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“Receiver怎么啟動”吧!
成都創新互聯自2013年起,是專業互聯網技術服務公司,擁有項目網站建設、成都網站制作網站策劃,項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命,1280元延津做網站,已為上家服務,為延津各地企業和個人服務,聯系電話:028-86922220
Receiver是通過ReceiverSupervisor的start方法啟動的:
首先會調用ReceiverSupervisor的onStart()方法
registeredBlockGenerators是在ReceiverSupervisor實例化時被賦值的:<具體是在父類ReceiverSupervisorImpl中實現的>
調用BlockGenerator的start方法
blockIntervalTimer是一個定時器,到時間了就調用updateCurrentBuffer函數
定時器會不斷的調用這個方法
改線程默認會每個200毫秒運行一次
triggerActionForNextInterval會調用如下的回調方法:
會把當前時間段內收到的數據,分裝為一個block,并將其加入隊列中
再來看看
可以看出每隔10毫秒調用一次 pushBlocak 方法
調用到了監聽器的,這個方法
數據會交給receivedBlockHandler進行存儲,也會保存的數據的元數據信息匯報給receiverTracker
ReceivedBlockHandler有兩種保存數據的方法,一種是預寫日志的方式,一種是直接進行存儲
感謝各位的閱讀,以上就是“Receiver怎么啟動”的內容了,經過本文的學習后,相信大家對Receiver怎么啟動這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是創新互聯,小編將為大家推送更多相關知識點的文章,歡迎關注!
當前文章:Receiver怎么啟動
URL網址:http://vcdvsql.cn/article14/peijge.html
成都網站建設公司_創新互聯,為您提供網站營銷、靜態網站、搜索引擎優化、外貿網站建設、網站建設、企業建站
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯