公开(公告)号：CN104917825A

公开(公告)日：2015-09-16

申请号：CN201510259654.0

申请日：2015-05-20

Applicant: 中国科学院信息工程研究所

Inventor： 张闯 ,  陈蒙蒙 ,  李钊 ,  徐克付

IPC: H04L29/08 ,  H04L12/803

CPC classification number: H04L67/1002 ,  H04L47/125

Abstract: 本发明提供一种面向实时流计算平台的负载均衡方法，在无全局会话表情况下，保持会话一致性，实现云任务数据流量均衡。适应实时流计算平台节点多和数据流量大的特点。包括以下步骤：1)当前任务节点出现过载，则寻找迁移目的节点；2)从服务表中查询指向当前任务节点的数据项集合，然后向当前任务节点询问哪些数据项可以迁移至迁移目的节点；3)当前任务节点接收询问，连接表中的不活跃连接，得到可迁移数据项集合；4)根据可迁移数据项集合建立转发表，转发在所述服务表TD同步期内收的不一致数据；5)将转发表通知给状态级调度器，状态级调度器将转发表同步给所有上游任务节点；6)所有上游任务节点完成同步，删除转发表。

公开(公告)号：CN103812949A

公开(公告)日：2014-05-21

申请号：CN201410080647.X

申请日：2014-03-06

Applicant: 中国科学院信息工程研究所

Inventor： 张闯 ,  陈蒙蒙 ,  李钊 ,  徐克付

IPC: H04L29/08 ,  G06F9/50

Abstract: 本发明涉及一种面向实时云平台的任务调度与资源分配方法及系统，包括全局状态存储模块获取云平台的运行状况，将运行状况上报给全局状态监控模块；全局状态监控模块根据运行状况，利用任务分配矩阵、任务邻接矩阵和掩码矩阵制定相应的调度策略；根据调度策略在实时云平台中进行节点驱动型和/或任务驱动型任务调度与资源分配，本发明分配任务时充分考虑任务之间的关系、降低节点之间的通信量、减少带宽压力，从而提高平台性能；能很好的适应云平台动态调度的各种情况，保证云平台在运行过程中时刻保持较高的计算性能和资源利用率；且时间复杂度低，适合在具有大规模节点和大任务量的云环境中部署使用。

公开(公告)号：CN103346901A

公开(公告)日：2013-10-09

申请号：CN201310227114.5

申请日：2013-06-07

Applicant: 中国科学院信息工程研究所

Inventor： 张鹏 ,  杜华明 ,  徐克付 ,  张闯 ,  谭建龙

IPC: H04L12/24 ,  H04L29/08 ,  G06F17/30

Abstract: 本发明涉及一种面向数据流处理的元组跟踪方法及系统，该系统包括元组生成器、元组跟踪器和若干个元组处理器，元组生成器生成根元组并处理产生新的元组，然后，将新的元组发送给不同的元组处理器，元组处理器对接收的元组进行处理产生新的元组，每个根元组经过处理后会产生一个元组树，在每个元组树生成过程中，元组生成器向元组跟踪器发送该根元组的相关信息，供元组跟踪器构建该根元组的跟踪记录，元组跟踪器为每个根元组选择一个元组跟踪单元；每个元组处理器处理元组的过程中向元组跟踪器发送元组的相关信息来对跟踪记录的标识位进行更新，本发明可以实现大大降低内存开销，实现元组跟踪单元的负载均衡，提高元组处理的可靠性。