實時處理系統的自動化測試

       storm是分佈式的消息處理系統,spout任務發射出一條消息之後,可能要經過很多bolt任務的處理,而ack任務就負責跟蹤每條消息的處理情況,直到所有的bolt都處理完畢。由於業務上的需要,不同類型的消息可能經過的bolt也不一樣,不同的消息可能會做合併,那將各種複雜的場景抽象之後,spout、消息、以及bolt構成的是一張張有向圖,如下圖所示:   spout是數據源頭,也是有向
相關文章
相關標籤/搜索