跨平台事件协同处置方法及系统与流程

本发明涉及分布式信息处理，特别是基于分布式信息处理系统进行跨平台事件协调处理的。

背景技术：

1、在应急指挥、多级政务协同等领域，省、市、县等多级平台需要实现事件的跨级协同处置。在对多级平台系统进行事件的跨级协同功能升级改造过程中，由于各级平台通常由不同单位在不同时期独立建设，在改造过程中面临以下问题：

2、1、对平台进行接口改造、开发适配器，存在改造成本高、周期长的问题；同时，系统稳定性要求极高，任何代码改动都可能引发生产事故；

3、2、有些基层单位处于偏远地区，网络条件不稳定，存在高延迟、高丢包、频繁中断等现象；

4、3、对数据安全要求高，不能接受传统对接方式需要开放本地系统的http/api接口至外网的要求。

5、现有的针对跨平台数据同步需求的增量同步方案和中心化协调方案均难以在实施改造过程中解决上述问题。

技术实现思路

1、为了在对多级平台系统进行事件的跨级协同功能升级改造过程中解决前述问题，本发明提供了一种跨平台事件协同处置方法及系统。

2、本发明的技术方案如下：

3、跨平台事件协同处置方法，所述平台包括生成事件信息的源头平台和接收所述事件信息的接收平台，包括以下步骤：

4、p1、所述源头平台生成事件信息，所述事件信息包括全局标识、源头平台标识、分发关系树、事件创建时间；所述源头平台向所述接收平台推送所述事件信息；

5、p2、所述接收平台接收所述事件信息；

6、还包括事件状态快照分发步骤：

7、s1、所述源头平台生成事件状态快照；所述事件状态快照包括所述全局标识、事件处理状态、事件状态快照更新时间；所述源头平台向所述接收平台推送所述事件状态快照；

8、s2、所述接收平台收到所述事件状态快照后，根据所述全局标识和所述事件状态快照更新时间，更新本地事件状态数据库。

9、可选地，所述事件状态快照分发步骤还包括：

10、s3、所述接收平台更新所述事件状态快照，按所述分发关系树推送更新后的所述事件状态快照。

11、可选地，步骤s3中所述接收平台推送所述事件状态快照的顺序是：根据所述分发关系树先向下级平台推送，再向上级平台推送；若所述下级平台或所述上级平台为所述源头平台或向所述接收平台推送所述事件状态快照的平台，则所述接收平台不向所述下级平台或所述上级平台推送。

12、可选地，所述事件信息还包括消息签名；所述消息签名基于共享密钥生成；

13、所述接收平台接收到所述事件信息后，基于预存的所述共享密钥对所述消息签名进行验证。

14、可选地，所述事件状态快照更新时间包括以下分量：物理时间分量、逻辑计数分量、处理平台标识分量；

15、所述接收平台更新所述事件状态快照时，若当前物理时间晚于所述物理时间分量，则以所述当前物理时间更新所述物理时间分量，并将所述逻辑计数分量清零；若当前物理时间等于或早于所述物理时间分量，则将所述逻辑计数分量增加一个计数单位。

16、可选地，所述跨平台事件协同处置方法还包括以下步骤：

17、所述接收平台收到所述事件状态快照后，根据所述全局标识将所述事件状态快照中的所述事件状态快照更新时间与所述本地事件状态数据库存储的所述事件状态快照更新时间进行比较，若所述事件状态快照中的所述事件状态快照更新时间晚于所述本地事件状态数据库存储的所述事件状态快照更新时间，则以所述事件状态快照中的所述事件状态快照更新时间更新所述事件状态数据库。

18、可选地，所述事件状态快照包括反馈平台标识和反馈平台处理累计序号；所述接收平台根据所述反馈平台处理累计序号判断是否遗漏所述事件状态快照。

19、可选地，所述事件信息、所述事件状态快照包括事件处理平台列表和/或跳数；若所述接收平台已在所述事件处理平台列表中，则所述接收平台放弃接收所述事件信息、所述事件状态快照；若所述跳数达到或超过预设的跳数上限，则所述接收平台放弃接收所述事件信息、所述事件状态快照；所述跳数是所述事件信息、所述事件状态快照自所述源头平台开始被推送的次数。

20、执行如前所述方法的跨平台事件协同处置系统，包括所述源头平台和所述接收平台，在所述源头平台和所述接收平台中分别设置有旁路处理模块；所述旁路处理模块与所述源头平台和所述接收平台中的消息中间件连接，并用于执行以下步骤：

21、p1、所述源头平台生成事件信息，所述事件信息包括全局标识、源头平台标识、分发关系树、事件创建时间；所述源头平台向所述接收平台推送所述事件信息；

22、p2、所述接收平台接收所述事件信息；

23、还包括事件状态快照分发步骤：

24、s1、所述源头平台生成事件状态快照；所述事件状态快照包括所述全局标识、事件处理状态、事件状态快照更新时间；所述源头平台向所述接收平台推送所述事件状态快照；

25、s2、所述接收平台收到所述事件状态快照后，根据所述全局标识和所述事件状态快照更新时间，更新本地事件状态数据库。

26、可选地，所述事件状态快照更新时间包括以下分量：物理时间分量、逻辑计数分量、处理平台标识分量；

27、所述接收平台更新所述事件状态快照时，若当前物理时间晚于所述物理时间分量，则以所述当前物理时间更新所述物理时间分量，并将所述逻辑计数分量清零；若当前物理时间等于或早于所述物理时间分量，则将所述逻辑计数分量增加一个计数单位。

28、本发明的技术效果如下：

29、本发明的技术方案，可以在已有的平台系统设置旁路处理模块。旁路处理模块在执行相关步骤时通过平台系统的消息中间件进行异步通讯。旁路处理模块仅具有受控的平台消息中间件访问权限，可连接到外部平台的kafka集群进行主题订阅和消息推送，但不具有访问外部平台其他网络资源的权限。本地平台的业务接口不对外暴露，防火墙仅需开放消息中间件的一个端口即可，满足了对安全性的要求。同时，旁路处理模块的设置对平台原有系统改动小，降低了改造成本与周期。

30、本发明的技术方案，通过事件信息的传递即可进行事件协同处置，无需依赖中心化节点即可独立完成消息来源识别和防重复判断，实现了去中心化的协同；同时避免了传统token鉴权所需的网络往返开销。事件状态快照的传递，需要传递的信息量较小，可简化同步逻辑、降低状态不一致风险。

31、综上所述，本发明的技术方案实现了本发明的目的。

32、上述可选方式所具有的进一步效果，将在下文中结合具体实施方式加以说明。

1.跨平台事件协同处置方法，所述平台包括生成事件信息的源头平台和接收所述事件信息的接收平台，其特征在于：包括以下步骤：

2.根据权利要求1所述跨平台事件协同处置方法，其特征在于：所述事件状态快照分发步骤还包括：

3.根据权利要求2所述跨平台事件协同处置方法，其特征在于：步骤s3中所述接收平台推送所述事件状态快照的顺序是：根据所述分发关系树先向下级平台推送，再向上级平台推送；若所述下级平台或所述上级平台为所述源头平台或向所述接收平台推送所述事件状态快照的平台，则所述接收平台不向所述下级平台或所述上级平台推送。

4.根据权利要求1所述跨平台事件协同处置方法，其特征在于：所述事件信息还包括消息签名；所述消息签名基于共享密钥生成；

5.根据权利要求1所述跨平台事件协同处置方法，其特征在于：所述事件状态快照更新时间包括以下分量：物理时间分量、逻辑计数分量、处理平台标识分量；

6.根据权利要求5所述跨平台事件协同处置方法，其特征在于：还包括以下步骤：

7.根据权利要求1所述跨平台事件协同处置方法，其特征在于：所述事件状态快照包括反馈平台标识和反馈平台处理累计序号；所述接收平台根据所述反馈平台处理累计序号判断是否遗漏所述事件状态快照。

8.根据权利要求1所述跨平台事件协同处置方法，其特征在于：所述事件信息、所述事件状态快照包括事件处理平台列表和/或跳数；若所述接收平台已在所述事件处理平台列表中，则所述接收平台放弃接收所述事件信息、所述事件状态快照；若所述跳数达到或超过预设的跳数上限，则所述接收平台放弃接收所述事件信息、所述事件状态快照；所述跳数是所述事件信息、所述事件状态快照自所述源头平台开始被推送的次数。

9.执行如权利要求1所述方法的跨平台事件协同处置系统，其特征在于：包括所述源头平台和所述接收平台，在所述源头平台和所述接收平台中分别设置有旁路处理模块；所述旁路处理模块与所述源头平台和所述接收平台中的消息中间件连接，并用于执行以下步骤：

10.根据权利要求9所述系统，其特征在于：所述事件状态快照更新时间包括以下分量：物理时间分量、逻辑计数分量、处理平台标识分量；