溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Storm ACK框架知識點有哪些

發布時間:2021-12-23 14:00:07 來源:億速云 閱讀:156 作者:iii 欄目:云計算

本篇內容介紹了“Storm ACK框架知識點有哪些”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!

1: 在Ack框架的設計之中,Storm發射出去的消息都會對應于一個隨機的消息ID號。

2 : Spout發射消息之后。將像Acker Bolt發射一個消息,這個消息的內容為 《RootID,消息ID》 Acker Bolt將會為該消息創

建一條跟蹤項

3: Bolt產生要發射的消息的過程之中,也會將該消息ID發射Acker Bolt,AckerBolt 對消息ID進行異或以后進行存儲。

4: Bolt在對于輸入的消息進行Ack的過程之中,也會將該消息ID發射到 AckerBolt,Acker Bolt對于消息ID進行亦或以后再存儲,由于該消息在被發射之時,已經向Acker Bolt發射過了ID,之后在被Ack 時又再次發射該消息ID,一句 【與或】的語義,這相當于對于該消息的跟蹤的結束。

5:Acker Bolt 在更新某一個消息的跟蹤值時,若發現他的值變為0,那么就會像Spout節點發射消息,表名,Spout發射的這條消息已經被成功的處理 。

6:所有消息的消息ID 都將更新到最  根上( /root ) 樹上的,根消息為Spout發射出去的消息,Bolt新產生的消息并不會被單獨跟蹤

7:如果你在發射的過程之中,沒有指定用于消息跟蹤的ID,那么系統就不對消息進行跟蹤,若系統中不含有Ack bolt,消息也不會被跟蹤。

8: Spout的每條消息以及該消息所演化出來的消息的跟蹤 容量負載為:《16個字節》,8個字節的根消息ID,以及8個字節的消息跟蹤值《AckValue》,  事實上,由于Storm中采用的是HashMap對其進行的跟蹤,在32位的JVM之中,每條消息至少需要20個字節的額外負載,故有一條消息的跟蹤需要 40個左右的負載。

“Storm ACK框架知識點有哪些”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女