CN112055058A - 数据的存储方法、装置及计算机可读存储介质 - Google Patents
数据的存储方法、装置及计算机可读存储介质 Download PDFInfo
- Publication number
- CN112055058A CN112055058A CN202010840376.9A CN202010840376A CN112055058A CN 112055058 A CN112055058 A CN 112055058A CN 202010840376 A CN202010840376 A CN 202010840376A CN 112055058 A CN112055058 A CN 112055058A
- Authority
- CN
- China
- Prior art keywords
- data
- terminal
- memory
- data storage
- processing logic
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000013500 data storage Methods 0.000 title claims abstract description 96
- 238000000034 method Methods 0.000 title claims abstract description 69
- 238000012545 processing Methods 0.000 claims description 101
- 238000007781 pre-processing Methods 0.000 claims description 24
- 238000004590 computer program Methods 0.000 claims description 20
- 230000006870 function Effects 0.000 description 11
- 238000010586 diagram Methods 0.000 description 8
- 238000012986 modification Methods 0.000 description 5
- 230000004048 modification Effects 0.000 description 5
- 238000004891 communication Methods 0.000 description 3
- 238000005538 encapsulation Methods 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 238000007726 management method Methods 0.000 description 2
- 238000012544 monitoring process Methods 0.000 description 2
- 238000004519 manufacturing process Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L63/00—Network architectures or network communication protocols for network security
- H04L63/04—Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks
- H04L63/0428—Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks wherein the data content is protected, e.g. by encrypting or encapsulating the payload
Landscapes
- Engineering & Computer Science (AREA)
- Computer Security & Cryptography (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Hardware Design (AREA)
- Computing Systems (AREA)
- General Engineering & Computer Science (AREA)
- Storage Device Security (AREA)
Abstract
本发明公开了一种数据的存储方法、装置及计算机可读存储介质，所述数据的存储方法包括：数据的存储装置获取第一终端发送的数据报文；根据数据报文获取第二终端中存储器内的第一数据；将第一数据存储至第一终端的存储器。本发明降低了数据存储的存储延迟。
Description
技术领域
本发明涉及数据处理领域，尤其涉及一种数据的存储方法、装置及计算机可读存储介质。
背景技术
当前物联网、大数据发展迅速，数据通过传感器或设备采集后通常通过网络传输到数据采集中心，每一种业务有不同的处理逻辑和带宽要求，在数据采集中心流量会分流到业务处理服务器中，由业务处理服务器对数据进行处理后存储到存储单元系统。在这个过程中需要定制分布式的业务处理软件，消耗大量的服务器和网卡资源，并且增加了存储延迟。
发明内容
本发明实施例通过提供一种数据的存储方法、装置及计算机可读存储介质，旨在解决数据存取过程中需要定制分布式的业务处理软件，消耗大量的服务器和网卡资源，并且增加了存储延迟的问题。
本发明实施例的第一方面提供一种数据的存储方法，所述数据的存储方法应用于数据的存储装置，所述数据的存储装置通信连接第一终端以及第二终端，所述数据的存储方法包括：
数据的存储装置获取第一终端发送的数据报文；
根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内。
在一实施例中，所述获取第一终端发送的数据报文的步骤之后，还包括；
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，执行所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤；
在所述控制指令为写入指令时，从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
在一实施例中，所述从所述数据报文中获取第二数据的步骤，还包括：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第二数据，其中，所述预处理包括添加时间轴或者加密。
在一实施例中，所述确定所述数据报文对应的处理逻辑的步骤之后，还包括：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第二数据的步骤；
在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第二数据。
本发明实施例的第二方面提供一种数据的存储方法，所述数据的存储方法应用于数据的存储装置，所述数据的存储装置通信连接第一终端以及第二终端，所述数据的存储方法包括：
数据的存储装置获取第一终端发送的数据报文；
从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
在一实施例中，所述获取第一终端发送的数据报文的步骤之后，还包括；
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内；
在所述控制指令为写入指令时，执行所述从所述数据报文中获取第二数据的步骤。
在一实施例中，所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤，还包括：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第一数据，其中，所述预处理包括添加时间轴或者加密。
在一实施例中，所述确定所述数据报文对应的处理逻辑的步骤之后，还包括：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第一数据的步骤；
在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第一数据。
为实现上述目的，本发明提供了一种数据的存储装置，所述数据的存储装置包括：存储器、处理器及存储在所述存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现如上所述的数据的存储装置的各个步骤。
为实现上述目的，本发明提供了一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上所述的数据的存储装置的各个步骤。
本发明提供的数据的存储方法、装置及计算机可读存储介质，通过获取第一终端发送的数据报文；根据所述数据报文获取第二终端中存储器内的第一数据；将所述第一数据发送至所述第一终端，以使所述第一终端将所述第一数据存储至所述第一终端的存储器。通过获取第一终端发送的数据报文；从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；将所述第二数据发送所述第二终端，以使所述第二终端将所述第二数据存储至所述第二终端的存储器内。由于在数据的存储过程中，通过直接将数据存储至存储器，可以避免消耗大量的服务器和网卡资源，降低了存储延迟。
附图说明
为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
图1为本发明实施例涉及的硬件架构示意图；
图2为本发明数据的存储方法第一实施例的流程示意图；
图3为本发明数据的存储方法第二实施例的流程示意图；
图4为本发明数据的存储方法第三实施例的步骤S60的细化流程示意图；
图5为本发明数据的存储方法第四实施例的步骤S60的细化流程示意图；
图6为本发明数据的存储方法第五实施例的流程示意图；
图7为本发明数据的存储方法第六实施例的流程示意图；
图8为本发明数据的存储方法第七实施例的步骤S130的细化流程示意图；
图9为本发明数据的存储方法第八实施例的步骤S130的细化流程示意图。
具体实施方式
为了更好的理解上述技术方案，下面将参照附图更详细地描述本公开的示例性实施例。虽然附图中显示了本公开的示例性实施例，然而应当理解，可以以各种形式实现本公开而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本公开，并且能够将本公开的范围完整的传达给本领域的技术人员。
本发明的主要解决方案是：通过数据的存储装置获取第一终端发送的数据报文；根据所述数据报文获取第二终端中存储器内的第一数据；将所述第一数据存储至所述第一终端的存储器。
由于在数据的存储过程中，通过直接将数据存储至存储器，可以避免消耗大量的服务器和网卡资源，降低了存储延迟。
参照图1，图1为本发明实施例涉及的数据的存储装置的硬件架构示意图。
本发明实施例方案涉及的是数据的存储装置，数据的存储装置包括：处理器101，例如CPU，存储器102，通信总线103。其中，通信总线103用于实现这些组件之间的连接通信。
存储器102可以是高速RAM存储器，也可以是稳定的存储器(non-volatilememory)，例如磁盘存储器。如图1所述，作为一种计算机存储介质的存储器103中可以包括检测程序；而处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
数据的存储装置获取第一终端发送的数据报文；
根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，执行所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤；
在所述控制指令为写入指令时，从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第二数据，其中，所述预处理包括添加时间轴或者加密。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第二数据的步骤；
在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第二数据。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
数据的存储装置获取第一终端发送的数据报文；
从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内；
在所述控制指令为写入指令时，执行所述从所述数据报文中获取第二数据的步骤。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第一数据，其中，所述预处理包括添加时间轴或者加密。
在一实施例中，处理器101可以用于调用存储器102中存储的检测程序，并执行以下操作：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第一数据的步骤；在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第一数据。
在本实施例提供的技术方案中，通过获取第一终端发送的数据报文；根据所述数据报文获取第二终端中存储器内的第一数据；将所述第一数据发送至所述第一终端，以使所述第一终端将所述第一数据存储至所述第一终端的存储器。通过获取第一终端发送的数据报文；从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；将所述第二数据发送所述第二终端，以使所述第二终端将所述第二数据存储至所述第二终端的存储器内。由于在数据的存储过程中，通过直接将数据存储至存储器，可以避免消耗大量的服务器和网卡资源，降低了存储延迟。
为了更好的理解上述技术方案，下面将结合说明书附图以及具体的实施方式对上述技术方案进行详细的说明。
参照图2，图2为本发明数据的存储方法的第一实施例，所述数据的存储方法包括以下步骤：
步骤S10，数据的存储装置获取第一终端发送的数据报文。
在本实施例中，第一终端通过可编程芯片与第二终端通信连接，具体的，上述可编程芯片为可编程交换机，具有一定CPU处理的数据处理能力，上述第一终端可为手机、电脑等携带存储功能的电子设备，进一步的，上述数据报文是网络中交换与传输的数据单元，即站点一次性要发送的数据块。报文包含了将要发送的完整的数据信息，其长短很不一致，长度不限且可变。
可选的，在可编程交换机获取第一终端发送的数据报文后，还可以确定数据报文的权限和服务类型，再控制器上做用户配置管理，指定业务策略，策略包括：服务的网络端口,网络协议类型，服务类型，服务的处理编码，存储单元等要求；可通过可编程交换机提供的接口对可编程交换机进行业务配置；在本段结束后，业务配置将会在数据处理节点中生效。
步骤S20，根据所述数据报文获取第二终端中存储器内的第一数据。
在本实施例中，上述第二终端可为手机、电脑等携带存储功能的电子设备，进一步的，上述第一数据指的要进行数据存储的目标数据。
步骤S30，将所述第一数据存储至所述第一终端的存储器内。
在本实施例中，将第一数据进行远程直接数据存储以存储至第一终端，具体的远程直接数据存储(Remote Direct Memory Access)技术是是一种绕过主机(host-offload/host-bypass)技术：一个应用(包括存储)<--发送/接收数据-->另外一个(远程)应用的内存空间。他的底层协议可以是底层可以是以太网(RoCE或者iWARP)或者Infiniband。
可选的，将所述第一数据发送至所述第一终端，以使所述第一终端将所述第一数据存储至所述第一终端的存储器
在本实施例的技术方案中，通过获取第一终端发送的数据报文；根据所述数据报文获取第二终端中存储器内的第一数据；将所述第一数据发送至所述第一终端，以使所述第一终端将所述第一数据存储至所述第一终端的存储器。由于在数据的存储过程中，通过直接将数据存储至存储器，可以避免消耗大量的服务器和网卡资源，降低了存储延迟。
参照图3，图3为本发明数据的存储方法的第二实施例，基于第一实施例，所述步骤S10之后，还包括以下步骤：
步骤S40，确定数据报文对应的控制指令。
在本实施例中，在本实施例中，第一终端通过协议封装发送数据报文到数据处理节点；可编程交换机可根据业务配置对数据报文进行控制，如果处理策略不存在，将丢弃数据报文；如果处理策略权限是拒绝，也将丢弃数据报文。如果处理策略存在，并且允许第一终端接入，在数据平面获取控制指令，在一个报文中可能有一条或多条控制指令；本实施例所指的数据平面，是数据处理节点，采用可编程交换机实现的业务逻辑，在数据平面直接对报文处理实现高速数据存储，上述控制指令包括写入指令和读取指令。
步骤S50，在所述控制指令为读取指令时，执行所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤。
在本实施例中，当确定数据报文携带的控制指令为读取指令时，可通过数据报文来确定第一数据在第二终端存储器内的位置并执行上述将第一数据进行远程直接数据存储以存储至第一终端的步骤。
步骤S60，在所述控制指令为写入指令时，从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据。
在本实施例中，当确定数据报文携带的控制指令为写入指令时，会解析数据报文，获取要存储至第二终端的第二数据，上述第二数据为第一终端发送的数据，数据报文内携带了第二数据。
步骤S70，将所述第二数据存储至所述第二终端的存储器内。
在本实施例中，在解析数据报文获取到第二数据之后，可编程交换机将第二数据，通过远程数据之间存取，将第二数据存储至第二终端的存储器内。
可选的，将所述第二数据发送所述第二终端，以使所述第二终端将所述第二数据存储至所述第二终端的存储器内。
在本实施例的技术方案中，通过数据报文中不同的控制指令，在不消耗大量的服务器和网卡资源，降低了存储延迟的情况下，可同时处理，提高了指令处理的灵活性。
参照图4，图4为本发明数据的存储方法的第三实施例，基于第一和第二实施例，所述步骤S60还包括以下步骤：
步骤S61，确定所述数据报文对应的处理逻辑。
在本实施例中，上述处理逻辑为业务处理逻辑，例如：我们从HTML通过表单提交数据到服务端，然后我们有时候需要对这些提交后的数据进行一定的处理，之后在存到数据库。那么在将数据提交数据库到之前对数据的一系列处理比如：加密、或者生成当前系统时间，既添加时间轴、又或者对提交的数据进行部分截取等操作的统称就叫业务的逻辑处理，也可理解为对数据的预处理。
步骤S62，根据所述处理逻辑对所述数据报文进行预处理得到所述第二数据，其中，所述预处理包括添加时间轴或者加密。
在本实施例的技术方案中，在进行数据的存储前，通过对数据报文进行业务逻辑处理，例如通过加密数据和添加时间轴，可以分别增加要存储的数据的安全性和完整性。
参照图5，图5为本发明数据的存储方法的第四实施例，基于第一至第三任一实施例，所述步骤S61的步骤之后，包括以下步骤：
步骤S63，确定所述处理逻辑的复杂度。
在本实施例的技术方案中，通过监控可编程交换机中的芯片的工作状态来确定处理逻辑的复杂度，进一步的，也可预先通过要进行逻辑处理的数据量的确定，来确定上述复杂度，例如：在可编程交换机确定不能或者难以处理上述业务逻辑时，可通过预设的功能较为强大的处理器节点进行处理。可选的，上述处理器节点可为数据存储方的处理器，例如：第二终端的处理器节点。
步骤S64，在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第二数据的步骤；
步骤S65，在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第二数据。
在本实施例的技术方案中，在进行数据存储前的逻辑处理阶段，可编程交换机难以实现数据报文中的处理逻辑时，可通过调用功能更强大的处理器进行处理，间接提高了数据存储的稳定性。
参照图6，图6为本发明数据的存储方法的第五实施例，所述数据的存储方法包括以下步骤：
步骤S90，数据的存储装置获取第一终端发送的数据报文。
第一终端通过可编程芯片与第二终端通信连接，具体的，上述可编程芯片为可编程交换机，具有一定CPU处理的数据处理能力，上述第一终端可为手机、电脑等携带存储功能的电子设备，进一步的，上述数据报文是网络中交换与传输的数据单元，即站点一次性要发送的数据块。报文包含了将要发送的完整的数据信息，其长短很不一致，长度不限且可变。
可选的，在可编程交换机获取第一终端发送的数据报文后，还可以确定数据报文的权限和服务类型，再控制器上做用户配置管理，指定业务策略，策略包括：服务的网络端口,网络协议类型，服务类型，服务的处理编码，存储单元等要求；可通过可编程交换机提供的接口对可编程交换机进行业务配置；在本段结束后，业务配置将会在数据处理节点中生效。第一终端通过协议封装发送数据报文到数据处理节点；可编程交换机可根据业务配置对数据报文进行控制，如果处理策略不存在，将丢弃数据报文；如果处理策略权限是拒绝，也将丢弃数据报文。如果处理策略存在，并且允许第一终端接入，在数据平面对报文解析和获取控制指令，在一个报文中可能有一条或多条控制指令；本例所指的数据平面，是数据处理节点，采用可编程交换机实现的业务逻辑，在数据平面直接对报文处理实现高速数据存储。
步骤S100，从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据。
在本实施例中，上述第二终端可为手机、电脑等携带存储功能的电子设备，进一步的，上述第二数据指的要进行数据存储的目标数据，要注意的是，上述数据报文包括上述第二数据。
步骤S110，将所述第二数据存储至所述第二终端的存储器内。
在本实施例中，直接通过可编程交换机，及数据的存储装置将第二数据存储至第二终端的存储器内。
可选的，将所述第二数据发送所述第二终端，以使所述第二终端将所述第二数据存储至所述第二终端的存储器内。
在本实施例的技术方案中，通过获取第一终端发送的数据报文；从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；将所述第二数据发送所述第二终端，以使所述第二终端将所述第二数据存储至所述第二终端的存储器内。由于在数据的存储过程中，通过直接将数据存储至存储器，可以避免消耗大量的服务器和网卡资源，降低了存储延迟。
参照图7，图7为本发明数据的存储方法的第六实施例，基于第五实施例，所述步骤S90的步骤之后，包括以下步骤：
步骤S120，确定数据报文对应的控制指令。
在本实施例中，第一终端通过协议封装发送数据报文到数据处理节点；可编程交换机可根据业务配置对数据报文进行控制，如果处理策略不存在，将丢弃数据报文；如果处理策略权限是拒绝，也将丢弃数据报文。如果处理策略存在，并且允许第一终端接入，在数据平面获取控制指令，在一个报文中可能有一条或多条控制指令；本实施例所指的数据平面，是数据处理节点，采用可编程交换机实现的业务逻辑，在数据平面直接对报文处理实现高速数据存储。上述控制指令包括写入指令和读取指令。
步骤S130，在所述控制指令为读取指令时，根据所述数据报文获取第二终端中存储器内的第一数据。
在本实施例中，当确定数据报文携带的控制指令为读取指令时，可通过数据报文来确定第一数据在第二终端存储器内的位置。
步骤S140，将所述第一数据存储至所述第一终端的存储器。
在本实施例中，将上述第一数据进行远程直接数据存储以存储至第一终端的存储器。
可选的，将所述第一数据发送所述第一终端，以使所述第一终端将所述第一数据存储至所述第一终端的存储器。
步骤S150，在所述控制指令为写入指令时，执行所述从所述数据报文中获取第二数据的步骤。
在本实施例中，在确定控制指令为写入指令时，将上述第一数据进行远程直接数据存储以存储至第一终端。
在本实施例的技术方案中，通过数据报文中不同的控制指令，在不消耗大量的服务器和网卡资源，降低了存储延迟的情况下，可同时处理，提高了指令处理的灵活性。
参照图8，图8为本发明数据的存储方法的第六实施例，基于第五实施例，所述步骤S130包括以下步骤：
步骤S131，确定所述数据报文对应的处理逻辑；
步骤S132，根据所述处理逻辑对所述数据报文进行预处理得到所述第一数据，其中，所述预处理包括添加时间轴或者加密。
在本实施例的技术方案中，在进行数据的存储前，通过对数据报文进行业务逻辑处理，例如通过加密数据和添加时间轴，可以分别增加要存储的数据的安全性和完整性。
参照图9，图9为本发明数据的存储方法的第六实施例，基于第五实施例，所述步骤S131的步骤之后，包括以下步骤：
步骤S133，确定所述处理逻辑的复杂度；
在本实施例的技术方案中，通过监控可编程交换机中的芯片的工作状态来确定处理逻辑的复杂度，进一步的，也可预先通过要进行逻辑处理的数据量的确定，来确定上述复杂度，例如：在可编程交换机确定不能或者难以处理上述业务逻辑时，可通过预设的功能较为强大的处理器节点进行处理。可选的，上述处理器节点可为数据存储方的处理器，例如：第一终端的处理器节点。
步骤S134，在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第一数据的步骤；
步骤S135，在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第一数据。
在本实施例的技术方案中，在本实施例的技术方案中，在进行数据存储前的逻辑处理阶段，可编程交换机难以实现数据报文中的处理逻辑时，可通过调用功能更强大的处理器进行处理，间接提高了数据存储的稳定性。
为实现上述目的，本发明提供了一种数据的存储装置，所述数据的存储装置包括：存储器、处理器及存储在所述存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现如上所述的数据的存储方法的各个步骤。
为实现上述目的，本发明提供了一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上所述的数据的存储方法的各个步骤。
本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计算机程序产品。因此，本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
应当注意的是，在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的部件或步骤。位于部件之前的单词“一”或“一个”不排除存在多个这样的部件。本发明可以借助于包括有若干不同部件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。
尽管已描述了本发明的优选实施例，但本领域内的技术人员一旦得知了基本创造性概念，则可对这些实施例作出另外的变更和修改。所以，所附权利要求意欲解释为包括优选实施例以及落入本发明范围的所有变更和修改。
显然，本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样，倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内，则本发明也意图包含这些改动和变型在内。
Claims (10)
1.一种数据的存储方法，其特征在于，所述数据的存储方法应用于数据的存储装置，所述数据的存储装置通信连接第一终端以及第二终端，所述数据的存储方法包括：
数据的存储装置获取第一终端发送的数据报文；
根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内。
2.如权利要求1所述的数据的存储方法，其特征在于，所述获取第一终端发送的数据报文的步骤之后，还包括；
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，执行所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤；
在所述控制指令为写入指令时，从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
3.如权利要求2所述的数据的存储方法，其特征在于，所述从所述数据报文中获取第二数据的步骤，还包括：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第二数据，其中，所述预处理包括添加时间轴或者加密。
4.如权利要求3所述的数据的存储方法，其特征在于，所述确定所述数据报文对应的处理逻辑的步骤之后，还包括：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第二数据的步骤；
在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第二数据。
5.一种数据的存储方法，其特征在于，所述数据的存储方法应用于数据的存储装置，所述数据的存储装置通信连接第一终端以及第二终端，所述数据的存储方法包括：
数据的存储装置获取第一终端发送的数据报文；
从所述数据报文中获取第二数据，所述第二数据为所述第一终端存储器中存储的数据；
将所述第二数据存储至所述第二终端的存储器内。
6.如权利要求5所述的数据的存储方法，其特征在于，所述获取第一终端发送的数据报文的步骤之后，还包括；
确定数据报文对应的控制指令；
在所述控制指令为读取指令时，根据所述数据报文获取第二终端中存储器内的第一数据；
将所述第一数据存储至所述第一终端的存储器内；
在所述控制指令为写入指令时，执行所述从所述数据报文中获取第二数据的步骤。
7.如权利要求6所述的数据的存储方法，其特征在于，所述根据所述数据报文获取第二终端中存储器内的第一数据的步骤，还包括：
确定所述数据报文对应的处理逻辑；
根据所述处理逻辑对所述数据报文进行预处理得到所述第一数据，其中，所述预处理包括添加时间轴或者加密。
8.如权利要求7所述的数据的存储方法，其特征在于，所述确定所述数据报文对应的处理逻辑的步骤之后，还包括：
确定所述处理逻辑的复杂度；
在所述处理逻辑的复杂度不满足预设条件时，执行所述根据所述处理逻辑对所述数据报文进行预处理得到第一数据的步骤；
在所述处理逻辑的复杂度满足预设条件时，将所述数据报文发送至第三终端，以接收所述第三终端发送的所述第一数据。
9.一种数据的存储装置，其特征在于，所述数据的存储装置包括：存储器、处理器及存储在所述存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现如权利要求1至8中任一项所述的数据的存储方法的步骤。
10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1至8中任一项所述的数据的存储方法的步骤。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010840376.9A CN112055058A (zh) | 2020-08-19 | 2020-08-19 | 数据的存储方法、装置及计算机可读存储介质 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010840376.9A CN112055058A (zh) | 2020-08-19 | 2020-08-19 | 数据的存储方法、装置及计算机可读存储介质 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN112055058A true CN112055058A (zh) | 2020-12-08 |
Family
ID=73599679
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010840376.9A Pending CN112055058A (zh) | 2020-08-19 | 2020-08-19 | 数据的存储方法、装置及计算机可读存储介质 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112055058A (zh) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114401218A (zh) * | 2021-12-28 | 2022-04-26 | 绿盟科技集团股份有限公司 | 一种数据报文的旁路转发方法及装置 |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103718167A (zh) * | 2011-06-30 | 2014-04-09 | 诺基亚公司 | 用于通过提供对数据的直接访问减少存储器复制开销而改进网络传送的方法、装置和计算机程序产品 |
| CN107276912A (zh) * | 2016-04-07 | 2017-10-20 | 华为技术有限公司 | 存储器、报文处理方法及分布式存储系统 |
| WO2019000866A1 (zh) * | 2017-06-29 | 2019-01-03 | 京信通信系统（中国）有限公司 | 一种数据处理方法及物联网网关 |
| CN109302466A (zh) * | 2018-09-18 | 2019-02-01 | 华为技术有限公司 | 数据处理方法、相关设备及计算机存储介质 |
| CN109739434A (zh) * | 2018-12-03 | 2019-05-10 | 中科恒运股份有限公司 | 文件读取地址获取方法、文件读取方法和终端设备 |
| CN109981480A (zh) * | 2017-12-27 | 2019-07-05 | 华为技术有限公司 | 一种数据传输方法及第一设备 |
-
2020
- 2020-08-19 CN CN202010840376.9A patent/CN112055058A/zh active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103718167A (zh) * | 2011-06-30 | 2014-04-09 | 诺基亚公司 | 用于通过提供对数据的直接访问减少存储器复制开销而改进网络传送的方法、装置和计算机程序产品 |
| CN107276912A (zh) * | 2016-04-07 | 2017-10-20 | 华为技术有限公司 | 存储器、报文处理方法及分布式存储系统 |
| WO2019000866A1 (zh) * | 2017-06-29 | 2019-01-03 | 京信通信系统（中国）有限公司 | 一种数据处理方法及物联网网关 |
| CN109981480A (zh) * | 2017-12-27 | 2019-07-05 | 华为技术有限公司 | 一种数据传输方法及第一设备 |
| CN109302466A (zh) * | 2018-09-18 | 2019-02-01 | 华为技术有限公司 | 数据处理方法、相关设备及计算机存储介质 |
| CN109739434A (zh) * | 2018-12-03 | 2019-05-10 | 中科恒运股份有限公司 | 文件读取地址获取方法、文件读取方法和终端设备 |
Non-Patent Citations (3)
| Title |
|---|
| 薛建生等: "物联网海量数据的分布式存储算法", 《小型微型计算机系统》 * |
| 薛建生等: "物联网海量数据的分布式存储算法", 《小型微型计算机系统》, no. 09, 15 September 2013 (2013-09-15), pages 115 - 118 * |
| 金浩;梅君君;: "一种RDMA传输控制方法研究", 网络安全技术与应用, no. 05, pages 484 - 23 * |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114401218A (zh) * | 2021-12-28 | 2022-04-26 | 绿盟科技集团股份有限公司 | 一种数据报文的旁路转发方法及装置 |
| CN114401218B (zh) * | 2021-12-28 | 2023-07-21 | 绿盟科技集团股份有限公司 | 一种数据报文的旁路转发方法及装置 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111278031A (zh) | Pdu类型的设置方法、ue策略的设置方法及相关实体 | |
| US8539089B2 (en) | System and method for vertical perimeter protection | |
| CN111083180B (zh) | 物联网系统、物联网设备联动方法及装置 | |
| CN109194765B (zh) | 请求控制方法、装置、计算机设备和存储介质 | |
| CN111935017B (zh) | 跨网络的应用调用方法、装置及路由设备 | |
| WO2021128927A1 (zh) | 报文的处理方法及装置、存储介质和电子装置 | |
| US20230152978A1 (en) | Data Access Method and Related Device | |
| CN114124929A (zh) | 跨网络的数据处理方法和装置 | |
| CN113517985A (zh) | 文件数据处理方法、装置、电子设备及计算机可读介质 | |
| US20210132993A1 (en) | Rate limiting compliance assessments with multi-layer fair share scheduling | |
| CN115297164A (zh) | 网络代理方法、装置、电子设备及计算机可读存储介质 | |
| CN110536359B (zh) | 网络切片创建方法、装置、设备及存储介质 | |
| CN113032410B (zh) | 数据处理方法、装置、电子设备及计算机存储介质 | |
| CN114338477B (zh) | 一种通信链路监控方法、装置、设备及存储介质 | |
| CN112055058A (zh) | 数据的存储方法、装置及计算机可读存储介质 | |
| US9923794B2 (en) | Method, apparatus, and system for identifying abnormal IP data stream | |
| CN115639954A (zh) | 一种数据传输方法、装置、设备及介质 | |
| CN114697387A (zh) | 数据包传输方法、装置及存储介质 | |
| CN110391991B (zh) | 一种流量控制的方法及相关装置 | |
| CN111240867B (zh) | 一种信息通讯系统及方法 | |
| CN116602044A (zh) | 通信方法、装置、设备以及存储介质 | |
| CN113726885A (zh) | 一种流量配额的调整方法和装置 | |
| CN108874564A (zh) | 一种进程间通信方法、电子设备及可读存储介质 | |
| US20070136472A1 (en) | Systems and methods for requesting protocol in a network using natural language messaging | |
| CN115022224B (zh) | 一种会话建立处理方法、装置及设备 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20201208 |
|
| RJ01 | Rejection of invention patent application after publication |