基于元数据的时空大数据REST微服务数据交互方法和系统

摘要

本发明提供了一种基于元数据的时空大数据REST微服务数据交互方法，利用时空大数据分布式REST微服务返回的JSON数据包包括操作数据、路由数据、请求数据和响应数据；操作数据包括GETMETA操作数据和GETDATA操作数据，通过路由数据使用GETMETA操作数据发送请求数据获取元数据信息，GETDATA操作数据根据响应数据获取时空大数据；路由数据标识工业互联网系统和时空大数据REST微服务，包括源地址数据和目标地址数据。本发明解决了时空大数据REST微服务的调用端无法智能识别时空大数据REST服务返回数据的语义的技术问题，同时，解决了在工业互联网系统内以及跨工业互联网系统提供统一方法访问时空大数据REST服务的技术问题。

说明书

技术领域

本发明涉及工业互联网的技术领域，具体地，涉及一种基于元数据的时空大数据REST微服务数据交互方法和系统。

背景技术

在宝武集团的工业互联网中，各个钢铁厂均部署有工业互联网，每个工业互联网利用时空大数据REST微服务架构进行访问。例如，鄂城钢铁工业互联网系统的时空大数据REST服务仅可以在鄂城钢铁访问，湛江钢铁工业互联网系统的时空大数据REST服务仅可以在湛江钢铁访问，但是在实际应用中，跨工业互联网系统访问时空大数据REST服务的需求存在。

通常情况下，REST服务使用JSON数据格式进行数据交互，REST服务返回的 JSON数据是一个Key-Value的键值对，是不具有元数据信息的。开发人员在使用时空大数据REST服务时，通常是去查看REST服务接口文档，然后按照接口文档描述的参数说明和返回值说明去调用时空大数据REST服务。这对于时空大数据REST 微服务的调用端来说存在问题，因为，对于时空大数据REST微服务的调用端来说，是不可能知道时空大数据REST服务返回的数据中，哪些数据是空间数据，更不可能知道这些空间数据是点、是线、还是面。

经过检索，专利文献CN111752965A，公开了一种基于微服务的实时数据库数据交互方法和系统，通过将SQL操作请求嵌入REST请求报文体中，采用服务网关技术实现对REST访问请求的接收和http报文头解析，并将请求负载均衡到访问请求执行微服务实例中，访问请求执行微服务实例解析微服务RESTful请求报文，提取其中的SQL请求内容，调用实时库SQL接口执行并返回执行结果。该现有技术解决的是实时数据库的数据交互问题，但是并不能解决时空大数据的数据交互问题。

专利文献CN110096653A，公开了一种时空信息服务架构的构建方法。该方法包括：获取时空信息服务接口对应的目标时空数据；根据目标时空数据，确定时空信息服务接口对应的接口类别；根据接口类别查找时空信息服务接口对应的RESTful风格和RESTful风格对应的配置要求；根据RESTful风格和配置要求，对时空信息服务接口进行改造，得到符合REST架构的时空信息服务接口规范；根据时空信息服务接口规范，构建时空信息服务架构。该现有技术解决的是异构平台无法实现资源服务共享，数据融合的技术问题，并不能解决时空大数据的数据交互问题。

因此，迫切需要开发一种跨工业互联网系统访问时空大数据REST服务的数据交互方法和系统。

发明内容

针对现有技术中的缺陷，本发明的目的是提供一种基于元数据的时空大数据REST微服务数据交互方法及系统，解决了时空大数据REST微服务的调用端无法智能识别时空大数据REST服务返回数据的语义的技术问题，同时，解决在工业互联网系统内以及跨工业互联网系统提供统一方法访问时空大数据REST服务的技术问题，使得交互体验上，在工业互联网系统内访问时空大数据REST服务与跨工业互联网系统访问时空大数据REST服务，访问方法是完全相同的。

根据本发明提供的一种基于元数据的时空大数据REST微服务数据交互方法，利用时空大数据分布式REST微服务返回的JSON数据包包括操作数据、路由数据、请求数据和响应数据；

操作数据包括GETMETA操作数据和GETDATA操作数据，通过路由数据使用 GETMETA操作数据发送请求数据获取元数据信息，GETDATA操作数据根据响应数据获取时空大数据；

路由数据标识工业互联网系统和时空大数据REST微服务，包括源地址数据和目标地址数据。

优选地，包括如下步骤：

步骤S1：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETMETA操作调用请求；

步骤S2：时空大数据REST微服务网关将REST微服务GETMETA操作调用请求路由到时空大数据REST微服务；

步骤S3：时空大数据REST微服务发送REST微服务GETMETA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关；

步骤S4：时空大数据REST微服务网关将REST微服务GETMETA操作的响应数据路由到时空大数据REST微服务的调用端；

步骤S5：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETDATA操作调用请求；

步骤S6：时空大数据REST微服务网关将REST微服务GETDATA操作调用请求路由到时空大数据REST微服务；

步骤S7：时空大数据REST微服务发送REST微服务GETDATA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关；

步骤S8：时空大数据REST微服务网关将REST微服务GETDATA操作的响应数据路由到时空大数据REST微服务的调用端；

GETMETA操作是指获取REST微服务的元数据信息；

GETDATA操作是指REST微服务提供的数据查询服务。

优选地，步骤S1包括如下步骤：

步骤S1.1：时空大数据REST微服务的调用端在系统开始运行时，从所在工业互联网系统的时空大数据REST微服务网关获取时空大数据REST微服务注册信息表，并定时更新，在内存中保持一份最新的本工业互联网系统的时空大数据REST 微服务注册信息表；

步骤S1.2：构造时空大数据REST微服务GETMETA操作调用请求JSON数据包；

步骤S1.3：时空大数据REST微服务的调用端比对时空大数据REST微服务的 GUID和自身的GUID，若处于同一个工业互联网系统，则查找时空大数据REST微服务注册信息表，直接与时空大数据REST微服务建立HTTP或者HTTPS连接；若处于不同的工业互联网系统，则与本工业互联网系统的时空大数据REST微服务网关建立HTTP或者HTTPS连接；

步骤S1.4：时空大数据REST微服务的调用端通过HTTP或者HTTPS连接向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务 GETMETA操作调用请求JSON数据包。

优选地，步骤S2包括如下步骤：

步骤S2.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持 TCP/IP长连接，减少建立HTTP或HTTPS短连接的耗时，建立高速通讯通道加速时空大数据REST微服务路由；

步骤S2.2：时空大数据REST微服务网关解析时空大数据REST微服务 GETMETA操作调用请求JSON数据包，根据路由数据中的目标地址数据查找时空大数据REST微服务网关静态路由表；

步骤S2.3：时空大数据REST微服务网关将时空大数据REST微服务GETMETA 操作调用请求JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址数据对应工业互联网系统的时空大数据REST微服务网关；

步骤S2.4：目标地址的时空大数据REST微服务网关与路由数据中的目标地址所指向的时空大数据REST微服务建立HTTP或者HTTPS连接；

步骤S2.5：目标地址的时空大数据REST微服务网关通过HTTP或者HTTPS连接将时空大数据REST微服务GETMETA操作调用请求JSON数据包发送到路由数据中的目标地址Destination所指向的时空大数据REST微服务。

优选地，步骤S3包括如下步骤：

步骤S3.1：时空大数据REST微服务接收到时空大数据REST微服务的调用端或者时空大数据REST微服务网关发送的时空大数据REST微服务GETMETA操作调用请求JSON数据包；

步骤S3.2：构造REST微服务GETMETA操作响应JSON数据包；

步骤S3.3：将REST微服务GETMETA操作响应JSON数据包通过步骤1.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端或者通过步骤2.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务网关。

优选地，步骤S4包括如下步骤：

步骤S4.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持 TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，以便建立高速通讯通道加速时空大数据REST微服务路由；

步骤S4.2：时空大数据REST微服务网关解析时空大数据REST微服务 GETMETA操作响应JSON数据包，根据路由数据中的目标地址查找时空大数据 REST微服务路由表；

步骤S4.3：时空大数据REST微服务网关将时空大数据REST微服务GETMETA 操作响应JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关；

步骤S4.4：目标地址的时空大数据REST微服务网关将时空大数据REST微服务GETMETA操作响应JSON数据包通过步骤S1.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端。

优选地，步骤S5包括如下步骤：

步骤S5.1：时空大数据REST微服务的调用端在系统开始运行时，从当前所在工业互联网系统的时空大数据REST微服务网关获取时空大数据REST微服务注册信息表，并定时更新，在内存中保持一份最新的本工业互联网系统的时空大数据 REST微服务注册信息表；

步骤S5.2：构造时空大数据REST微服务GETDATA操作调用请求JSON数据包；

步骤S5.3：时空大数据REST微服务的调用端比对时空大数据REST微服务的 GUID和自身的GUID，若处于同一个工业互联网系统，则查找时空大数据REST微服务注册信息表，直接与时空大数据REST微服务建立HTTP或者HTTPS连接；若处于不同的工业互联网系统，则与本工业互联网系统的时空大数据REST微服务网关建立HTTP或者HTTPS连接；

步骤S5.4：时空大数据REST微服务的调用端通过HTTP或者HTTPS连接向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务 GETDATA操作调用请求JSON数据包；

优选地，步骤S6包括如下步骤：

步骤S6.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持 TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，建立高速通讯通道加速时空大数据REST微服务路由；

步骤S6.2：时空大数据REST微服务网关解析时空大数据REST微服务 GETDATA操作调用请求JSON数据包，根据路由数据中的目标地址查找时空大数据REST微服务网关静态路由表；

步骤S6.3：时空大数据REST微服务网关将时空大数据REST微服务GETDATA 操作调用请求JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关；

步骤S6.4：目标地址Destination的时空大数据REST微服务网关查找内存中最新的时空大数据REST微服务注册信息表，与路由数据中的目标地址所指向的时空大数据REST微服务建立HTTP或者HTTPS连接；

步骤S6.5：目标地址的时空大数据REST微服务网关通过HTTP或者HTTPS连接将时空大数据REST微服务GETDATA操作调用请求JSON数据包发送到路由数据中的目标地址所指向的时空大数据REST微服务。

优选地，步骤S7包括如下步骤：

步骤S7.1：时空大数据REST微服务接收到时空大数据REST微服务的调用端或者时空大数据REST微服务网关发送的时空大数据REST微服务GETDATA操作调用请求JSON数据包；

步骤S7.2：构造REST微服务GETDATA操作响应JSON数据包；

步骤S7.3：将REST微服务GETDATA操作响应JSON数据包通过步骤5.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端或者通过步骤6.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务网关；

步骤S8包括如下步骤：

步骤S8.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，建立高速通讯通道加速时空大数据REST微服务路由；

步骤S8.2：时空大数据REST微服务网关解析时空大数据REST微服务 GETDATA操作响应JSON数据包，根据路由数据中的目标地址查找时空大数据 REST微服务路由表；

步骤S8.3：时空大数据REST微服务网关将时空大数据REST微服务GETDATA 操作响应JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关；

步骤S8.4：目标地址的时空大数据REST微服务网关将时空大数据REST微服务GETDATA操作响应JSON数据包通过步骤5.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端。

根据本发明提供的一种基于元数据的时空大数据REST微服务数据交互系统，包括：

模块M1：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETMETA操作调用请求；

模块M2：时空大数据REST微服务网关将REST微服务GETMETA操作调用请求路由到时空大数据REST微服务；

模块M3：时空大数据REST微服务发送REST微服务GETMETA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关；

模块M4：时空大数据REST微服务网关将REST微服务GETMETA操作的响应数据路由到时空大数据REST微服务的调用端；

模块M5：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETDATA操作调用请求；

模块M6：时空大数据REST微服务网关将REST微服务GETDATA操作调用请求路由到时空大数据REST微服务；

模块M7：时空大数据REST微服务发送REST微服务GETDATA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关；

模块M8：时空大数据REST微服务网关将REST微服务GETDATA操作的响应数据路由到时空大数据REST微服务的调用端；

GETMETA操作是指获取REST微服务的元数据信息；

GETDATA操作是指REST微服务提供的数据查询服务。

与现有技术相比，本发明具有如下的有益效果：

1、本发明通过时空大数据REST微服务的数据交互方法很容易对跨工业互联网系统访问时空大数据REST微服务进行鉴权和实现负载均衡，也便于网络管理员对工业互联网系统配置网络防火墙，解决了跨工业互联网系统访问时空大数据REST 微服务的数据交互问题。对于时空大数据REST微服务的调用端来说，访问本工业互联网系统的时空大数据REST微服务和跨工业互联网系统访问时空大数据REST 微服务是一样的，完全是透明的。

2、本发明利用元数据解决了时空大数据REST微服务的调用端智能识别时空大数据REST微服务返回数据的问题，时空大数据REST微服务的调用端完全可以根据元数据智能识别时空大数据REST服务返回的数据中，哪些数据是空间数据，也能智能识别这些空间数据是点、是线、还是面。开发人员完全不需要去查看REST 微服务接口文档，也完全不用担心REST微服务接口文档与REST微服务实际接口可能存在不一致的情况。

3、本发明利用元数据解决了时空大数据REST微服务智能识别时空大数据 REST微服务的调用端发送的调用请求的问题，时空大数据REST微服务能智能识别时空大数据REST微服务的调用端发送的请求参数中，哪些数据是空间数据，也能智能识别这些空间数据是点、是线、还是面，也能智能识别是做哪种空间查询，例如，时空大数据REST微服务的调用端发送的请求参数的元数据可以指定空间定位查询、按点查询、按矩形查询、按圆查询、按多边形查询、空间关系查询、邻接查询、包含关系查询、穿越查询、落入查询、缓冲区查询、属性-空间查询、单属性查找、SQL查询、扩展的SQL查询。

附图说明

通过阅读参照以下附图对非限制性实施例所作的详细描述，本发明的其它特征、目的和优点将会变得更明显：

图1为本发明中基于元数据的时空大数据REST微服务数据交互方法步骤流程图；

图2为本发明中工业互联网系统时空大数据REST微服务架构示意图；

图3为本发明中时空大数据REST微服务网关双向链路架构示意图。

具体实施方式

下面结合具体实施例对本发明进行详细说明。以下实施例将有助于本领域的技术人员进一步理解本发明，但不以任何形式限制本发明。应当指出的是，对本领域的普通技术人员来说，在不脱离本发明构思的前提下，还可以做出若干变化和改进。这些都属于本发明的保护范围。

如图1-图3所示，本发明提供了一种基于元数据的时空大数据REST微服务数据交互方法，利用时空大数据分布式REST微服务返回的JSON数据包包括操作数据、路由数据、请求数据和响应数据；操作数据包括GETMETA操作数据和GETDATA操作数据，通过路由数据使用GETMETA操作数据发送请求数据获取元数据信息，GETDATA 操作数据根据响应数据获取时空大数据；路由数据标识工业互联网系统和时空大数据 REST微服务，包括源地址数据和目标地址数据。

操作数据、路由数据、请求数据和响应数据进行交互的区域一一对应操作区、路由区、请求区和响应区；路由区包含源地址和目标地址，源地址目标地址均为GUID，其中前两节标识工业互联网系统，后三节标识时空大数据REST微服务，例如6eae233e- 1499-4c61-96ad-fb81c1729094，其中6eae233e-1499标识鄂城钢铁工业互联网系统，4c61- 96ad-fb81c1729094标识时空大数据REST微服务，6eae233e-1499-0000-0000- 000000000000标识时空大数据REST微服务网关；请求区包含请求参数的元数据子区和请求参数的数据值子区以及对响应区的控制参数子区，将Key-Value中的Key存储在元数据子区，Value存放在数据值子区，控制参数子区用于控制响应区返回的数据；响应区包含返回数据的元数据子区和数据值子区，将Key-Value中的Key存储在元数据子区， Value存放在数据值子区。

具体地，包括如下步骤：

步骤S1：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETMETA操作调用请求。

步骤S1.1：时空大数据REST微服务的调用端在系统开始运行时，从所在工业互联网系统的时空大数据REST微服务网关获取时空大数据REST微服务注册信息表，并定时更新，在内存中保持一份最新的本工业互联网系统的时空大数据REST微服务注册信息表。

步骤S1.2：构造时空大数据REST微服务GETMETA操作调用请求JSON数据包； JSON数据包格式详见表1发送REST微服务GETMETA操作调用请求的数据格式，假设调用端位于鄂城钢铁工业互联网系统6eae233e-1498，时空大数据REST微服务位于湛江钢铁工业互联网系统6eae233e-1499，时空大数据REST微服务的GUID为6eae233e- 1499-4c61-96ad-fb81c1729094。

表1发送REST微服务GETMETA操作调用请求的数据格式

步骤S1.3：时空大数据REST微服务的调用端比对时空大数据REST微服务的GUID和自身的GUID，若处于同一个工业互联网系统，则查找时空大数据REST微服务注册信息表，直接与时空大数据REST微服务建立HTTP或者HTTPS连接；若处于不同的工业互联网系统，则与本工业互联网系统的时空大数据REST微服务网关建立HTTP或者HTTPS连接；假设调用端位于工业互联网系统6eae233e-1498，若目标地址Destination 处于同一个工业互联网，为6eae233e-1498-4c61-96ad-fb81c1729094，则直接与时空大数据REST微服务6eae233e-1498-4c61-96ad-fb81c1729094建立连接，若目标地址Destination处于不同工业互联网，为6eae233e-1499-4c61-96ad-fb81c1729094，则与时空大数据REST微服务网关6eae233e-1498-0000-0000-000000000000建立连接。

步骤S1.4：时空大数据REST微服务的调用端通过HTTP或者HTTPS连接向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETMETA操作调用请求JSON数据包。

步骤S2：时空大数据REST微服务网关将REST微服务GETMETA操作调用请求路由到时空大数据REST微服务。

步骤S2.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持TCP/IP长连接，减少建立HTTP或HTTPS短连接的耗时，建立高速通讯通道加速时空大数据 REST微服务路由；例如，鄂城钢铁时空大数据REST微服务网关6eae233e-1498-0000- 0000-000000000000和湛江钢铁时空大数据REST微服务网关6eae233e-1499-0000-0000-000000000000始终保持长连接。

步骤S2.2：时空大数据REST微服务网关解析时空大数据REST微服务GETMETA 操作调用请求JSON数据包，根据路由数据中的目标地址数据查找时空大数据REST微服务网关静态路由表。

步骤S2.3：时空大数据REST微服务网关将时空大数据REST微服务GETMETA操作调用请求JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址数据对应工业互联网系统的时空大数据REST微服务网关。

步骤S2.4：目标地址的时空大数据REST微服务网关与路由数据中的目标地址所指向的时空大数据REST微服务建立HTTP或者HTTPS连接。

步骤S2.5：目标地址的时空大数据REST微服务网关通过HTTP或者HTTPS连接将时空大数据REST微服务GETMETA操作调用请求JSON数据包发送到路由数据中的目标地址Destination所指向的时空大数据REST微服务。

步骤S3：时空大数据REST微服务发送REST微服务GETMETA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关。

步骤S3.1：时空大数据REST微服务接收到时空大数据REST微服务的调用端(源地址和目标地址处于同一个工业互联网系统)或者时空大数据REST微服务网关(源地址和目标地址处于不同工业互联网系统)发送的时空大数据REST微服务GETMETA操作调用请求JSON数据包。

步骤S3.2：构造REST微服务GETMETA操作响应JSON数据包；JSON数据包格式详见表2发送REST微服务GETMETA操作响应数据的数据格式，其中REST微服务 GETMETA操作响应JSON数据包中路由区的源地址和目标地址分别为时空大数据 REST微服务GETMETA操作调用请求JSON数据包中路由区的目标地址和源地址；请求区的元数据表示该时空大数据REST微服务支持哪些查询参数，时空大数据REST微服务GETDATA操作调用请求JSON数据包请求区中的查询参数必须从该请求区中取值；响应区的元数据表示时空大数据REST微服务返回哪些字段以及支持哪些空间坐标系，时空大数据REST微服务GETDATA操作调用请求JSON数据包Request请求区中的ResponseFileds和ResponseCoordinate必须从该Response响应区中取值。

表2发送REST微服务GETMETA操作响应数据的数据格式

步骤S3.3：将REST微服务GETMETA操作响应JSON数据包通过步骤1.4建立的 HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端(源地址和目标地址处于同一个工业互联网系统)或者通过步骤2.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务网关(源地址和目标地址处于不同工业互联网系统)。

步骤S4：时空大数据REST微服务网关将REST微服务GETMETA操作的响应数据路由到时空大数据REST微服务的调用端。

步骤S4.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，以便建立高速通讯通道加速时空大数据 REST微服务路由。例如，鄂城钢铁时空大数据REST微服务网关6eae233e-1498-0000- 0000-000000000000和湛江钢铁时空大数据REST微服务网关6eae233e-1499-0000-0000-000000000000始终保持长连接。

步骤S4.2：时空大数据REST微服务网关解析时空大数据REST微服务GETMETA 操作响应JSON数据包，根据路由数据中的目标地址查找时空大数据REST微服务路由表。

步骤S4.3：时空大数据REST微服务网关将时空大数据REST微服务GETMETA操作响应JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关。

步骤S4.4：目标地址的时空大数据REST微服务网关将时空大数据REST微服务GETMETA操作响应JSON数据包通过步骤S1.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端。

步骤S5：时空大数据REST微服务的调用端向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETDATA操作调用请求。

步骤S5.1：时空大数据REST微服务的调用端在系统开始运行时，从当前所在工业互联网系统的时空大数据REST微服务网关获取时空大数据REST微服务注册信息表，并定时更新，在内存中保持一份最新的本工业互联网系统的时空大数据REST微服务注册信息表.

步骤S5.2：构造时空大数据REST微服务GETDATA操作调用请求JSON数据包； JSON数据包格式详见表3发送REST微服务GETDATA操作调用请求的数据格式，时空大数据REST微服务GETDATA操作调用请求JSON数据包Request请求区中的查询参数必须从时空大数据REST微服务GETMETA操作响应JSON数据包请求区中取值；时空大数据REST微服务GETDATA操作调用请求JSON数据包请求区中的 ResponseFileds和ResponseCoordinate必须从时空大数据REST微服务GETMETA操作响应JSON数据包响应区的Fileds和Coordinate中取值。假设调用端位于鄂城钢铁工业互联网系统6eae233e-1498，时空大数据REST微服务位于湛江钢铁工业互联网系统 6eae233e-1499，时空大数据REST微服务的GUID为6eae233e-1499-4c61-96ad- fb81c1729094，示例时空大数据REST微服务GETDATA操作调用请求JSON数据包表明，查询地址包含郭守敬路，经纬度坐标位于圆心[121.1,31.4]，半径1000米的圆范围内的记录，仅返回两个字段Address和Location，返回数据的空间坐标系采用WGS84。

表3发送REST微服务GETDATA操作调用请求的数据格式

步骤S5.3：时空大数据REST微服务的调用端比对时空大数据REST微服务的GUID和自身的GUID，若处于同一个工业互联网系统，则查找时空大数据REST微服务注册信息表，直接与时空大数据REST微服务建立HTTP或者HTTPS连接；若处于不同的工业互联网系统，则与本工业互联网系统的时空大数据REST微服务网关建立HTTP或者HTTPS连接；假设调用端位于工业互联网系统6eae233e-1498，若目标地址Destination 处于同一个工业互联网，为6eae233e-1498-4c61-96ad-fb81c1729094，则直接与时空大数据REST微服务6eae233e-1498-4c61-96ad-fb81c1729094建立连接，若目标地址 Destination处于不同工业互联网，为6eae233e-1499-4c61-96ad-fb81c1729094，则与时空大数据REST微服务网关6eae233e-1498-0000-0000-000000000000建立连接。

步骤S5.4：时空大数据REST微服务的调用端通过HTTP或者HTTPS连接向时空大数据REST微服务或者时空大数据REST微服务网关发送REST微服务GETDATA操作调用请求JSON数据包；

步骤S6：时空大数据REST微服务网关将REST微服务GETDATA操作调用请求路由到时空大数据REST微服务。

步骤S6.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，建立高速通讯通道加速时空大数据REST 微服务路由；例如，鄂城钢铁时空大数据REST微服务网关6eae233e-1498-0000-0000-000000000000和湛江钢铁时空大数据REST微服务网关6eae233e-1499-0000-0000-000000000000始终保持长连接。

步骤S6.2：时空大数据REST微服务网关解析时空大数据REST微服务GETDATA 操作调用请求JSON数据包，根据路由数据中的目标地址查找时空大数据REST微服务网关静态路由表。

步骤S6.3：时空大数据REST微服务网关将时空大数据REST微服务GETDATA操作调用请求JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关。

步骤S6.4：目标地址Destination的时空大数据REST微服务网关查找内存中最新的时空大数据REST微服务注册信息表，与路由数据中的目标地址所指向的时空大数据REST微服务建立HTTP或者HTTPS连接。

步骤S6.5：目标地址的时空大数据REST微服务网关通过HTTP或者HTTPS连接将时空大数据REST微服务GETDATA操作调用请求JSON数据包发送到路由数据中的目标地址所指向的时空大数据REST微服务。

步骤S7：时空大数据REST微服务发送REST微服务GETDATA操作的响应数据到时空大数据REST微服务的调用端或者时空大数据REST微服务网关。

步骤S7.1：时空大数据REST微服务接收到时空大数据REST微服务的调用端(源地址和目标地址处于同一个工业互联网系统)或者时空大数据REST微服务网关(源地址和目标地址处于不同工业互联网系统)发送的时空大数据REST微服务GETDATA操作调用请求JSON数据包。

步骤S7.2：构造REST微服务GETDATA操作响应JSON数据包；JSON数据包格式详见表4、发送REST微服务GETDATA操作响应数据的数据格式，其中REST微服务GETDATA操作响应JSON数据包中Route路由区的Source和Destination分别为时空大数据REST微服务GETDATA操作调用请求JSON数据包中Route路由区的 Destination和Source，REST微服务GETDATA操作响应JSON数据包中请求区即为时空大数据REST微服务GETDATA操作调用请求JSON数据包中请求区内容，响应区根据Request请求区中的ResponseFileds和ResponseCoordinate来返回，示例时空大数据 REST微服务GETDATA操作响应JSON数据包如下，该示例仅返回两个字段Address 和Location，返回数据的空间坐标系采用WGS84，返回Address为上海市郭守敬路498 号,Location为[121.212312,31.323143]，和Address为上海市郭守敬路515号,Location 为[121.123112,31.413121]两条记录。

表4发送REST微服务GETDATA操作响应数据的数据格式

步骤S7.3：将REST微服务GETDATA操作响应JSON数据包通过步骤5.4建立的 HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端(源地址和目标地址处于同一个工业互联网系统)或者通过步骤6.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务网关(源地址和目标地址处于不同工业互联网系统)。

步骤S8：时空大数据REST微服务网关将REST微服务GETDATA操作的响应数据路由到时空大数据REST微服务的调用端。

步骤S8.1：各工业互联网系统的时空大数据REST微服务网关之间始终保持TCP/IP长连接，减少建立HTTP/HTTPS短连接的耗时，建立高速通讯通道加速时空大数据REST 微服务路由；例如，鄂城钢铁时空大数据REST微服务网关6eae233e-1498-0000-0000-000000000000和湛江钢铁时空大数据REST微服务网关6eae233e-1499-0000-0000-000000000000始终保持长连接。

步骤S8.2：时空大数据REST微服务网关解析时空大数据REST微服务GETDATA 操作响应JSON数据包，根据路由数据中的目标地址查找时空大数据REST微服务路由表；

步骤S8.3：时空大数据REST微服务网关将时空大数据REST微服务GETDATA操作响应JSON数据包通过工业互联网系统的时空大数据REST微服务网关之间的长连接发送到目标地址对应工业互联网系统的时空大数据REST微服务网关；

步骤S8.4：目标地址的时空大数据REST微服务网关将时空大数据REST微服务GETDATA操作响应JSON数据包通过步骤5.4建立的HTTP或者HTTPS连接返回给时空大数据REST微服务的调用端。

GETMETA操作是指获取REST微服务的元数据信息；

GETDATA操作是指REST微服务提供的数据查询服务。

以订单查询REST微服务为例，

GETDATA操作返回信息如下，即为查询到的每笔订单的详细信息：

GETMETA操作返回信息如下，即下述操作每个字段的元数据信息：

本发明采用时空大数据REST微服务静态路由，具体包括：

第一，为每个工业互联网系统静态分配唯一的GUID，例如鄂城钢铁工业互联网系统分配GUID前两节为6eae233e-1498，湛江钢铁工业互联网系统分配GUID前两节为6eae233e-1499。

第二，为每个工业互联网系统的时空大数据REST微服务网关静态分配唯一的GUID，例如鄂城钢铁时空大数据REST微服务网关分配GUID为6eae233e-1498-0000- 0000-000000000000，湛江钢铁时空大数据REST微服务网关分配GUID为6eae233e- 1499-0000-0000-000000000000。

第三，每个工业互联网系统的时空大数据REST微服务网关保存一份最新的时空大数据REST微服务网关静态路由表，详见表5时空大数据REST微服务网关静态路由表。

表5时空大数据REST微服务网关静态路由表

第四，每个工业互联网系统的时空大数据REST微服务网关与时空大数据REST微服务网关静态路由表中的所有其他工业互联网系统的时空大数据REST微服务网关建立长连接，减少建立HTTP/HTTPS短连接的耗时，以便建立高速通讯通道加速时空大数据 REST微服务路由。

第五，每个工业互联网系统的时空大数据REST微服务注册到时空大数据REST微服务网关，由时空大数据REST微服务网关为每个时空大数据REST微服务静态分配唯一的GUID，例如鄂城钢铁时空大数据REST微服务网关为某时空大数据REST微服务静态分配的GUID为6eae233e-1498-4c61-96ad-fb81c1729084，湛江钢铁时空大数据REST 微服务网关为某时空大数据REST微服务静态分配的GUID为6eae233e-1499-4c61-96ad-fb81c1729094。

第六，每个工业互联网系统的时空大数据REST微服务网关在内存中保存一份最新的时空大数据REST微服务注册信息表，详见表6时空大数据REST微服务注册信息表。

表6时空大数据REST微服务注册信息表

第七，工业互联网系统的每个客户端向时空大数据REST微服务网关获取最新的时空大数据REST微服务注册信息表。

按照本发明提供的详细步骤以及本发明提供的时空大数据REST微服务GETMETA操作调用请求JSON数据包、时空大数据REST微服务GETMETA操作响应JSON数据包、时空大数据REST微服务GETDATA操作调用请求JSON数据包、时空大数据REST 微服务GETDATA操作响应JSON数据包、时空大数据REST微服务网关静态路由表、时空大数据REST微服务注册信息表即可实现。

本领域技术人员知道，除了以纯计算机可读程序代码方式实现本发明提供的系统及其各个装置、模块、单元以外，完全可以通过将方法步骤进行逻辑编程来使得本发明提供的系统及其各个装置、模块、单元以逻辑门、开关、专用集成电路、可编程逻辑控制器以及嵌入式微控制器等的形式来实现相同功能。所以，本发明提供的系统及其各项装置、模块、单元可以被认为是一种硬件部件，而对其内包括的用于实现各种功能的装置、模块、单元也可以视为硬件部件内的结构；也可以将用于实现各种功能的装置、模块、单元视为既可以是实现方法的软件模块又可以是硬件部件内的结构。

以上对本发明的具体实施例进行了描述。需要理解的是，本发明并不局限于上述特定实施方式，本领域技术人员可以在权利要求的范围内做出各种变化或修改，这并不影响本发明的实质内容。在不冲突的情况下，本申请的实施例和实施例中的特征可以任意相互组合。