[開源]CSharpFlink（NET 5.0開發）分散式實時計算框架，PC機10萬數據點秒級計算測試說明

2020 年 11 月 19 日
筆記
個人

github地址：//github.com/wxzz/CSharpFlink
gitee地址：//gitee.com/wxzz/CSharpFlink

參考：[開源地址] 放棄Flink，.NET5.0開發CSharpFlink，簡要設計、部署及二次開發說明。

1 電腦硬體配置

CPU：4核 I5-7400 2.7GHz,記憶體：16G，隨機數據點時間窗口和計算運算元，主節點CPU和記憶體使用情況：15%-35%、1500MB-2048MB, 工作節點CPU和記憶體使用情況：0.1%-2.5%、18MB-30MB。運行效果，如下圖：

2 計算節點及任務配置

本機部署1個主節點，10個計算節點。主節點生成10萬個數據點的計算任務，每個數據點1秒鐘產生一個新數據，計算時間窗口的最大值、最小值、平均值或和值。

聚合計算類型：

計算統計:CSharpFlink.Core.Window.Operator.Avg:25003
計算統計:CSharpFlink.Core.Window.Operator.Max:24892
計算統計:CSharpFlink.Core.Window.Operator.Sum:25133
計算統計:CSharpFlink.Core.Window.Operator.Min:24972

數據點時間窗口統計：

窗口統計:60秒窗口:25015
窗口統計:5秒窗口:24976
窗口統計:3600秒窗口:25130
窗口統計:300秒窗口:24879

如下圖：

3 配製文件參數

如下圖：

（1）MaxDegreeOfParallelism：任務並行度，主節點生成任務、工作節點處理任務依賴這個參數。

（2）MasterListenPort：主節點偵聽埠，用於工作節點主動連接。

（3）MasterIp：主節點IP，用於工作節點主動連接。

（4）NodeType：節點運行模式，包括：Master、Slave和Both。

（5）RemoteInvokeInterval：遠程調用工作節點間隔時間，單位：毫秒。

（6）RepeatRemoteInvokeInterval：調用工作節點失敗後，重新調用工作節點間隔時間，單位：毫秒。

（7）SlaveExcuteCalculateInterval：工作節點執行計算任務間隔時間，單位：毫秒。

（8）MaxFrameLength：主節點和工作節點之間傳輸數據最大數據偵，單位：位元組。

（9）WorkerPower：工作節點能力係數，大於1，會連續發送多個任務。

4 部署結構示意

「mastercache」是主節點計算任務的快取，完成即時讓計算節點消費掉，部署結構示意，如下圖：

5 測試演示

測試演示，如下圖：

物聯網&大數據技術 QQ群：54256083

物聯網&大數據合作 QQ群：727664080

網站：//www.ineuos.net

聯繫QQ：504547114

合作微信：wxzz0151

官方部落格：//www.cnblogs.com/lsjwq

iNeuOS工業互聯網作業系統公眾號

Tags: 個人