基於golang的slice /tumbling window流處理器

針對數據量不大，但流處理業務邏輯繁多的場景，golang 沒有須要引入flink那種很重的分佈式計算框架的需求併發 而golang的協程模式，自然適合處理多流併發讀的場景，框架 所以，最近作了個小工具，基於超時隊列技術實現流計算的 slice window、tumbling window分佈式 本文主要分享特定場景的處理思路，有須要源碼的可私聊~工具

>>阅读原文<<