公开(公告)号：CN114070563A

公开(公告)日：2022-02-18

申请号：CN202010761601.X

申请日：2020-07-31

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团有限公司

Inventor： 顾刚 ,  李宏源

IPC: H04L9/32 ,  G06F9/54 ,  G06F16/215

Abstract: 本申请实施例提供一种数据处理方法、装置、终端及存储介质，其中，所述方法包括：对待处理数据进行采集，将采集的数据写入消息缓存队列；如果消息缓存队列中的数据满足第一预设条件，将消息缓存队列中具有第一消息ID的数据发送至数据处理服务器，以使数据处理服务器对所述数据进行处理生成第二消息ID；接收数据处理服务器发送的所述第二消息ID；对所述第一消息ID和所述第二消息ID进行异或操作，确定所述异或操作的值；如果所述异或操作的值满足第二预设条件的数据的数量大于数量阈值，输出告警信息，如此，可以提高数据采集过程中的数据完整性。

公开(公告)号：CN112527471A

公开(公告)日：2021-03-19

申请号：CN201910887217.1

申请日：2019-09-19

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团有限公司

Inventor： 韩伟森 ,  顾刚 ,  初颖俊

IPC: G06F9/46

Abstract: 本申请实施例公开了一种任务处理方法及其装置、存储介质，任务处理方法应用于集群中的客户端，集群中包括多个能够互相通信的客户端，方法包括：接收任务发送端发送的第一任务；确定第一任务为可拆分的复合任务时，拆分第一任务，得到k个初级子任务；其中，k为正整数，k≥1；向对应的客户端发送k个初级子任务；其中，初级子任务对应的客户端由初级子任务的类型确定；接收对应的客户端发送的初级子任务的执行结果；根据各初级子任务的执行结果，确定第一任务的第一执行结果；向任务发送端发送第一执行结果。本申请实施例中通过将拆分得到的初级子任务发送给集群中的其他客户端，可以实现任务的分布式执行，降低各个客户端处的运算压力。

公开(公告)号：CN110365620A

公开(公告)日：2019-10-22

申请号：CN201810253282.4

申请日：2018-03-26

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团有限公司

Inventor： 周中民 ,  顾刚 ,  付怀勇

IPC: H04L29/06

Abstract: 本发明涉及大数据隐私保护技术领域，特别涉及一种流式数据隐私保护方法及装置。该方法为：将实时采集到的流式数据切分为多个数据块；针对上述多个数据块中每一隐私数据块分别执行以下操作：将一个隐私数据块切分为多个字段，并针对每一字段分别生成相应的包含有随机数，字段名和索引的三元组，其中，一个字段的随机数用于表征上述一个字段的移位信息，上述一个字段的索引用于表征上述一个字段的存储位置信息；采用数据拥有者的密钥对三元组进行加密处理，并将移位后的上述多个字段和每一字段分别对应的加密后的三元组存储至数据存储器，其中，不同的数据拥有者的密钥不同。

公开(公告)号：CN110351106B

公开(公告)日：2022-01-25

申请号：CN201810288830.7

申请日：2018-04-03

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团有限公司

Inventor： 付怀勇 ,  顾刚 ,  周中民

IPC: H04L41/12 ,  H04L43/08

Abstract: 本发明提供了一种网络结构的检测方法、装置、电子设备及存储介质，以及时发现待检测网络中的重要节点，通过重要节点确定网络结构。该方法包括：将待检测网络中的节点划分到不同的社区中，每个节点对应一个社区；根据节点与在其所在第一社区内其他节点之间连接的第一连接数量、节点的度以及划分得到的社区数量，计算得到表征节点角色的第一参数和第二参数；根据第一参数、第二参数以及预设的阈值范围，将节点的角色为设定角色的节点确定为重要节点；根据重要节点的角色，及重要节点之间连接的连接数量，计算相同角色或者不同角色的重要节点之间连接的Z‑score值；根据每个Z‑score值，确定当前待检测网络的网络结构。

公开(公告)号：CN110457183A

公开(公告)日：2019-11-15

申请号：CN201810427172.5

申请日：2018-05-07

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团有限公司

Inventor： 顾刚 ,  孙晓 ,  康姝婷 ,  杨晶 ,  董少杰 ,  杨涛 ,  付怀勇

IPC: G06F11/32 ,  G06F11/30

Abstract: 本发明实施例提供一种日志处理方法及装置，用以解决现有技术中电子设备产生的日志量大，导致电子设备运维难度大的技术问题。其中，所述方法包括：获得第一设备生成的为预设日志级别的第一日志，预设日志级别表示第一日志记录的信息包括故障信息；根据故障信息，确定第一日志为表示第一故障类别的日志；指示第一设备运行与第一故障类别匹配的第一验证工具，第一验证工具用于验证是否存在第一故障类别的故障；获得第一设备运行第一验证工具进行验证的验证结果，并根据验证结果确定是否对第一日志进行告警处理。

公开(公告)号：CN110278231A

公开(公告)日：2019-09-24

申请号：CN201810218498.7

申请日：2018-03-16

Applicant: 中移(苏州)软件技术有限公司 ,  中国移动通信集团上海有限公司 ,  中国移动通信集团有限公司

Inventor： 王妙琼 ,  周立 ,  陈磊 ,  任怡健 ,  温士帅 ,  徐硕 ,  顾刚

IPC: H04L29/08

Abstract: 本发明公开了一种数据订阅分发方法及系统，用以解决由于现有的消息队列服务局限于主题级的授权，使得用户订阅更细粒度的消息数据时增加了额外的处理流程对数据进行过滤而导致的浪费流量的问题。所述数据订阅分发方法包括：消息队列集群服务器接收订阅端发送的订阅请求，其中，所述订阅请求中携带请求订阅的字段名称；确定所述请求订阅的字段个数小于已存储的原主题Topic中的每条消息内容中的字段个数，所述原Topic为所述请求订阅的字段名称对应的字段内容隶属的Topic；从所述原Topic中提取所述请求订阅的字段内容，组成新的Topic；将所述新的Topic中的所述字段内容分发给所述订阅端。