storm ack機制流程詳解

storm ack機制如今網上一堆資料。根據個人理解,對可靠版的word count進行了流程分析。函數 spout每發出一條信息,會根據用戶指定的message id生成root id(假設爲111),用於標記本次數據流;不論bolt仍是spout,ack val = (輸入tuple id) ^ (全部輸出tuple id的異或結果),只不過ack val的輸入tuple不存在。acker b
相關文章
相關標籤/搜索