(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111512414.9 (22)申请日 2021.12.08 (71)申请人 中盈优创资 讯科技有限公司 地址 200000 上海市嘉定区安亭镇杭桂 路 1112号10层10 04室-4 (72)发明人 王磊　 (74)专利代理 机构 上海嘉蓝专利代理事务所 (普通合伙) 31407 代理人 金波 (51)Int.Cl. H04L 9/40(2022.01) H04L 47/80(2022.01) H04L 43/0888(2022.01) (54)发明名称 一种NetFl ow流量还原的方法及装置 (57)摘要 本发明公开一种NetFlow流量还原的方法及 装置， 其中， 该方法包括： 在Flink流计算引擎内 置的滑动窗口中缓存自定义时间内的NetFlow流 量数据； 将滑动窗口中的NetFlow流量时序数据 打上权重标签； 将滑动窗口中的NetFlow流量数 据通过加权平均算法计算出当前滑动窗口内的 流量平均值， 再乘以采样比率， 即可输出客户当 前网络的流量。 该方法及装置可以最大程度还原 客户当前网络的流 量。 权利要求书2页 说明书5页 附图1页 CN 114221800 A 2022.03.22 CN 114221800 A 1.一种NetFl ow流量还原的方法， 其特 征在于， 该 方法包括： 在Flink流计算引擎内置的滑动窗口中缓存自定义时间内的NetFl ow流量数据； 将滑动窗口中的NetFl ow流量时序数据打上权 重标签； 将滑动窗口中的NetFlow流量数据通过加权平均 算法计算出当前滑动窗口内的流量平 均值， 再乘以采样比率， 即可输出客户当前网络的流 量。 2.根据权利 要求1所述的NetFlow流量还原的方法， 其特征在于， 在 Flink流计算引擎 内 置的滑动窗口中缓存自定义时间内的NetFl ow流量数据， 包括： 采集解析程序通过UDP协议收集到NetFlow报文后， 将其解析并封装为JSON对象， 发送 到消息中间件的消息队列中； Flink流计算引擎的程序实时拉取消息队列中的NetFlow流量数据， 存放到滑动窗口 中， 使用自定义滑动距离和窗口长度的数据模型存 储NetFlow流量数据。 3.根据权利要求1所述的NetFlow流量还原的方法， 其特征在于， 将滑动窗口中的 NetFlow流量时序数据打上权 重标签， 包括： 根据存入滑动窗口 的前后时间顺序， 按照权 重由小到大， 打上权 重标签。 4.根据权利要求1所述的NetFlow流量还原的方法， 其特征在于， 所述加权平均算法如 下： m＝(k1*a1+k2*a2+k3 *a3+....+kn*an)/(k1+k2+k3+. ..+kn) 其中， k代表权重大小， a代表当前滑动窗口内的流量大小， m代表当前滑动窗口内的平 均流速。 5.一种NetFl ow流量还原的装置， 其特 征在于， 该装置包括： NetFlow流量数据预处理模块， 用于在 Flink流计算引擎 内置的滑动窗口中缓存自定义 时间内的NetFl ow流量数据， 并将滑动窗口中的NetFl ow流量时序数据打上权 重标签； NetFlow流量计算模块， 用于将滑动窗口中的NetFlow流量数据 通过加权平均算法计算 出当前滑动窗口内的流 量平均值， 再乘以采样比率， 即可输出客户当前网络的流 量。 6.根据权利 要求5所述的NetFlow流量还原的装置， 其特征在于， 在 Flink流计算引擎 内 置的滑动窗口中缓存自定义时间内的NetFl ow流量数据， 包括： 采集解析程序通过UDP协议收集到NetFlow报文后， 将其解析并封装为JSON对象， 发送 到消息中间件的消息队列中； Flink流计算引擎的程序实时拉取消息队列中的NetFlow流量数据， 存放到滑动窗口 中， 使用自定义滑动距离和窗口长度的数据模型存 储NetFlow流量数据。 7.根据权利要求5所述的NetFlow流量还原的装置， 其特征在于， 将滑动窗口中的 NetFlow流量时序数据打上权 重标签， 包括： 根据存入滑动窗口 的前后时间顺序， 按照权 重由小到大， 打上权 重标签。 8.根据权利要求5所述的NetFlow流量还原的装置， 其特征在于， 所述加权平均算法如 下： m＝(k1*a1+k2*a2+k3 *a3+....+kn*an)/(k1+k2+k3+. ..+kn) 其中， k代表权重大小， a代表当前滑动窗口内的流量大小， m代表当前滑动窗口内的平 均流速。 9.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计权　利　要　求　书 1/2 页 2 CN 114221800 A 2算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求 1‑4任一项所述方 法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有执行权利 要求1‑4任一项所述方法的计算机程序。权　利　要　求　书 2/2 页 3 CN 114221800 A 3