CN108804711B - A data processing method, device and computer-readable storage medium - Google Patents
A data processing method, device and computer-readable storage medium Download PDFInfo
- Publication number
- CN108804711B CN108804711B CN201810678182.6A CN201810678182A CN108804711B CN 108804711 B CN108804711 B CN 108804711B CN 201810678182 A CN201810678182 A CN 201810678182A CN 108804711 B CN108804711 B CN 108804711B
- Authority
- CN
- China
- Prior art keywords
- data
- instruction
- server
- client
- program
- 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.)
- Active
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 13
- 238000012545 processing Methods 0.000 claims abstract description 60
- 238000000034 method Methods 0.000 claims abstract description 32
- 230000004044 response Effects 0.000 claims abstract description 25
- 230000008569 process Effects 0.000 claims abstract description 18
- 238000013507 mapping Methods 0.000 claims description 31
- 238000004590 computer program Methods 0.000 claims description 12
- 238000010586 diagram Methods 0.000 description 4
- 230000006870 function Effects 0.000 description 4
- 238000005516 engineering process Methods 0.000 description 3
- 238000004422 calculation algorithm Methods 0.000 description 2
- 238000004891 communication Methods 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 108010001267 Protein Subunits Proteins 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000007726 management method Methods 0.000 description 1
- 230000000750 progressive 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
-
- 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
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Transfer Between Computers (AREA)
Abstract
Description
技术领域technical field
本发明涉及分布式文件系统技术领域,特别是涉及一种数据处理的方法、装置和计算机可读存储介质。The present invention relates to the technical field of distributed file systems, in particular to a data processing method, device and computer-readable storage medium.
背景技术Background technique
分布式文件系统中的管理模块即Mon模块扮演者管理者的角色,维护了整个集群的状态,保证集群的相关组件在同一时刻能够达成一致,相当于集群中的领导层。Mon模块在管理各节点时,会将各节点的数据信息以图表即map表的形式存储,其中map的类型可以包括osdmap、monmap、mdsmap、authmap、logmap等,这些数据信息都保存在键值数据库(Key-Value Store,kvstore)中。The management module in the distributed file system, the Mon module, plays the role of the manager, maintaining the status of the entire cluster and ensuring that the relevant components of the cluster can reach a consensus at the same time, which is equivalent to the leadership in the cluster. When the Mon module manages each node, it will store the data information of each node in the form of a chart, that is, a map table. The type of map can include osdmap, monmap, mdsmap, authmap, logmap, etc. These data information are stored in the key-value database (Key-Value Store, kvstore).
在分布式文件系统中,每个节点有其对应的一个kvstore,当管理人员需要获取kvstore中的数据时,需要借助数据读取工具(kvstore-tool)先取出数据。由于kvstore中的数据是经过序列化处理后的数据,因此取出数据之后管理人员需要借助另一个解码器工具对序列化的数据进行反序列化处理,这样才能得到便于管理人员识别的数据。In the distributed file system, each node has its corresponding kvstore. When the administrator needs to obtain the data in the kvstore, he needs to use the data reading tool (kvstore-tool) to retrieve the data first. Since the data in kvstore is serialized data, after taking out the data, the manager needs to use another decoder tool to deserialize the serialized data, so as to obtain data that is easy for the manager to identify.
在分布式文件系统中各kvstore中的数据应该保持一致。为了验证各kvstore中的数据是否一致,需要依据上述查询数据的方式,获取相应节点的数据,并通过人工比对的方式,确定各节点上的数据是否一致。现有技术中,无论是对数据进行查询,还是对不同节点上的数据进行一致性的检验,都需要人工进行操作,处理效率较低。The data in each kvstore in the distributed file system should be consistent. In order to verify whether the data in each kvstore is consistent, it is necessary to obtain the data of the corresponding node according to the above query data method, and determine whether the data on each node is consistent through manual comparison. In the prior art, no matter whether it is to query data or to check the consistency of data on different nodes, manual operations are required, and the processing efficiency is low.
可见,如何提升kvstore中数据处理的效率,是本领域技术人员亟待解决的问题。It can be seen that how to improve the efficiency of data processing in kvstore is an urgent problem to be solved by those skilled in the art.
发明内容Contents of the invention
本发明实施例的目的是提供一种数据处理的方法、装置和计算机可读存储介质,可以提升kvstore中数据处理的效率。The purpose of the embodiments of the present invention is to provide a data processing method, device and computer-readable storage medium, which can improve the efficiency of data processing in kvstore.
为解决上述技术问题,本发明实施例提供一种数据处理的方法,对分布式文件系统中的每个节点设置相应的客户端程序和服务端程序,所述方法包括:In order to solve the above-mentioned technical problems, an embodiment of the present invention provides a data processing method, which sets a corresponding client program and server program for each node in the distributed file system, and the method includes:
客户端依据接收的指令,向相应的服务端发送与所述指令相对应的命令;The client sends a command corresponding to the instruction to the corresponding server according to the received instruction;
所述客户端接收所述服务端反馈的响应结果;The client receives a response result fed back by the server;
所述客户端依据所述响应结果中携带的数据,调用相应的脚本程序对所述数据进行处理,以实现数据的自动化处理。According to the data carried in the response result, the client invokes a corresponding script program to process the data, so as to realize automatic data processing.
可选的,所述客户端依据接收的指令,向相应的服务端发送与所述指令相对应的命令包括:Optionally, the client sending a command corresponding to the instruction to the corresponding server according to the received instruction includes:
客户端接收所述指令;The client receives the instruction;
所述客户端依据所述指令中携带的主机名,查询主机名和IP地址的对应关系,以获取主机对应的IP地址;The client queries the correspondence between the host name and the IP address according to the host name carried in the instruction, so as to obtain the corresponding IP address of the host;
所述客户端依据所述IP地址,与相应的服务端建立连接,并向所述服务端发送与所述指令相对应的命令。The client establishes a connection with the corresponding server according to the IP address, and sends a command corresponding to the instruction to the server.
可选的,所述指令包括信息对比指令和数据查询指令;其中,所述信息对比指令中携带有对比标识以及多个节点的主机名;所述数据查询指令中携带有至少一个节点的主机名。Optionally, the instruction includes an information comparison instruction and a data query instruction; wherein, the information comparison instruction carries comparison identifiers and host names of multiple nodes; the data query instruction carries the host name of at least one node .
可选的,当所述指令为信息对比指令时,与所述指令相对应的命令为获取所述服务端中所有数据信息的命令;Optionally, when the instruction is an information comparison instruction, the command corresponding to the instruction is a command for obtaining all data information in the server;
相应的,所述客户端依据所述响应结果中携带的数据,调用相应的脚本程序对所述数据进行处理,以实现数据的自动化处理包括:Correspondingly, the client invokes a corresponding script program to process the data according to the data carried in the response result, so as to realize automatic data processing including:
所述客户端接收各所述服务端反馈的映射表;其中,所述映射表中存储有数据类型和数据版本的对应关系;The client receives the mapping table fed back by each of the servers; wherein, the mapping table stores the correspondence between data types and data versions;
所述客户端将所有所述映射表进行对比,以得到各所述映射表各自独有的数据类型和数据版本;The client compares all the mapping tables to obtain the unique data type and data version of each of the mapping tables;
所述客户端接收各所述服务端反馈的键值表,并调用反序列化脚本对所述键值表中的目标数据进行反序列化处理,并保存反序列化处理后的键值表;其中,所述键值表中存储有各所述数据版本及其相应的目标数据的对应关系。The client receives the key-value table fed back by each of the servers, and calls a deserialization script to deserialize the target data in the key-value table, and saves the deserialized key-value table; Wherein, the corresponding relationship between each of the data versions and their corresponding target data is stored in the key-value table.
本发明实施例还提供了一种数据处理的装置,对分布式文件系统中的每个节点设置相应的客户端程序和服务端程序,所述装置包括发送单元、接收单元和处理单元;The embodiment of the present invention also provides a data processing device, which sets a corresponding client program and server program for each node in the distributed file system, and the device includes a sending unit, a receiving unit and a processing unit;
所述发送单元,用于依据接收的指令,向相应的服务端发送与所述指令相对应的命令;The sending unit is configured to send a command corresponding to the instruction to a corresponding server according to the received instruction;
所述接收单元,用于接收所述服务端反馈的响应结果;The receiving unit is configured to receive a response result fed back by the server;
所述处理单元,用于依据所述响应结果中携带的数据,调用相应的脚本程序对所述数据进行处理,以实现数据的自动化处理。The processing unit is configured to call a corresponding script program to process the data according to the data carried in the response result, so as to realize automatic data processing.
可选的,所述发送单元包括接收子单元、查询子单元和建立子单元;Optionally, the sending unit includes a receiving subunit, a query subunit and an establishment subunit;
所述接收子单元,用于接收所述指令;The receiving subunit is configured to receive the instruction;
所述查询子单元,用于依据所述指令中携带的主机名,查询主机名和IP地址的对应关系,以获取主机对应的IP地址;The query subunit is used to query the correspondence between the host name and the IP address according to the host name carried in the instruction, so as to obtain the corresponding IP address of the host;
所述建立子单元,用于依据所述IP地址,与相应的服务端建立连接,并向所述服务端发送与所述指令相对应的命令。The establishing subunit is configured to establish a connection with a corresponding server according to the IP address, and send a command corresponding to the instruction to the server.
可选的,所述指令包括信息对比指令和数据查询指令;其中,所述信息对比指令中携带有对比标识以及多个节点的主机名;所述数据查询指令中携带有至少一个节点的主机名。Optionally, the instruction includes an information comparison instruction and a data query instruction; wherein, the information comparison instruction carries comparison identifiers and host names of multiple nodes; the data query instruction carries the host name of at least one node .
可选的,当所述指令为信息对比指令时,Optionally, when the instruction is an information comparison instruction,
相应的,所述处理单元包括接收子单元、对比子单元和保存子单元;Correspondingly, the processing unit includes a receiving subunit, a comparing subunit and a saving subunit;
所述接收子单元,用于接收各所述服务端反馈的映射表;其中,所述映射表中存储有数据类型和数据版本的对应关系;The receiving subunit is configured to receive the mapping table fed back by each of the servers; wherein, the mapping table stores the corresponding relationship between data types and data versions;
所述对比子单元,用于将所有所述映射表进行对比,以得到各所述映射表各自独有的数据类型和数据版本;The comparison subunit is used to compare all the mapping tables to obtain the unique data types and data versions of each of the mapping tables;
所述保存子单元,用于接收各所述服务端反馈的键值表,并调用反序列化脚本对所述键值表中的数据进行反序列化处理,并保存反序列化处理后的键值表。The saving subunit is used to receive the key-value table fed back by each of the servers, and call the deserialization script to deserialize the data in the key-value table, and save the deserialized key table of values.
本发明实施例还提供了一种数据处理的装置,包括:The embodiment of the present invention also provides a data processing device, including:
存储器,用于存储计算机程序;memory for storing computer programs;
处理器,用于执行所述计算机程序以实现如上述数据处理的方法的步骤。A processor, configured to execute the computer program to implement the steps of the above data processing method.
本发明实施例还提供了一种计算机可读存储介质,所述计算机可读存储介质上存储有计算机程序,所述计算机程序被处理器执行时实现如上述数据处理的方法的步骤。An embodiment of the present invention also provides a computer-readable storage medium, where a computer program is stored on the computer-readable storage medium, and when the computer program is executed by a processor, the steps of the above data processing method are implemented.
由上述技术方案可以看出,对于每个节点设置了相应的客户端程序和服务端程序,客户端程序可以向用户提供服务界面,以便于用户根据需求输入相应的指令。服务端程序可以实现数据的查询和读取,客户端程序可以和不同节点的服务端程序进行交互。客户端程序依据接收的指令,可以向相应的服务端发送与该指令相对应的命令,从而获取服务端反馈的响应结果,并依据该响应结果中携带的数据,调用相应的脚本程序对数据进行处理,以实现数据的自动化处理。相比于现有技术中完全依据于人工对数据进行处理,在该过程中,用户只需输入指令,便可以实现数据的自动化处理,提升了kvstore中数据处理的效率,并且有效的保证了数据处理的准确性。It can be seen from the above technical solution that a corresponding client program and server program are set for each node, and the client program can provide a service interface to the user, so that the user can input corresponding instructions according to requirements. The server program can realize the query and reading of data, and the client program can interact with the server programs of different nodes. According to the received instruction, the client program can send the command corresponding to the instruction to the corresponding server, so as to obtain the response result fed back by the server, and call the corresponding script program to process the data according to the data carried in the response result. processing to automate the processing of data. Compared with the existing technology that completely relies on manual data processing, in this process, the user only needs to input instructions to realize the automatic processing of data, which improves the efficiency of data processing in kvstore and effectively guarantees the data processing accuracy.
附图说明Description of drawings
为了更清楚地说明本发明实施例,下面将对实施例中所需要使用的附图做简单的介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to illustrate the embodiments of the present invention more clearly, the accompanying drawings used in the embodiments will be briefly introduced below. Obviously, the accompanying drawings in the following description are only some embodiments of the present invention. As far as people are concerned, other drawings can also be obtained based on these drawings on the premise of not paying creative work.
图1为本发明实施例提供的一种数据处理的方法的流程图;FIG. 1 is a flowchart of a data processing method provided by an embodiment of the present invention;
图2为本发明实施例提供的一种数据处理的装置的结构示意图;FIG. 2 is a schematic structural diagram of a data processing device provided by an embodiment of the present invention;
图3为本发明实施例提供的一种数据处理的装置的硬件结构示意图。FIG. 3 is a schematic diagram of a hardware structure of a data processing device provided by an embodiment of the present invention.
具体实施方式detailed description
下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下,所获得的所有其他实施例,都属于本发明保护范围。The following will clearly and completely describe the technical solutions in the embodiments of the present invention in conjunction with the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.
为了使本技术领域的人员更好地理解本发明方案,下面结合附图和具体实施方式对本发明作进一步的详细说明。In order to enable those skilled in the art to better understand the solution of the present invention, the present invention will be further described in detail below in conjunction with the accompanying drawings and specific embodiments.
接下来,详细介绍本发明实施例所提供的一种数据处理的方法。图1为本发明实施例提供的一种数据处理的方法的流程图,对分布式文件系统中的每个节点设置相应的客户端程序和服务端程序,该方法包括:Next, a data processing method provided by an embodiment of the present invention is introduced in detail. Fig. 1 is the flow chart of a kind of method of data processing provided by the embodiment of the present invention, each node in the distributed file system is provided with corresponding client program and server program, and this method comprises:
S101:客户端依据接收的指令,向相应的服务端发送与指令相对应的命令。S101: The client sends a command corresponding to the instruction to a corresponding server according to the received instruction.
在本发明实施例中,为了实现数据的自动化、便捷化处理,针对于每个节点会设置相应的客户端程序和服务端程序。其中,客户端程序和服务端程序可以采用Python语言。In the embodiment of the present invention, in order to realize automatic and convenient data processing, a corresponding client program and a server program are set for each node. Wherein, the client program and the server program can adopt Python language.
在实际应用中,各节点的服务端程序相当于后台程序,需要一直在后台运行。而客户端程序在其需要运行指令时才被启动,也即客户端程序只有在接收到指令后才会被启动。为了便于介绍,可以将客户端程序简称为客户端,服务端程序简称为服务端。In practical applications, the server program of each node is equivalent to a background program and needs to run in the background all the time. However, the client program is started only when it needs to run an instruction, that is, the client program will only be started after receiving the instruction. For ease of introduction, the client program may be referred to as the client for short, and the server program may be referred to as the server for short.
客户端用于接收指令、建立与服务端的连接、对接收到的数据进行分析处理等。服务端用于读取自身节点的kvstore中的数据、并将数据反馈给客户端。The client is used to receive instructions, establish a connection with the server, analyze and process the received data, etc. The server is used to read the data in the kvstore of its own node and feed the data back to the client.
各节点kvstore中的数据可以以前缀(prefix)-键(key)-键值(value)的形式存储,其中,prefix具体可以包括osdmap、monmap、mdsmap、authmap、logmap等数据类型,key可以是每个数据类型所对应的数据版本,value可以是相应key所对应的具体信息。The data in the kvstore of each node can be stored in the form of prefix (prefix)-key (key)-key value (value), where the prefix can specifically include data types such as osdmap, monmap, mdsmap, authmap, and logmap, and the key can be each The data version corresponding to each data type, value can be the specific information corresponding to the corresponding key.
例如,osdmap:128,osdmap为prefix,128为key,即osdmap的版本号为128。而对应的value就是128版本的osdmap的具体信息。For example, osdmap:128, osdmap is the prefix, 128 is the key, that is, the version number of osdmap is 128. The corresponding value is the specific information of the 128 version of osdmap.
在实际应用中,用户可以在任意一个节点例如节点1上的相关界面上输入相应的指令,此时该节点1上的客户端被启动,客户端可以依据指令中携带的主机名,查询主机名和IP地址的对应关系,以获取主机对应的IP地址,从而依据该IP地址,与相应的服务端建立连接,并向服务端发送与指令相对应的命令。In practical applications, the user can input the corresponding command on any node such as the relevant interface on node 1. At this time, the client on the node 1 is started, and the client can query the host name and The corresponding relationship of the IP address is to obtain the corresponding IP address of the host, so as to establish a connection with the corresponding server according to the IP address, and send the command corresponding to the instruction to the server.
主机名用于表示节点的名称。在本发明实施例中,每个节点有其唯一的一个主机名,可以依据主机名区分不同的节点。The hostname is used to represent the name of the node. In the embodiment of the present invention, each node has its unique host name, and different nodes can be distinguished according to the host name.
每个服务端有其对应的一个IP地址。客户端依据IP地址便可以建立与该IP地址所指向的服务端的通信连接。Each server has its corresponding IP address. Based on the IP address, the client can establish a communication connection with the server pointed to by the IP address.
S102:客户端接收服务端反馈的响应结果。S102: The client receives a response result fed back by the server.
服务端接收到客户端发送的命令后,可以读取自身节点的kvstore中与该命令相对应的数据,并将这些数据作为响应结果反馈给客户端。After receiving the command sent by the client, the server can read the data corresponding to the command in the kvstore of its own node, and feed back the data to the client as a response result.
S103:客户端依据响应结果中携带的数据,调用相应的脚本程序对数据进行处理,以实现数据的自动化处理。S103: The client invokes a corresponding script program to process the data according to the data carried in the response result, so as to realize automatic data processing.
用户输入的指令不同,客户端所连接的服务端以及向服务端发送的命令也会有所不同,相应的,服务端反馈的响应结果中携带的数据也会有所不同,对于不同的数据,客户端的处理方式也会有所差异。The command entered by the user is different, the server connected to the client and the command sent to the server will also be different, and correspondingly, the data carried in the response result fed back by the server will also be different. For different data, Clients are also handled differently.
接下来将以举例说明的方式,对具体形式的数据处理流程展开介绍。Next, the specific form of data processing flow will be introduced by way of example.
针对于不同的操作需求,用户可以在节点上输入不同形式的指令。在本发明实施例中,指令可以分成两种类型,一种类型为信息对比指令,另一种类型为数据查询指令。According to different operation requirements, users can input different forms of instructions on the nodes. In the embodiment of the present invention, the instructions can be divided into two types, one type is an information comparison instruction, and the other type is a data query instruction.
其中,信息对比指令用于对不同节点的kvstore中的数据的一致性进行验证。信息对比指令中可以携带有对比标识以及多个节点的主机名。Wherein, the information comparison instruction is used to verify the consistency of the data in the kvstore of different nodes. The information comparison instruction may carry a comparison identifier and host names of multiple nodes.
数据查询指令用于对某个或某些节点的kvstore中存储的数据进行查询,从而获取所需的数据。在数据查询指令中可以携带有至少一个节点的主机名。The data query instruction is used to query the data stored in the kvstore of one or some nodes, so as to obtain the required data. The host name of at least one node may be carried in the data query instruction.
为了保证查询的条理性、避免查询信息出现混乱,一般以一个节点作为查询的处理单位,也即在数据查询指令中携带一个节点的主机名。In order to ensure the orderliness of the query and avoid confusion in the query information, a node is generally used as the processing unit of the query, that is, the host name of a node is carried in the data query command.
当指令为信息对比指令时,与指令相对应的命令为获取服务端中所有数据信息的命令。具体的,服务端反馈的响应结果中携带的数据可以包括映射表和键值表。其中,映射表中存储有数据类型和数据版本的对应关系;键值表中存储有各数据版本及其相应的目标数据的对应关系。目标数据即为数据版本所对应的具体数据信息。When the instruction is an information comparison instruction, the command corresponding to the instruction is a command for obtaining all data information in the server. Specifically, the data carried in the response result fed back by the server may include a mapping table and a key-value table. Wherein, the corresponding relationship between data types and data versions is stored in the mapping table; the corresponding relationship between each data version and its corresponding target data is stored in the key-value table. The target data is specific data information corresponding to the data version.
相应的,客户端可以接收各服务端反馈的映射表,并将所有映射表进行对比,以得到各映射表各自独有的数据类型和数据版本。客户端接收各服务端反馈的键值表,并调用反序列化脚本对键值表中的目标数据进行反序列化处理,并保存反序列化处理后的键值表。Correspondingly, the client can receive the mapping tables fed back by each server, and compare all the mapping tables to obtain the unique data type and data version of each mapping table. The client receives the key-value table fed back by each server, calls the deserialization script to deserialize the target data in the key-value table, and saves the deserialized key-value table.
举例说明,假设用户需要将节点1和节点2的kvstore中的数据进行比较,其具体处理流程如下,For example, assuming that the user needs to compare the data in the kvstore of node 1 and node 2, the specific processing flow is as follows,
(1)用户可以在任意一个节点例如节点1上运行指令“store-tool-clientautoContrast host1 host2”来启动节点1上的客户端。(1) The user can run the command "store-tool-clientautoContrast host1 host2" on any node such as node 1 to start the client on node 1.
其中,“store-tool-client”表示客户端程序,autoContrast为命令参数,host1为节点1的主机名,host2为节点2的主机名。Among them, "store-tool-client" indicates the client program, autoContrast is the command parameter, host1 is the host name of node 1, and host2 is the host name of node 2.
因为需要获取两个节点的kvstore中的数据,在具体实现中,客户端可以先和其中的一个节点的服务端建立连接,获取该节点kvstore中的数据。然后再和另一个节点的服务端建立连接,获取该节点kvstore中的数据。以先与节点1的服务端建立连接为例,客户端可以进入(2)。Because it is necessary to obtain the data in the kvstore of two nodes, in a specific implementation, the client can first establish a connection with the server of one of the nodes to obtain the data in the kvstore of the node. Then establish a connection with the server of another node to obtain the data in the kvstore of the node. Taking the example of first establishing a connection with the server of node 1, the client can enter (2).
(2)客户端依据主机名和IP地址的对应关系,获取到节点1的IP地址。根据该IP地址,可以和节点1上的服务端建立连接,此时,客户端可以向该服务端发送查询所有prefix的命令。(2) The client obtains the IP address of node 1 according to the correspondence between the host name and the IP address. According to the IP address, a connection can be established with the server on node 1. At this time, the client can send a command to query all prefixes to the server.
(3)节点1的服务端接收到该命令后,先列举一下本地kvstore中的prefix,然后逐个查询不同prefix所对应的key。(3) After receiving the command, the server of node 1 first lists the prefixes in the local kvstore, and then queries the keys corresponding to different prefixes one by one.
一个节点的kvstore中可以包括有多个prefix,每个prefix有其对应的一个key以及与该key相应的value。A node's kvstore can include multiple prefixes, and each prefix has a corresponding key and a value corresponding to the key.
服务端可以先向客户端发送prefix-key的映射表,然后将不同prefix的查询结果打包成网络消息,逐个发送给客户端。The server can first send the prefix-key mapping table to the client, and then package the query results of different prefixes into network messages, and send them to the client one by one.
其中,查询结果可以是服务端获取的键值表即key-value表。每个prefix都有其对应的key-value表。Wherein, the query result may be a key-value table obtained by the server, that is, a key-value table. Each prefix has its corresponding key-value table.
(4)客户端收到节点1的服务端发回的prefix-key的映射表后,先将该映射表保存下来。然后处理服务端发回的打包后的不同prefix的所有key-value表。(4) After receiving the prefix-key mapping table sent back by the server of node 1, the client first saves the mapping table. Then process all the packaged key-value tables with different prefixes sent back by the server.
由于服务端反馈的key-value表为序列化后的数据。客户端可以调用反序列化脚本程序对数据进行反序列化处理,然后将反序列化处理后的数据进行存储。具体的,数据存储时的文件名可以采用hostname+prefix的格式。Because the key-value table fed back by the server is serialized data. The client can call the deserialization script program to deserialize the data, and then store the deserialized data. Specifically, the file name during data storage may adopt the format of hostname+prefix.
(5)客户端按照上述步骤(2)(3)(4)的处理流程,可以对节点2执行相应的处理。(5) The client can perform corresponding processing on the node 2 according to the processing flow of the above steps (2) (3) (4).
(6)客户端对比节点1和对节点2的prefix-key的映射表,输出这两个节点独有的prefix以及key。(6) The client compares node 1 with the prefix-key mapping table of node 2, and outputs the unique prefix and key of these two nodes.
在具体实现中,可以将进行对比之后的输出结果进行保存或展示,用户依据该输出结果,便可以直接获知节点1和节点2的kvstore中的数据是否一致。In a specific implementation, the output result after the comparison can be saved or displayed, and the user can directly know whether the data in the kvstore of node 1 and node 2 are consistent according to the output result.
当节点1和对节点2没有独有的prefix以及key时,则说明这两个节点的kvstore中的数据一致,实现了数据的同步。When node 1 and node 2 do not have a unique prefix and key, it means that the data in the kvstore of the two nodes is consistent, and data synchronization is realized.
当节点1或对节点2中存在独有的prefix以及key时,则说明这两个节点的kvstore中的数据不一致,未实现数据的同步。When there is a unique prefix and key in node 1 or pair node 2, it means that the data in the kvstore of the two nodes is inconsistent, and the data synchronization has not been realized.
和现有技术中用户手动查询、人工对比等步骤相比,在本发明实施例中,用户只需输入一条指令,便可以获取到相应的输出结果。简化了用户的操作流程,提升了数据的处理效率。Compared with the steps of manual query and manual comparison in the prior art, in the embodiment of the present invention, the user only needs to input one command to obtain the corresponding output result. It simplifies the user's operation process and improves the data processing efficiency.
当指令为数据查询指令时,根据实际操作中,用户所需获取的数据信息的不同,数据查询指令可以包括有4个类型的指令:list、dump、dumpAll和get。When the command is a data query command, the data query command may include four types of commands: list, dump, dumpAll and get according to the different data information that the user needs to obtain in actual operation.
其中,list表示查询节点的kvstore中所有prefix和key。Among them, list represents all prefixes and keys in the kvstore of the query node.
以启动节点1上的客户端为例,list指令的实施方式如下,Taking starting the client on node 1 as an example, the implementation of the list command is as follows,
(1)用户可以在host1上运行指令“tore-tool-client list host1”来启动客户端。(1) The user can run the command "tore-tool-client list host1" on host1 to start the client.
(2)客户端依据主机名和IP地址的对应关系,获取到节点1的IP地址。根据该IP地址,可以和节点1上的服务端建立连接,此时,客户端可以向该服务端发送list命令。(2) The client obtains the IP address of node 1 according to the correspondence between the host name and the IP address. According to the IP address, a connection can be established with the server on node 1. At this time, the client can send a list command to the server.
(3)host1的服务端接收到list命令后,查询本地kvstore的所有prefix,将prefix-key映射表发送给客户端。(3) After receiving the list command, the server of host1 queries all prefixes in the local kvstore, and sends the prefix-key mapping table to the client.
(4)客户端可以将接收到的prefix-key映射表输出到屏幕上,以便于用户查看。(4) The client can output the received prefix-key mapping table to the screen, so that the user can check it.
dump表示查询节点的kvstore中某一个prefix的所有key-value。Dump means to query all key-values of a certain prefix in the kvstore of the node.
以启动节点1上的客户端为例,dump指令的实施方式如下,Taking starting the client on node 1 as an example, the implementation of the dump command is as follows,
(1)在host1上运行指令“store-tool-client dump host1 prefix”来启动客户端。(1) Run the command "store-tool-client dump host1 prefix" on host1 to start the client.
其中,prefix可以是具体的一个数据类型,例如,查询host1的osdmap的具体指令为:store-tool-client dump host1 osdmap。Among them, prefix can be a specific data type. For example, the specific command to query the osdmap of host1 is: store-tool-client dump host1 osdmap.
(2)客户端依据主机名和IP地址的对应关系,获取到节点1的IP地址。根据该IP地址,可以和节点1上的服务端建立连接,此时,客户端可以向该服务端发送dump命令。(2) The client obtains the IP address of node 1 according to the correspondence between the host name and the IP address. According to the IP address, a connection can be established with the server on node 1. At this time, the client can send a dump command to the server.
(3)服务端收到dump命令后,查询本地kvstore的指定prefix的所有key以及value,将查询结果打包成网络消息发送给客户端。(3) After receiving the dump command, the server queries all the keys and values of the specified prefix in the local kvstore, and packages the query results into a network message and sends it to the client.
(4)客户端收到服务端反馈的消息后,可以调用反序列化脚本程序对消息中的数据进行反序列化处理,然后将反序列化处理后的数据进行存储。(4) After the client receives the message fed back by the server, it can call the deserialization script program to deserialize the data in the message, and then store the deserialized data.
dumpALL表示查询节点的kvstore中所有的prefix,以及其对应的的所有key-value。dumpALL means to query all prefixes in the kvstore of the node and all corresponding key-values.
以启动节点1上的客户端为例,dumpALL指令的实施方式如下,Taking starting the client on node 1 as an example, the implementation of the dumpALL command is as follows,
(1)在host1上运行指令“store-tool-client dumpALL host1”来启动客户端。(1) Run the command "store-tool-client dumpALL host1" on host1 to start the client.
(2)客户端依据主机名和IP地址的对应关系,获取到节点1的IP地址。根据该IP地址,可以和节点1上的服务端建立连接,此时,客户端可以向该服务端发送dumpALL命令。(2) The client obtains the IP address of node 1 according to the correspondence between the host name and the IP address. According to the IP address, a connection can be established with the server on node 1. At this time, the client can send the dumpALL command to the server.
(3)服务端收到dumpALL命令后,查询本地kvstore中的所有prefix以及每个prefix对应的key-value,将不同prefix的key-value打包成网络消息,逐个发送给客户端。(3) After receiving the dumpALL command, the server queries all the prefixes in the local kvstore and the key-values corresponding to each prefix, packs the key-values of different prefixes into network messages, and sends them to the client one by one.
(4)客户端收到服务端反馈的消息后,可以调用反序列化脚本程序对消息中的数据进行反序列化处理,然后将反序列化处理后的数据进行存储。(4) After the client receives the message fed back by the server, it can call the deserialization script program to deserialize the data in the message, and then store the deserialized data.
get表示查询节点的kvstore中指定prefix中的指定key。get means to query the specified key in the specified prefix in the kvstore of the node.
以启动节点1上的客户端为例,get指令的实施方式如下,Taking starting the client on node 1 as an example, the implementation of the get command is as follows,
(1)在host1上运行指令“store-tool-client get host1 prefix key out””来启动客户端。(1) Run the command "store-tool-client get host1 prefix key out"" on host1 to start the client.
(2)客户端依据主机名和IP地址的对应关系,获取到节点1的IP地址。根据该IP地址,可以和节点1上的服务端建立连接,此时,客户端可以向该服务端发送get命令。(2) The client obtains the IP address of node 1 according to the correspondence between the host name and the IP address. According to the IP address, a connection can be established with the server on node 1, and at this time, the client can send a get command to the server.
(3)服务端收到get命令后,查询本地kvstore中的对应prefix的对应key,将该key的value发送给客户端。(3) After receiving the get command, the server queries the corresponding key corresponding to the prefix in the local kvstore, and sends the value of the key to the client.
(4)客户端调用反序列化脚本程序对接收到的value进行反序列化处理,然后将反序列化处理后的value输出到屏幕上,以便于用户查看。(4) The client calls the deserialization script program to deserialize the received value, and then outputs the deserialized value to the screen for easy viewing by the user.
需要说明的是,一个节点上的客户端除了和自身节点的服务端实现信息的交互外,还可以和其它节点上的服务端实现信息的交互,从而可以实现跨节点查询的功能。It should be noted that, in addition to realizing information interaction with the server of its own node, a client on a node can also realize information interaction with servers on other nodes, so as to realize the function of cross-node query.
例如,用户在节点1的相关界面上输入相应的指令后,节点1上的客户端被启动,假设指令中携带的是节点2的主机名,此时客户端可以依据主机名和IP地址的对应关系,获取到该主机名所对应的IP地址,该IP地址所指向的是节点2上的服务端,此时节点1上的客户端可以和节点2上的服务端建立通信连接。由于节点2上的服务端可以读取节点2的kvstore中的数据,并将读取的数据反馈给客户端。因此,用户在节点1上输入指令,便可以获取到节点2中的数据,实现了跨节点查询。For example, after the user enters the corresponding command on the relevant interface of node 1, the client on node 1 is started. Suppose the command carries the host name of node 2. At this time, the client can use the corresponding relationship between the host name and the IP address , the IP address corresponding to the host name is obtained, and the IP address points to the server on node 2. At this time, the client on node 1 can establish a communication connection with the server on node 2. Since the server on node 2 can read the data in the kvstore of node 2, and feed back the read data to the client. Therefore, when the user enters an instruction on node 1, the data in node 2 can be obtained, realizing cross-node query.
由上述技术方案可以看出,对于每个节点设置了相应的客户端程序和服务端程序,客户端程序可以向用户提供服务界面,以便于用户根据需求输入相应的指令。服务端程序可以实现数据的查询和读取,客户端程序可以和不同节点的服务端程序进行交互。客户端程序依据接收的指令,可以向相应的服务端发送与该指令相对应的命令,从而获取服务端反馈的响应结果,并依据该响应结果中携带的数据,调用相应的脚本程序对数据进行处理,以实现数据的自动化处理。相比于现有技术中完全依据于人工对数据进行处理,在该过程中,用户只需输入指令,便可以实现数据的自动化处理,提升了kvstore中数据处理的效率,并且有效的保证了数据处理的准确性。It can be seen from the above technical solution that a corresponding client program and server program are set for each node, and the client program can provide a service interface to the user, so that the user can input corresponding instructions according to requirements. The server program can realize the query and reading of data, and the client program can interact with the server programs of different nodes. According to the received instruction, the client program can send the command corresponding to the instruction to the corresponding server, so as to obtain the response result fed back by the server, and call the corresponding script program to process the data according to the data carried in the response result. processing to automate the processing of data. Compared with the existing technology that completely relies on manual data processing, in this process, the user only needs to input instructions to realize the automatic processing of data, which improves the efficiency of data processing in kvstore and effectively guarantees the data processing accuracy.
图2为本发明实施例提供的一种数据处理的装置的结构示意图,对分布式文件系统中的每个节点设置相应的客户端程序和服务端程序,所述装置包括发送单元21、接收单元22和处理单元23;Fig. 2 is a schematic structural diagram of a data processing device provided by an embodiment of the present invention, and a corresponding client program and a server program are set for each node in the distributed file system, and the device includes a sending
发送单元21,用于依据接收的指令,向相应的服务端发送与指令相对应的命令;The sending
接收单元22,用于接收服务端反馈的响应结果;The receiving
处理单元23,用于依据响应结果中携带的数据,调用相应的脚本程序对数据进行处理,以实现数据的自动化处理。The
可选的,发送单元包括接收子单元、查询子单元和建立子单元;Optionally, the sending unit includes a receiving subunit, a query subunit and an establishment subunit;
接收子单元,用于接收指令;The receiving subunit is used to receive instructions;
查询子单元,用于依据指令中携带的主机名,查询主机名和IP地址的对应关系,以获取主机对应的IP地址;The query subunit is used to query the corresponding relationship between the host name and the IP address according to the host name carried in the instruction, so as to obtain the corresponding IP address of the host;
建立子单元,用于依据IP地址,与相应的服务端建立连接,并向服务端发送与指令相对应的命令。The establishment subunit is used to establish a connection with the corresponding server according to the IP address, and send a command corresponding to the instruction to the server.
可选的,指令包括信息对比指令和数据查询指令;其中,信息对比指令中携带有对比标识以及多个节点的主机名;数据查询指令中携带有至少一个节点的主机名。Optionally, the instruction includes an information comparison instruction and a data query instruction; wherein, the information comparison instruction carries comparison identifiers and host names of multiple nodes; the data query instruction carries at least one node host name.
可选的,当指令为信息对比指令时,Optionally, when the instruction is an information comparison instruction,
相应的,处理单元包括接收子单元、对比子单元和保存子单元;Correspondingly, the processing unit includes a receiving subunit, a comparing subunit and a saving subunit;
接收子单元,用于接收各服务端反馈的映射表;其中,映射表中存储有数据类型和数据版本的对应关系;The receiving subunit is used to receive the mapping table fed back by each server; wherein, the mapping table stores the corresponding relationship between the data type and the data version;
对比子单元,用于将所有映射表进行对比,以得到各映射表各自独有的数据类型和数据版本;The comparison subunit is used to compare all the mapping tables to obtain the unique data type and data version of each mapping table;
保存子单元,用于接收各服务端反馈的键值表,并调用反序列化脚本对键值表中的数据进行反序列化处理,并保存反序列化处理后的键值表。图2所对应实施例中特征的说明可以参见图1所对应实施例的相关说明,这里不再一一赘述。Save the sub-unit, which is used to receive the key-value table fed back by each server, and call the deserialization script to deserialize the data in the key-value table, and save the deserialized key-value table. For descriptions of features in the embodiment corresponding to FIG. 2 , reference may be made to relevant descriptions of the embodiment corresponding to FIG. 1 , and details will not be repeated here.
由上述技术方案可以看出,对于每个节点设置了相应的客户端程序和服务端程序,客户端程序可以向用户提供服务界面,以便于用户根据需求输入相应的指令。服务端程序可以实现数据的查询和读取,客户端程序可以和不同节点的服务端程序进行交互。客户端程序依据接收的指令,可以向相应的服务端发送与该指令相对应的命令,从而获取服务端反馈的响应结果,并依据该响应结果中携带的数据,调用相应的脚本程序对数据进行处理,以实现数据的自动化处理。相比于现有技术中完全依据于人工对数据进行处理,在该过程中,用户只需输入指令,便可以实现数据的自动化处理,提升了kvstore中数据处理的效率,并且有效的保证了数据处理的准确性。It can be seen from the above technical solution that a corresponding client program and server program are set for each node, and the client program can provide a service interface to the user, so that the user can input corresponding instructions according to requirements. The server program can realize the query and reading of data, and the client program can interact with the server programs of different nodes. According to the received instruction, the client program can send the command corresponding to the instruction to the corresponding server, so as to obtain the response result fed back by the server, and call the corresponding script program to process the data according to the data carried in the response result. processing to automate the processing of data. Compared with the existing technology that completely relies on manual data processing, in this process, the user only needs to input instructions to realize automatic data processing, which improves the efficiency of data processing in kvstore and effectively guarantees the data processing accuracy.
图3为本发明实施例提供的一种数据处理的装置30的硬件结构示意图,装置30包括:FIG. 3 is a schematic diagram of a hardware structure of a
存储器31,用于存储计算机程序;
处理器32,用于执行计算机程序以实现如上述数据处理的方法的步骤。The
本发明实施例还提供了一种计算机可读存储介质,计算机可读存储介质上存储有计算机程序,计算机程序被处理器执行时实现如上述数据处理的方法的步骤。An embodiment of the present invention also provides a computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the steps of the above data processing method are implemented.
以上对本发明实施例所提供的一种数据处理的方法、装置和计算机可读存储介质进行了详细介绍。说明书中各个实施例采用递进的方式描述,每个实施例重点说明的都是与其他实施例的不同之处,各个实施例之间相同相似部分互相参见即可。对于实施例公开的装置而言,由于其与实施例公开的方法相对应,所以描述的比较简单,相关之处参见方法部分说明即可。应当指出,对于本技术领域的普通技术人员来说,在不脱离本发明原理的前提下,还可以对本发明进行若干改进和修饰,这些改进和修饰也落入本发明权利要求的保护范围内。A data processing method, device, and computer-readable storage medium provided by the embodiments of the present invention are described above in detail. Each embodiment in the description is described in a progressive manner, each embodiment focuses on the difference from other embodiments, and the same and similar parts of each embodiment can be referred to each other. As for the device disclosed in the embodiment, since it corresponds to the method disclosed in the embodiment, the description is relatively simple, and for the related information, please refer to the description of the method part. It should be pointed out that for those skilled in the art, without departing from the principle of the present invention, some improvements and modifications can be made to the present invention, and these improvements and modifications also fall within the protection scope of the claims of the present invention.
专业人员还可以进一步意识到,结合本文中所公开的实施例描述的各示例的单元及算法步骤,能够以电子硬件、计算机软件或者二者的结合来实现,为了清楚地说明硬件和软件的可互换性,在上述说明中已经按照功能一般性地描述了各示例的组成及步骤。这些功能究竟以硬件还是软件方式来执行,取决于技术方案的特定应用和设计约束条件。专业技术人员可以对每个特定的应用来使用不同方法来实现所描述的功能,但是这种实现不应认为超出本发明的范围。Professionals can further realize that the units and algorithm steps of the examples described in conjunction with the embodiments disclosed herein can be implemented by electronic hardware, computer software or a combination of the two. In order to clearly illustrate the possible For interchangeability, in the above description, the composition and steps of each example have been generally described according to their functions. Whether these functions are executed by hardware or software depends on the specific application and design constraints of the technical solution. Skilled artisans may use different methods to implement the described functions for each specific application, but such implementation should not be regarded as exceeding the scope of the present invention.
结合本文中所公开的实施例描述的方法或算法的步骤可以直接用硬件、处理器执行的软件模块,或者二者的结合来实施。软件模块可以置于随机存储器(RAM)、内存、只读存储器(ROM)、电可编程ROM、电可擦除可编程ROM、寄存器、硬盘、可移动磁盘、CD-ROM、或技术领域内所公知的任意其它形式的存储介质中。The steps of the methods or algorithms described in connection with the embodiments disclosed herein may be directly implemented by hardware, software modules executed by a processor, or a combination of both. Software modules can be placed in random access memory (RAM), internal memory, read-only memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, removable disk, CD-ROM, or any other Any other known storage medium.
Claims (6)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201810678182.6A CN108804711B (en) | 2018-06-27 | 2018-06-27 | A data processing method, device and computer-readable storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201810678182.6A CN108804711B (en) | 2018-06-27 | 2018-06-27 | A data processing method, device and computer-readable storage medium |
Publications (2)
Publication Number | Publication Date |
---|---|
CN108804711A CN108804711A (en) | 2018-11-13 |
CN108804711B true CN108804711B (en) | 2022-12-06 |
Family
ID=64071206
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201810678182.6A Active CN108804711B (en) | 2018-06-27 | 2018-06-27 | A data processing method, device and computer-readable storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN108804711B (en) |
Families Citing this family (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN109739828B (en) * | 2018-12-29 | 2021-06-29 | 咪咕文化科技有限公司 | A data processing method, device and computer-readable storage medium |
CN110718218B (en) * | 2019-09-12 | 2022-08-23 | 百度在线网络技术(北京)有限公司 | Voice processing method, device, equipment and computer storage medium |
CN110718219B (en) * | 2019-09-12 | 2022-07-22 | 百度在线网络技术(北京)有限公司 | Voice processing method, device, equipment and computer storage medium |
Citations (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN104333578A (en) * | 2014-10-23 | 2015-02-04 | 秦科 | Distributed data exchange system and method |
CN106302607A (en) * | 2015-06-05 | 2017-01-04 | 腾讯科技(深圳)有限公司 | It is applied to block storage system and the method for cloud computing |
CN107203594A (en) * | 2017-04-28 | 2017-09-26 | 努比亚技术有限公司 | A kind of data processing equipment, method and computer-readable recording medium |
CN107256269A (en) * | 2013-05-03 | 2017-10-17 | 脸谱公司 | Method, computer readable non-transitory storage medium and system |
CN108171473A (en) * | 2017-12-26 | 2018-06-15 | 北京九章云极科技有限公司 | A kind of Data Analysis Services system and data analysis processing method |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN103581229B (en) * | 2012-07-26 | 2018-06-15 | 腾讯科技(深圳)有限公司 | Distributed file system, file access method and client |
-
2018
- 2018-06-27 CN CN201810678182.6A patent/CN108804711B/en active Active
Patent Citations (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN107256269A (en) * | 2013-05-03 | 2017-10-17 | 脸谱公司 | Method, computer readable non-transitory storage medium and system |
CN104333578A (en) * | 2014-10-23 | 2015-02-04 | 秦科 | Distributed data exchange system and method |
CN106302607A (en) * | 2015-06-05 | 2017-01-04 | 腾讯科技(深圳)有限公司 | It is applied to block storage system and the method for cloud computing |
CN107203594A (en) * | 2017-04-28 | 2017-09-26 | 努比亚技术有限公司 | A kind of data processing equipment, method and computer-readable recording medium |
CN108171473A (en) * | 2017-12-26 | 2018-06-15 | 北京九章云极科技有限公司 | A kind of Data Analysis Services system and data analysis processing method |
Also Published As
Publication number | Publication date |
---|---|
CN108804711A (en) | 2018-11-13 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN108510389B (en) | Blockchain-based smart contract calling method, device and readable storage medium | |
CN107343027B (en) | APP sharing method | |
CN111045833B (en) | Interface calling method and device | |
CN105516266B (en) | A business monitoring method, system and related equipment | |
CN107402956B (en) | Data processing method and device for large task and computer readable storage medium | |
CN108804711B (en) | A data processing method, device and computer-readable storage medium | |
US11379446B1 (en) | Session-based data storage for chat-based communication sessions | |
CN110532123A (en) | The failover method and device of HBase system | |
CN109274777B (en) | A method, device, equipment and readable storage medium for exporting configuration files | |
CN111277481A (en) | Method, device, equipment and storage medium for establishing VPN tunnel | |
CN114490071A (en) | Resource scheduling method, device, equipment and medium based on cloud game | |
CN110688201A (en) | Log management method and related equipment | |
CN113541987A (en) | A method and apparatus for updating configuration data | |
CN112737921B (en) | Message interaction method, client and communication system | |
CN110597783A (en) | Database management method, device, equipment and storage medium | |
CN114610461B (en) | Task processing method and device | |
CN114301872B (en) | Domain name based access method and device, electronic equipment and storage medium | |
CN115329005A (en) | Multi-cluster cooperation method, system, device and computer readable storage medium | |
CN110809045A (en) | A data communication method and related equipment | |
CN108282374B (en) | A method, system and readable storage medium for configuring NCSI network card | |
CN113055193B (en) | A data multicast transmission method, device, equipment and storage medium | |
CN112925628A (en) | Service management method and device | |
CN109918210B (en) | Method and terminal for displaying offline message | |
CN118312076A (en) | Map icon processing method, device, electronic device and computer readable medium | |
CN118297568A (en) | Conference schedule management method, device, equipment and storage medium |
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 | ||
GR01 | Patent grant | ||
GR01 | Patent grant |