首页> 中国专利> 异构系统的数据传输方法、装置、计算机设备和存储介质

异构系统的数据传输方法、装置、计算机设备和存储介质

摘要

本申请涉及一种异构系统的数据传输方法、装置、计算机设备和存储介质。所述方法包括:服务器接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;服务器根据所述业务请求,下发指令至对应的已建立长连接的客户端;所述客户端用于对接企业内网与外网之间的交互数据;所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心,所述数据中心对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。采用本方法能够确保系统安全性的同时高效稳定的进行异构系统的数据传输。

著录项

  • 公开/公告号CN112291298A

    专利类型发明专利

  • 公开/公告日2021-01-29

    原文格式PDF

  • 申请/专利权人 云镝智慧科技有限公司;

    申请/专利号CN202010986011.7

  • 发明设计人 杨坤元;林洲;

    申请日2020-09-18

  • 分类号H04L29/08(20060101);H04L29/06(20060101);

  • 代理机构44224 广州华进联合专利商标代理有限公司;

  • 代理人方高明

  • 地址 518048 广东省深圳市福田区福田街道圩镇社区福田路24号海岸环庆大厦25层2501M房

  • 入库时间 2023-06-19 09:41:38

说明书

技术领域

本申请涉及计算机技术领域,特别是涉及一种异构系统的数据传输方法、装置、计算机设备和存储介质。

背景技术

随着计算机技术的发展,5G时代的来临,物联网的出现给现代生活带来了极大的便利,越来越多的企业可以通过使用企业内部的业务系统处理多种业务请求。各企业内部使用的业务系统,可能有多个业务系统如OA办公系统、业务处理系统等,不同企业之间使用的业务系统可能差异非常大,同时企业业务系统一般部署在企业内网,相关业务数据库基于安全考虑一般不能通过公网访问,当需要跨业务系统访问第三方企业的业务系统时,通常需要第三方企业直接开放企业数据库给外网访问。

然后,目前异构系统的数据传输时,采用直接开放企业数据库服务器给外网访问的方式,使得安全性大大降低,尤其涉及高并发的异构系统数据传输时,无法在确保系统安全性的同时进行有效的异构系统的数据传输。

发明内容

基于此,有必要针对上述技术问题,提供一种能够确保系统安全性的同时又能够有效的进行异构系统数据传输的异构系统的数据传输方法、装置、计算机设备和存储介质。

一种异构系统的数据传输方法,所述方法包括:

服务器接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;

服务器根据所述业务请求,下发指令至对应的已建立长连接的客户端;所述客户端用于对接企业内网与外网之间的交互数据;

所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心,所述数据中心对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。

在其中一个实施例中,所述业务请求中包含不同企业系统的业务;

所述将所述业务处理结果返回至所述数据中心之后,所述方法还包括:

所述数据中心根据所述业务处理结果,下发指令至与所述业务处理结果对应的下游客户端;

所述下游客户端根据所述指令,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心。

在其中一个实施例中,所述客户端与企业内网中的业务数据库连接;

所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,包括;

所述客户端根据所述指令中的业务处理逻辑,从企业内网中的业务数据库获取相关数据对所述业务请求相关的数据进行处理。

在其中一个实施例中,所述方法还包括:

所述异构系统还包括数据服务功能端;所述数据服务功能端用于通过预置功能账号发布优先级权限指令;

当服务启动时,所述数据服务功能端根据预先配置的启动参数接入服务器;所述服务器是长连接服务器集群;

当所述数据服务功能端接收到用户终端发送的控制指令时,根据所述控制指令,向所述长连接服务器集群下发指令,所述指令用于指示所述长连接服务器集群根据指令标识对客户端进行控制。在其中一个实施例中,所述将所述业务处理结果返回至所述数据中心之后,所述方法还包括:

通过长连接服务代理端接收第三方集成系统发送的服务调用请求;所述服务调用请求中携带所述第三方集成系统标识;所述长连接服务代理端用于将长连接功能端封装后将相应功能以服务形式进行发布,通过服务接口形式将指定功能提供给外部集成系统使用;

所述长连接服务代理端对所述第三方集成系统标识进行身份认证成功后,根据所述第三方集成系统标识调用对应的服务实例。

一种异构系统的数据传输装置,所述装置包括:

接收模块,用于服务器接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;

下发模块,用于服务器根据所述业务请求,下发指令至对应的已建立长连接的客户端;所述客户端用于对接企业内网与外网之间的交互数据;

处理模块,用于所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心,所述数据中心对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。

一种计算机设备,包括存储器和处理器,所述存储器存储有计算机程序,所述处理器执行所述计算机程序时实现以下步骤:

服务器接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;

服务器根据所述业务请求,下发指令至对应的已建立长连接的客户端;所述客户端用于对接企业内网与外网之间的交互数据;

所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心,所述数据中心对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。

一种计算机可读存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现以下步骤:

服务器接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;

服务器根据所述业务请求,下发指令至对应的已建立长连接的客户端;所述客户端用于对接企业内网与外网之间的交互数据;

所述客户端根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心,所述数据中心对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。

一种异构系统的数据传输方法,所述方法包括:

接收已建立长连接的客户端发送的指令;

根据所述指令中携带的目标客户端标识,将所述指令转发至对应的目标客户端;所述指令用于指示所述目标客户端从企业内网中获取相应的数据进行处理,得到与所述指令对应的处理结果;

接收到所述目标客户端返回的处理结果,并将所述处理结果推送至数据中心进行处理。

一种异构系统的数据传输装置,所述装置包括:

接收模块,用于接收已建立长连接的客户端发送的指令;

转发模块,用于根据所述指令中携带的目标客户端标识,将所述指令转发至对应的目标客户端;所述指令用于指示所述目标客户端从企业内网中获取相应的数据进行处理,得到与所述指令对应的处理结果;

推送模块,用于接收到所述目标客户端返回的处理结果,并将所述处理结果推送至数据中心进行处理。

一种计算机设备,包括存储器和处理器,所述存储器存储有计算机程序,所述处理器执行所述计算机程序时实现以下步骤:

接收已建立长连接的客户端发送的指令;

根据所述指令中携带的目标客户端标识,将所述指令转发至对应的目标客户端;所述指令用于指示所述目标客户端从企业内网中获取相应的数据进行处理,得到与所述指令对应的处理结果;

接收到所述目标客户端返回的处理结果,并将所述处理结果推送至数据中心进行处理。

一种计算机可读存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现以下步骤:

接收已建立长连接的客户端发送的指令;

根据所述指令中携带的目标客户端标识,将所述指令转发至对应的目标客户端;所述指令用于指示所述目标客户端从企业内网中获取相应的数据进行处理,得到与所述指令对应的处理结果;

接收到所述目标客户端返回的处理结果,并将所述处理结果推送至数据中心进行处理。

一种数据传输系统,包括:

长连接服务器集群,用于接收数据中心推送的业务请求;所述业务请求是用户终端发起的业务请求;根据所述业务请求,下发指令至对应的已建立长连接的客户端;

长连接客户端,用于对接企业内网与外网之间的交互数据;根据所述指令中的业务处理逻辑,对所述业务请求相关的数据进行处理,得到与所述业务请求相关的业务处理结果,并将所述业务处理结果返回至数据中心;

数据中心,用于对所述业务处理结果进行处理分析后,得到与所述业务请求对应的结果并返回至所述用户终端。

上述异构系统的数据传输方法、装置、计算机设备和存储介质,当需要跨业务系统进行数据传输时,服务器通过接收数据中心推送的业务请求,业务请求是用户终端发起的业务请求。相对于传统的数据传输方式,服务器可以根据业务请求,下发指令至对应的已建立长连接的客户端,客户端用于对接企业内网与外网之间的交互数据。客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。由此使得,基于长连接框架能够实现跨企业即跨业务系统场景下的数据交换传输,解决跨企业异构系统数据融合以及数据同步的问题,同时,也避免了客户端携带长连接集群的访问地址可能引发的网络服务攻击等安全性问题,确保系统安全性的同时又能够有效的进行异构系统数据传输。

附图说明

图1为一个实施例中异构系统的数据传输方法的应用环境图;

图2为一个实施例中异构系统的数据传输方法的流程示意图;

图3为一个实施例中异构系统的业务集成架构图;

图4为另一个实施例中异构系统的数据传输方法的流程示意图;

图5为一个实施例中异构系统的数据传输装置的结构框图;

图6为另一个实施例中异构系统的数据传输装置的结构框图;

图7为一个实施例中计算机设备的内部结构图。

具体实施方式

为了使本申请的目的、技术方案及优点更加清楚明白,以下结合附图及实施例,对本申请进行进一步详细说明。应当理解,此处描述的具体实施例仅仅用以解释本申请,并不用于限定本申请。

本申请提供的异构系统的数据传输方法,可以应用于如图1所示的应用环境中。其中,用户终端102通过网络与服务器104通过网络进行通信。客户端 106与服务器104通过网络进行通信。服务器104可以同时接收多个不同终端或客户端发送的指令,并根据接收到的指令执行相关操作或将指令进行转发。服务器104接收数据中心推送的业务请求,业务请求是用户终端102发起的业务请求。服务器104根据业务请求,下发指令至对应的已建立长连接的客户端106,客户端106用于对接企业内网与外网之间的交互数据。客户端106根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端102。其中,终端 102可以但不限于是各种个人计算机、笔记本电脑、智能手机、平板电脑和便携式可穿戴设备,服务器104可以用独立的服务器或者是多个服务器组成的服务器集群来实现。

在一个实施例中,如图2所示,提供了一种异构系统的数据传输方法,以该方法应用于图1中的系统为例进行说明,包括以下步骤:

步骤202,服务器接收数据中心推送的业务请求,业务请求是用户终端发起的业务请求。

各个企业可以通过采用统一的业务管理信息平台,将企业内部以及企业外部供应链上所有的资源与信息进行统一的管理,这种集成能够消除企业内部因部门分割造成的各种信息隔阂与信息孤岛,例如,利用企业资源计划系统就可以实现对整个供应链的有效管理,ERP即(Enterprise Resource Planning)企业资源计划,是一种主要面向制造行业进行物质资源、资金资源和信息资源集成一体化管理的企业信息管理系统。各企业内部使用的业务系统,可能有多个业务系统如OA办公系统、业务处理系统等,不同企业之间使用的业务系统可能差异非常大(异构系统)。同时,企业业务系统一般部署在企业内网,相关业务数据库基于安全考虑一般不能通过公网访问。具体的,用户可以通过在PC端或手机应用程序中或浏览器网页中输入用户名和密码的方式,登录特定场景的业务系统中,用户可以通过app(Application,应用程序)或web浏览器发起特定的业务请求,业务系统后台接收到用户终端发送的业务请求之后,通过数据中心将业务请求推送至服务器,服务器可以接收到数据中心推送的业务请求,业务请求中包含不同企业系统的业务。其中,用户终端是指与服务器相对应,为用户提供本地服务的程序。除了一些只在本地运行的应用程序之外,一般安装在普通的客户机上,需要与服务端互相配合运行。业务请求是指用户根据不同需求在不同业务场景系统中发起的与业务功能对应的业务请求,业务请求的处理过程中可能涉及供应链上下游不同的企业处理不同的数据,因而需要跨企业系统进行数据交互,才能得到最终的业务处理结果。企业可以根据不同的业务需求创建对应场景下的业务系统,例如,车联网业务系统、物联网系统等,不同企业的业务系统之间的业务数据是完全隔离的,业务数据可以包括业务服务数据、工单数据、组织机构数据等。针对同一个企业,在企业内部也可以创建多个不同场景下的业务系统,业务系统的用户管理中心使用统一的一套组织机构、角色信息和用户信息,即统一设置的组织机构、角色和用户等数据,是可以在同一企业中的各部门所共用的。企业的不同部门可以通过登录管理账号,在应用管理中心界面创建该部门自己的业务服务。不同企业或部门可以创建属于自己组织机构框架下的不同角色的用户以及不同场景的业务应用服务。例如,在网上购物应用中,用户需要创建一个订单,在这个业务请求的处理过程中需要读取“Customer”客户服务系统中的数据和“Product”产品服务系统中的数据。即服务器根据该用户端发送的创建订单请求,需要分别发送指令至客户服务系统和产品服务系统中查找对应的数据。用户可以通过触发操作发起创建订单请求,并通过系统中的数据中心将创建订单请求发送至服务器,该业务请求中包括用户终端标识,用户终端标识用于标识唯一的用户终端。

步骤204,服务器根据业务请求,下发指令至对应的已建立长连接的客户端,客户端用于对接企业内网与外网之间的交互数据。

当服务器接收数据中心推送的业务请求之后,服务器可以根据业务请求,下发指令至对应的已建立长连接的客户端,长连接客户端用于对接企业内网与外网之间的交互数据。其中,长连接客户端是在启动时根据登录账号自动连入长连接服务集群,与服务端保长持连接状态。例如,在网上购物系统中,用户可以通过触发操作发起创建订单请求,并通过服务网关或数据中心发送至服务器。当服务器接收到数据中心推送的该用户终端发送的创建订单请求时,则服务器可以根据创建订单请求,下发指令至对应的已建立长连接的客户端,该长连接客户端用于对接企业内网与外网之间的交互数据,可以实现以下功能:与企业业务数据库连接;接收来自服务端的工作指令,对指令进行处理,可以完成从企业业务数据库取数、写入数据的功能;实时检测网络状态,网络断开后自动恢复与服务器的连接;企业用户可按需要选择开启或禁止某些功能。

步骤206,客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。

服务器根据业务请求,下发指令至对应的已建立长连接的客户端之后,客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。其中,客户端对业务请求进行处理时,可能会同时需要获取该客户端对应的企业内网中数据库的数据。例如,当客户端接收到服务器转发的业务请求时,客户端对该业务请求进行处理时,客户端可以通过私有地址访问企业内网中的业务数据库对业务请求进行处理,得到与业务请求对应的业务处理结果之后,客户端可以通过公网地址与服务器保持长连接状态,实现企业内外网隔离,并将该业务处理结果返回至服务器,服务器再将该业务处理结果返回至数据中心,数据中心对该业务处理结果进一步进行处理分析后,得到与业务请求对应的结果并返回至用户终端。本申请中的服务器在原有服务功能之外扩展部署新的功能,服务器集群通过增加服务器并部署相关服务的线性资源扩展可以达到同时支持更多用户访问的能力。

本实施例中,当需要跨业务系统进行数据传输时,服务器通过接收数据中心推送的业务请求,业务请求是用户终端发起的业务请求。相对于传统的数据传输方式,服务器可以根据业务请求,下发指令至对应的已建立长连接的客户端,客户端用于对接企业内网与外网之间的交互数据。客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。由此使得,基于长连接框架能够实现跨企业即跨业务系统场景下的数据交换传输,解决跨企业异构系统数据融合以及数据同步的问题,同时,也避免了客户端携带长连接集群的访问地址可能引发的网络服务攻击等安全性问题,确保系统安全性的同时又能够有效的进行异构系统数据传输。

在一个实施例中,业务请求中包含不同企业系统的业务,将业务处理结果返回至数据中心之后,该方法还包括下发指令至与业务处理结果对应的下游客户端的步骤,具体包括:

数据中心根据业务处理结果,下发指令至与业务处理结果对应的下游客户端。

下游客户端根据指令,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心。

当客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心之后,由于业务请求中包含供应链中不同企业系统的业务,因而服务器还可以继续下发指令至与业务处理结果对应的下游客户端。具体的,如图3所示的异构系统的业务集成架构图。跨企业的异构系统即集成系统中的数据中心可以根据上游企业对应的客户端的业务处理结果,下发指令至与业务处理结果对应的下游客户端,使得下游客户端根据指令,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心。数据中心对该业务供应链中上下游企业客户端协同处理后的结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。由此使得,能够实现确保每个上下游企业系统安全性的同时,又能够使得与业务请求相关的供应链上下游企业客户端协同处理业务请求,有效的进行不同子系统之间的数据传输。

在一个实施例中,客户端与企业内网中的业务数据库连接,客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理的步骤,包括:

客户端根据指令中的业务处理逻辑,从企业内网中的业务数据库获取相关数据对业务请求相关的数据进行处理。

当服务器接收数据中心推送的业务请求之后,服务器可以根据业务请求,下发指令至对应的已建立长连接的客户端,向该业务请求处理过程中涉及的客户端下发指令,该指令用于指示客户端根据指令中的业务处理逻辑,从企业内网中的业务数据库获取相关数据对业务请求相关的数据进行处理。其中,客户端与企业内网中的业务数据库连接,该客户端可以在单独服务器安装,该服务器可通过私有地址访问业务数据库,通过公网地址与服务端连接,实现企业内外网隔离。本申请中客户端为打通企业内网及外网数据服务中心,例如,可在企业内网分配一台单独的机器进行部署,对该机器的网络访问可单独做安全策略配置,从而最小程度开放企业内网数据服务,从而有效确保系统进行数据传输时的安全性。具体的,客户端在启动时,可以通过登录账号的方式自动连入长连接服务集群,与服务器保持连接。服务器可以根据接收到的业务请求,下发指令至对应的已建立长连接的客户端,客户端与企业内网中的业务数据库连接,服务器下发的指令用于指示客户端从企业内网中获取相关数据对指令进行处理。本申请的长连接客户端可以包括短连接登录服务和长连接登录服务,用户通过账号密码经短连登录成功后,可获取长连接集群连接参数,客户端根据获取的长连接参数接入长连接服务集群。比如,当服务器集群接收到客户端A 发送的连接请求时,服务器根据连接请求返回对应的连接参数至客户端,并根据连接参数与客户端建立长连接,其中,客户端分配服务节点时自动负载均衡,例如,可根据服务节点客户端连接数,服务节点CPU或IO能力等进行自动进行分配。长连接服务器集群是指长连接服务采用集群架构,可防止单服务节点接入客户端单机限制,也可防止单节点服务中断造成服务停止,实现系统高可用性及实时扩容能力。服务端可以实现以下功能:管理长连接客户端接入;转发或下发指令给相应长连接客户端;实现服务节点之间相互通信,服务节点异常退出时自动转移相应客户端到其他服务节点管理;处理客户端请求指令(如数据上传),相关指令执行完成后将相应业务数据推送到数据中心。数据中心是指企业数据计算、存储、分析等处理中心,并可以对应用端提供数据服务。由此使得,通过长连接登录指令,确保登录的安全性,并通过构建高并发分布式指令交换架构,解决了跨企业业务数据集成的问题,实现了确保系统安全性的同时又能够有效的进行异构系统数据传输。

在一个实施例中,异构系统还包括数据服务功能端,数据服务功能端用于通过预置功能账号发布优先级权限指令。当服务启动时,数据服务功能端根据预先配置的启动参数接入服务器,服务器可以是长连接服务器集群,当数据服务功能端接收到用户终端发送的业务数据获取请求时,根据业务数据获取请求,通过短连接请求的方式从数据中心获取与业务数据请求对应的数据,并将数据返回至用户终端。其中,客户端包括数据服务功能端,即长连接功能端,长连接功能端是一种特殊的长连接客户端,通过分配特殊账号可执行高权限管理指令,如控制指定普通客户端等。长连接功能端用于通过预置功能账号发布优先级权限指令,不需要经过短连用户密码登录过程去获取长连接信息,当服务启动时,长连接功能端根据预先配置的启动参数接入长连接服务器集群,长连接功能端可以向服务器集群下发指令,该指令中携带指令标识,指令标识用于指示服务器集群根据指令标识对客户端进行控制。当数据服务功能端接收到用户终端发送的业务数据获取请求时,根据业务数据获取请求,通过短连接请求的方式从数据中心获取与业务数据请求对应的数据,并将数据返回至用户终端。此外,当数据服务功能端接收到用户终端发送的业务请求时,根据业务请求,通过长连接请求的方式将业务请求推送至服务器,并通过服务器根据业务请求,下发指令至对应的长连接客户端执行相关操作。由此使得,可以根据不同功能角色的划分,根据指令集的不同功能分配不同的端去处理,如客户端指令集主要在于接收数据上传等管理指令,并发起请求服务端分配存储空间指令等;长连接功能端负责具体的分配存储空间请求处理以及向服务器集群下发指令等,长连接功能端指令处理能力与普通连接客户端不同,有专门的处理指令集,通过将长连接功能端封装后将相应功能以服务形式进行发布,通过公开服务接口形式将功能端指定功能提供给其他集成系统或数据中心使用,从而有效解决了企业业务系统在内网部署的跨企业内网数据传输问题,并通过高并发可扩展集群实现了按需配置服务器系统资源。

在一个实施例中,将业务处理结果返回至数据中心之后,该方法还包括根据第三方集成系统标识调用对应的服务实例的步骤,具体包括:

通过长连接服务代理端接收第三方集成系统发送的服务调用请求,服务调用请求中携带第三方集成系统标识,长连接服务代理端用于将长连接功能端封装后将相应功能以服务形式进行发布,通过服务接口形式将指定功能提供给外部集成系统使用。

对第三方集成系统标识进行身份认证成功后,根据第三方集成系统标识调用对应的服务实例。

服务器将业务处理结果返回至数据中心之后,长连接服务器集群可以通过长连接服务代理端接收第三方集成系统发送的服务调用请求,服务调用请求中携带第三方集成系统标识,长连接服务代理端用于将长连接功能端封装后将相应功能以服务形式进行发布,通过服务接口形式将指定功能提供给第三方集成系统使用,即通过服务接口形式将指定功能提供给外部集成系统使用。长连接服务器集群可以通过长连接服务代理端对第三方集成系统标识进行身份认证成功后,根据第三方集成系统标识调用对应的服务实例。其中,长连服务代理端是一种特定的功能服务端的封装,针对数据中心交互功能进行服务封装,其他数据中心不直接接入本数据中心长连接集群,通过服务调用进行交互。长连服务代理端主要进行数据中心交互的身份认证和数据中心交互事宜的处理。长连接服务器集群具有服务节点自动保活功能,例如,通过zookeeper进行管理, ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google 的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。当服务节点断开后自动从集群中移除,所连接的客户端自动转移到其他服务节点。比如,某个服务节点异常终止服务后,服务器集群自动排除此节点继续为用户服务,原有连接在此节点的客户端检测到服务中断后会自动发起重连请求,服务端重新分配可用服务节点进行接入,从而达到自动恢复连接的效果。服务器集群支持资源的线程扩展,即服务器集群能同时接入的客户端也跟随线性扩展,即同时服务的客户端可以达到高并发,服务节点本身支持网络链路多路复用技术,单台服务节点即可达到较高的并发数。同时,长连接服务器集群还具有服务指令处理功能,可以实现指令接收处理、指令下发处理以及指令转发处理。例如,第三方集成系统可以是当前集成系统的子系统,比如,某政府工程系统中,当前集成系统可以为国家级异构系统,第三方集成系统则可以为下一级的省部级异构系统,每个集成系统中有包含多个子企业系统,每个子企业系统均设置有对应的长连接客户端。当长连接服务器集群通过长连接服务代理端接收第三方集成系统发送的服务调用请求时,长连接服务器集群可以根据服务调用请求中携带第三方集成系统标识,对第三方集成系统标识进行身份认证成功后,长连接服务器集群根据第三方集成系统标识调用对应的服务实例。由此使得,通过指令标识结合指令类型对不同指令进行安全权限验证和控制,能够通过身份验证,确保指令执行时业务的安全性以及确保企业异构系统之间数据交换的合规性,从而实现了系统安全稳定高效的进行异构系统之间的数据传输。

在一个实施例中,根据客户端标识调用对应的服务实例的步骤,包括:

获取客户端对应的版本信息。

根据版本信息调用对应版本的服务实例。

当服务器接收到客户端发送的请求或长连指令时,服务器对客户端标识进行身份认证,认证成功后,服务器可以根据客户端标识调用对应的服务实例。具体的,服务器可以获取客户端对应的版本信息,服务器根据版本信息调用对应版本的服务实例。其中,长连指令包括指令标识、指令类型、协议版本、序列号、数据包ID、来源ID、目标ID以及指令载荷。指令标识是指具体指令标识号,指令类型可以包括服务端指令、功能端指令以及客户端指令,服务器可以通过指令标识结合指令类型对指令进行安全权限控制。版本信息是指协议版本,即指令支持的协议版本,实现客户端指令兼容策略,低版本客户端不能执行高版本指令。序列号是指指令序列号,序列号可循环使用,可设定一个最大值,防止指令重发,系统自动丢弃已过期指令。数据包ID用于标识唯一的数据包,对该数据包的响应消息将回传此数据包ID,可用于跟踪数据的流转处理链路。来源ID是指从哪个端发出的指令(服务端、功能端或客户端)。目标ID或模板ID是指该指令要发给哪个端处理(服务端、功能端或客户端)。指令载荷是指指令携带的具体数据。例如,当服务器接收到客户端发送的指令时,服务器可以获取客户端对应的版本信息,该版本信息为版本1,则服务器根据上述版本信息调用对应版本1对应的服务实例。例如,指令A中包含版本1携带参数为c1、c2、c3。版本2增加了参数c4,即指令B中包含版本2携带参数为c1、 c2、c3、c4。高版本指令即指令B增加了参数,即指令B中版本2需要实现的功能效果已经不同,原有逻辑也可能已经修改,故原来接收低版本指令A的客户端不能执行高版本指令B。高版本指令可能是新增指令,低版本客户端不能识别并处理高版本的新增指令。由此使得,服务端通过接口形式将不同版本对应的指定功能提供给客户端使用,能够根据版本指令调用对应的版本的具体服务实例,服务端也可以根据客户端版本发送对应版本的指令,以实现不同版本的兼容。

在一个实施例中,如图4所示,提供了一种异构系统的数据传输方法,以该方法应用于图1中的服务器为例进行说明,包括以下步骤:

步骤402,接收已建立长连接的客户端发送的指令。

步骤404,根据指令中携带的目标客户端标识,将指令转发至对应的目标客户端,指令用于指示目标客户端从企业内网中获取相应的数据进行处理,得到与指令对应的处理结果。

步骤406,接收到目标客户端返回的处理结果,并将处理结果推送至数据中心进行处理。

服务器接收已建立长连接的客户端发送的业务指令,业务指令中包括目标客户端标识,该目标客户端标识可以为第三方客户端标识。目标客户端根据业务指令,从企业内网中获取相应的数据进行处理,得到与指令对应的处理结果,并将处理结果返回至服务器,服务器接收到目标客户端返回的处理结果,并将处理结果推送至数据中心进行处理。其中,长连接客户端可以接收并执行服务端指令,向服务端发送指令,通过服务端向其他企业客户端转发指令。指令类型可以包括业务相关(请求/响应)指令对,具有登录,登出,数据上传、更新、删除、回写等功能。指令类型还可以包括控制指令,可是实现立即上传数据,立即断开连接,清理数据上传方案,停止指定模块上传数据,立即升级客户端以及报告错误日志等功能。自动应答指令是指端接收到指令时自动应答上一个端。通用指令是指只定义了指令体,在相关载荷中自行定义业务处理逻辑。其他指令扩展是指根据业务需要可扩展指令集。长连接客户端在启动时根据登录账号自动连入长连接服务集群,与服务端保持连接。该客户端可以实现以下功能:与企业业务数据库连接,例如,客户端可以在单独服务器安装,该服务器可通过私有地址访问业务数据库,通过公网地址与服务端连接,实现企业内外网隔离。接收来自服务端的工作指令,对指令进行处理,可以完成从企业业务数据库取数、写入数据的功能。实时检测网络状态,网络断开后自动恢复与服务器的连接。企业用户可按需要选择开启或禁止某些功能。由此使得,能够解决企业业务系统在内网部署的跨企业内网数据传输问题,同时,从安全性和可扩展性确保系统安全稳定高效的传输数据,实现了集成系统的服务能力可扩展,高可靠以及高并发。

应该理解的是,虽然图1-4的流程图中的各个步骤按照箭头的指示依次显示,但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明,这些步骤的执行并没有严格的顺序限制,这些步骤可以以其它的顺序执行。而且,图1-4中的至少一部分步骤可以包括多个步骤或者多个阶段,这些步骤或者阶段并不必然是在同一时刻执行完成,而是可以在不同的时刻执行,这些步骤或者阶段的执行顺序也不必然是依次进行,而是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或者交替地执行。

在一个实施例中,如图5所示,提供了一种异构系统的数据传输装置,包括:接收模块502、下发模块504和处理模块506,其中:

接收模块502,用于服务器接收数据中心推送的业务请求,业务请求是用户终端发起的业务请求。

下发模块504,用于服务器根据业务请求,下发指令至对应的已建立长连接的客户端,客户端用于对接企业内网与外网之间的交互数据。

处理模块506,用于客户端根据指令中的业务处理逻辑,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心,数据中心对业务处理结果进行处理分析后,得到与业务请求对应的结果并返回至用户终端。

在一个实施例中,下发模块还用于数据中心根据业务处理结果,下发指令至与业务处理结果对应的下游客户端。处理模块还用于下游客户端根据指令,对业务请求相关的数据进行处理,得到与业务请求相关的业务处理结果,并将业务处理结果返回至数据中心。

在一个实施例中,处理模块还用于客户端根据指令中的业务处理逻辑,从企业内网中的业务数据库获取相关数据对业务请求相关的数据进行处理。

在一个实施例中,该装置还包括:获取模块。

获取模块用于当服务启动时,数据服务功能端根据预先配置的启动参数接入服务器,服务器是长连接服务器集群,当数据服务功能端接收到用户终端发送的控制指令时,根据控制指令,向长连接服务器集群下发指令,指令用于指示长连接服务器集群根据指令标识对客户端进行控制。在一个实施例中,该装置还包括:调用模块。

接收模块还用于通过长连接服务代理端接收第三方集成系统发送的服务调用请求,服务调用请求中携带第三方集成系统标识,长连接服务代理端用于将长连接功能端封装后将相应功能以服务形式进行发布,通过服务接口形式将指定功能提供给外部集成系统使用。调用模块用于对第三方集成系统标识进行身份认证成功后,根据第三方集成系统标识调用对应的服务实例。

在一个实施例中,如图6所示,提供了一种异构系统的数据传输装置,包括:接收模块602、转发模块604和推送模块606,其中:

接收模块602,用于接收已建立长连接的客户端发送的指令。

转发模块604,用于根据指令中携带的目标客户端标识,将指令转发至对应的目标客户端,指令用于指示目标客户端从企业内网中获取相应的数据进行处理,得到与指令对应的处理结果。

推送模块606,用于接收到目标客户端返回的处理结果,并将处理结果推送至数据中心进行处理。

关于异构系统的数据传输装置的具体限定可以参见上文中对于异构系统的数据传输方法的限定,在此不再赘述。上述异构系统的数据传输装置中的各个模块可全部或部分通过软件、硬件及其组合来实现。上述各模块可以硬件形式内嵌于或独立于计算机设备中的处理器中,也可以以软件形式存储于计算机设备中的存储器中,以便于处理器调用执行以上各个模块对应的操作。

在一个实施例中,提供了一种计算机设备,该计算机设备可以是服务器,其内部结构图可以如图7所示。该计算机设备包括通过系统总线连接的处理器、存储器和网络接口。其中,该计算机设备的处理器用于提供计算和控制能力。该计算机设备的存储器包括非易失性存储介质、内存储器。该非易失性存储介质存储有操作系统、计算机程序和数据库。该内存储器为非易失性存储介质中的操作系统和计算机程序的运行提供环境。该计算机设备的数据库用于存储异构系统的传输数据。该计算机设备的网络接口用于与外部的终端通过网络连接通信。该计算机程序被处理器执行时以实现一种异构系统的数据传输方法。

本领域技术人员可以理解,图7中示出的结构,仅仅是与本申请方案相关的部分结构的框图,并不构成对本申请方案所应用于其上的计算机设备的限定,具体的计算机设备可以包括比图中所示更多或更少的部件,或者组合某些部件,或者具有不同的部件布置。

在一个实施例中,提供了一种计算机设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,处理器执行计算机程序时实现上述各个方法实施例的步骤。

本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程,是可以通过计算机程序来指令相关的硬件来完成,所述的计算机程序可存储于一非易失性计算机可读取存储介质中,该计算机程序在执行时,可包括如上述各方法的实施例的流程。其中,本申请所提供的各实施例中所使用的对存储器、存储、数据库或其它介质的任何引用,均可包括非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(Read-Only Memory,ROM)、磁带、软盘、闪存或光存储器等。易失性存储器可包括随机存取存储器(Random Access Memory,RAM)或外部高速缓冲存储器。作为说明而非局限,RAM可以是多种形式,比如静态随机存取存储器(Static Random Access Memory, SRAM)或动态随机存取存储器(Dynamic Random Access Memory,DRAM)等。

以上实施例的各技术特征可以进行任意的组合,为使描述简洁,未对上述实施例中的各个技术特征所有可能的组合都进行描述,然而,只要这些技术特征的组合不存在矛盾,都应当认为是本说明书记载的范围。

以上所述实施例仅表达了本申请的几种实施方式,其描述较为具体和详细,但并不能因此而理解为对发明专利范围的限制。应当指出的是,对于本领域的普通技术人员来说,在不脱离本申请构思的前提下,还可以做出若干变形和改进,这些都属于本申请的保护范围。因此,本申请专利的保护范围应以所附权利要求为准。

去获取专利,查看全文>

相似文献

  • 专利
  • 中文文献
  • 外文文献
获取专利

客服邮箱:kefu@zhangqiaokeyan.com

京公网安备:11010802029741号 ICP备案号:京ICP备15016152号-6 六维联合信息科技 (北京) 有限公司©版权所有
  • 客服微信

  • 服务号