[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN112202862B - Method and device for synchronizing cluster data and files based on kafka - Google Patents

Method and device for synchronizing cluster data and files based on kafka Download PDF

Info

Publication number
CN112202862B
CN112202862B CN202011010531.0A CN202011010531A CN112202862B CN 112202862 B CN112202862 B CN 112202862B CN 202011010531 A CN202011010531 A CN 202011010531A CN 112202862 B CN112202862 B CN 112202862B
Authority
CN
China
Prior art keywords
file
data
kafka
cluster
hot spot
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
Application number
CN202011010531.0A
Other languages
Chinese (zh)
Other versions
CN112202862A (en
Inventor
付少波
王志海
喻波
安鹏
王志华
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Beijing Wondersoft Technology Co Ltd
Original Assignee
Beijing Wondersoft Technology Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Beijing Wondersoft Technology Co Ltd filed Critical Beijing Wondersoft Technology Co Ltd
Priority to CN202011010531.0A priority Critical patent/CN112202862B/en
Publication of CN112202862A publication Critical patent/CN112202862A/en
Application granted granted Critical
Publication of CN112202862B publication Critical patent/CN112202862B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/10Protocols in which an application is distributed across nodes in the network
    • H04L67/1095Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/06Protocols specially adapted for file transfer, e.g. file transfer protocol [FTP]
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

The invention provides a method and a device for synchronizing cluster data and files based on kafka, wherein the method comprises the following steps: a certain node in the cluster receives and analyzes the request, and each node in the cluster corresponds to one consumption group; judging an analysis result, sending the hot spot data to a hot spot data storage topic of Kafka or reading file stream information of a corresponding path by adopting a random access file according to the analysis result, packaging file json information, and sending and storing the packaged file json information to the file data storage topic of Kafka; and the rest nodes in the cluster respectively store topic and file data from the hot spot data of Kafka by using the corresponding consumption groups. According to the scheme of the invention, only the Kafka service plug-in is added in the cluster project, so that the complexity of the project is reduced. And the data in Kafka are all read into all nodes of the cluster, and hot spot data are refreshed into the service memory. And hot spot data sharing and file sharing among cluster servers are realized.

Description

Method and device for synchronizing cluster data and files based on kafka
Technical Field
The invention relates to the field of data processing, in particular to a kafka-based cluster data and file synchronization method and device.
Background
With the development of a distributed system, the application scenario of completing a common project by a distributed cluster is more and more wide, and the data and files of the project need to be synchronized and shared in the distributed cluster. In the prior art, the method for realizing synchronization and sharing of the data and the files of the project in the clusters comprises the steps of realizing file sharing among the clusters based on NAS service and realizing hot spot data sharing based on Redis.
In a mode of realizing the file sharing among clusters based on the NAS service, all the services in the clusters are linked with the NAS service, files are required to be read and written through the NAS service during file uploading or reading, synchronization of attachments, files and the like is not concerned among the services, and the mode of realizing the file sharing among clusters based on the NAS service is used, so that the method is suitable for large-scale projects. For the projects with smaller project scale, when no NAS shared server exists, a simple and practical solution for realizing file synchronization is lacking among clusters.
And based on the manner of realizing hot spot data sharing by the Redis, all services in the cluster are connected with the Redis cluster, and the hot spot data is read and written through the Redis transition to realize data sharing. However, when a difficult data structure or data with larger data are stored, hot spot data stored in a memory need to be adopted, synchronization among clusters is not suitable for implementation by using Redis.
That is, the existing scheme for realizing file sharing among clusters based on NAS service and hot spot data sharing based on dis is not applicable to projects with small scale and without NAS server in the projects, and needs to realize sharing of files among clusters and hot spot data sharing among memories among cluster nodes.
Disclosure of Invention
In order to solve the technical problems, the invention provides a kafka-based cluster data and file synchronization method and device, which are used for solving the problem that some items of the prior art can not realize data file sharing through a NAS (network attached storage) and other sharing servers; the project size is not large, and no NAS server project exists in the projects or the data files and hot spot data sharing cannot be realized through NAS; the project size is not large, no NAS server project exists in the projects, the sharing of files in clusters is needed, and the synchronization of data and files of the projects sharing hot spot data in memories among cluster nodes is needed.
According to a first aspect of the present invention, there is provided a method for synchronizing kafka-based cluster data and files, the method comprising the steps of:
step S101: a certain node in the cluster receives and analyzes the request, and each node in the cluster corresponds to one consumption group;
step S102: judging an analysis result, if the analysis result is that hot spot data is refreshed into the memory, entering step S103; if the analysis result is file sharing, entering step S104;
step S103: transmitting the hot spot data to a hot spot data storage topic of Kafka, and proceeding to step S105;
step S104: reading file stream information of a corresponding path by adopting a random access file, packaging file json information, sending and storing the packaged file json information to a file data storage topic of Kafka, and entering step S105;
step S105: and the rest nodes in the cluster respectively store topic and file data from the hot spot data of Kafka by using the corresponding consumption groups.
Further, in the step S101: a node in the cluster receives and parses the request, and before each node in the cluster corresponds to a consumption group, the method further includes:
and sending a hot spot data sharing request or a file sharing request through a browser or an external system to service a certain node in the docking cluster.
Further, in the step S104, the json information of the encapsulated file includes a file path, a name, a file stream, and a stream location of the file.
Further, for the file data obtained through consumption, the node analyzes the file path, the file stream position and the file name according to the character string information, then generates a corresponding file, and writes the generated file into a corresponding directory.
According to a second aspect of the present invention, there is provided a kafka-based cluster data and file synchronization apparatus, the apparatus comprising:
request parsing module: the method comprises the steps that a certain node in a cluster receives and analyzes a request, and each node in the cluster corresponds to one consumption group;
and a judging module: the method comprises the steps of configuring to judge an analysis result;
a first storage module: a hotspot data store topic configured to send hotspot data to Kafka;
and a second storage module: the method comprises the steps of using a random Access File to read file stream information of a corresponding path, packaging file json information, and sending and storing the packaged file json information to a file data storage topic of Kafka;
and a data acquisition module: the other nodes in the cluster are configured to respectively consume hot spot data and file data from hot spot data storage topic and file data storage topic of Kafka by utilizing corresponding consumption groups.
Further, the system comprises a receiving request module configured to send a hot spot data sharing request or a file sharing request to a service of a certain node in the cluster through a browser or an external system.
Further, the json information of the encapsulated file includes a file path, a name, a file stream, and a stream location of the file.
Further, for the file data obtained through consumption, the node analyzes the file path, the file stream position and the file name according to the character string information, then generates a corresponding file, and writes the generated file into a corresponding directory.
According to a third aspect of the present invention, there is provided a kafka-based cluster data and file synchronization system, comprising:
a processor for executing a plurality of instructions;
a memory for storing a plurality of instructions;
wherein the plurality of instructions are for storing by the memory and loading and executing by the processor the kafka-based cluster data and file synchronization method as described above.
According to a fourth aspect of the present invention, there is provided a computer-readable storage medium having stored therein a plurality of instructions; the instructions are used for loading and executing the synchronization method of the kafka-based cluster data and the file by the processor.
According to the scheme of the invention, only Kafka service plug-ins are required to be added in the cluster project, service middleware such as Redis and NAS is not required to be added, and the complexity of the project is reduced. The method comprises the steps that service for sending hot spot data and data files to the topic of Kafka is achieved through a data sending program in the cluster service, the program sends the data to the Kafka when the hot spot data or the shared files are needed to be shared, a data receiving program in the cluster service adopts different consumption groups to read the data in the topic of the Kafka, all the data in the Kafka are read into all nodes of the cluster, the hot spot data are refreshed into a service memory, and the data files are read and written into the files through random access files and are stored into corresponding catalogues. And hot spot data sharing and file sharing among cluster servers are realized.
The foregoing description is only an overview of the present invention, and is intended to provide a better understanding of the present invention, as it is embodied in the following description, with reference to the preferred embodiments of the present invention and the accompanying drawings.
Drawings
The accompanying drawings, which are included to provide a further understanding of the invention, illustrate the invention and together with the description serve to explain the invention. In the drawings:
FIG. 1 is a flowchart of a method for synchronizing kafka-based cluster data and files according to one embodiment of the invention;
FIG. 2 is a schematic diagram of a method for synchronizing kafka-based cluster data and files according to one embodiment of the present invention;
FIG. 3 is a schematic diagram of an embodiment of a method of kafka-based cluster data and file synchronization of the present invention;
fig. 4 is a block diagram of a synchronization apparatus for kafka-based cluster data and files according to an embodiment of the present invention.
Detailed Description
Definition:
kafka is an open source stream processing platform developed by the Apache software Foundation, written by Scala and Java. Kafka is a high-throughput distributed publish-subscribe messaging system that can handle all action flow data in consumer-scale websites. Such actions (web browsing, searching and other user actions) are a key factor in many social functions on modern networks. These data are typically addressed by processing logs and log aggregations due to throughput requirements. This is a viable solution for log data and offline analysis systems like Hadoop, but with the limitation of requiring real-time processing. The purpose of Kafka is to unify on-line and off-line message processing through the Hadoop parallel loading mechanism, and also to provide real-time messages through the clusters.
Redis: redis is a key-value store system. Like Memcached, it supports relatively more stored value types, including string, list, set, zset (sorted set-ordered set), and hash (hash type). These data types all support push/pop, add/remove, and pick intersection union and difference and richer operations, and these operations are all atomic.
Random Access File: java provides an operation that can randomly access a file, including read and write operations.
A method of kafka-based cluster data and file synchronization, which is one embodiment of the present invention, is first described in connection with fig. 1-2. As shown in fig. 1-2, the method comprises the steps of:
step S101: a certain node in the cluster receives and analyzes the request, and each node in the cluster corresponds to one consumption group;
step S102: judging an analysis result, if the analysis result is that hot spot data is refreshed into the memory, entering step S103; if the analysis result is file sharing, entering step S104;
step S103: transmitting the hot spot data to a hot spot data storage topic of Kafka, and proceeding to step S105;
step S104: reading file stream information of a corresponding path by adopting a random access file, packaging file json information, sending and storing the packaged file json information to a file data storage topic of Kafka, and entering step S105;
step S105: and the rest nodes in the cluster respectively store topic and file data from the hot spot data of Kafka by using the corresponding consumption groups.
In the step S101: a node in the cluster receives and parses the request, and before each node in the cluster corresponds to a consumption group, the method further includes:
and sending a hot spot data sharing request or a file sharing request through a browser or an external system to service a certain node in the docking cluster. The hot spot data sharing request corresponds to refreshing hot spot data to memory.
In the step S104, the json information of the encapsulated file includes a file path, a name, a file stream, and a stream position of the file.
Each node in the cluster can receive and analyze the request, determine a processing mode according to the analysis result, for example, send the hot spot data to a hot spot data storage topic of Kafka, or read file flow information of a corresponding path by adopting a random access file, package the file information, and send and store the packaged file information to the file data storage topic of Kafka.
Each node in the cluster can send and/or receive a file request and a hot spot data request, and the data is acquired from the cluster nodes, so that the hot spot data and the file data sharing among the clusters are realized. And for the read file data, analyzing the file path, the file stream position and the file name according to the character string information, generating a corresponding file, and writing the generated file into a corresponding directory.
After step S105, the subsequent hotspot data request or the file data request may acquire corresponding data from any cluster node, or may access the corresponding data through a browser or an external system, so as to realize sharing of hotspot data and file data between clusters.
The method solves the problem of synchronous sharing of hot spot data in small-scale projects, and solves the problem of synchronous sharing of files in projects without NAS service.
A specific embodiment of kafka-based cluster data and file synchronization is described below in conjunction with fig. 3.
Step S301: the browser or an external system sends hot spot data or file requests to a certain node of the cluster server;
step S302: after receiving the request, the current node analyzes the request, and if the request is a hot spot data request, the current node sends hot spot data to a hot spot data topic; if the file request is a file request, reading file content, packaging file json information and sending the file json information to Kafka;
step S303: 5 nodes in the cluster start to consume the data information in Kafka; refreshing the read hot spot data into a memory;
step S304: for the read file data, analyzing the file path, the file stream position and the file name according to the character string information, then generating a corresponding file, and writing the generated file into a corresponding directory;
step S305: the normal data can be obtained in 5 nodes by the subsequent hot spot data query or file data query request, so that the synchronous sharing of the data and the files among the cluster nodes is realized.
The embodiment of the invention further provides a device for synchronizing the cluster data and the files based on kafka, as shown in fig. 4, the device comprises:
request parsing module: the method comprises the steps that a certain node in a cluster receives and analyzes a request, and each node in the cluster corresponds to one consumption group;
and a judging module: the method comprises the steps of configuring to judge an analysis result;
a first storage module: a hotspot data store topic configured to send hotspot data to Kafka;
and a second storage module: the method comprises the steps of using a random Access File to read file stream information of a corresponding path, packaging file json information, and sending and storing the packaged file json information to a file data storage topic of Kafka;
and a data acquisition module: the other nodes in the cluster are configured to respectively consume hot spot data and file data from hot spot data storage topic and file data storage topic of Kafka by utilizing corresponding consumption groups.
The embodiment of the invention further provides a system for synchronizing the cluster data and the files based on kafka, which comprises the following steps:
a processor for executing a plurality of instructions;
a memory for storing a plurality of instructions;
wherein the instructions are stored by the memory and loaded by the processor and perform a kafka-based method of synchronizing cluster data and files as described above.
The embodiment of the invention further provides a computer readable storage medium, wherein a plurality of instructions are stored in the storage medium; the instructions are used for loading and executing the synchronization method of the kafka-based cluster data and the file by the processor.
It should be noted that, without conflict, the embodiments of the present invention and features of the embodiments may be combined with each other.
In the several embodiments provided in the present invention, it should be understood that the disclosed systems, devices, and methods may be implemented in other manners. For example, the apparatus embodiments described above are merely illustrative, e.g., the division of the elements is merely a logical function division, and there may be additional divisions when actually implemented, e.g., multiple elements or components may be combined or integrated into another system, or some features may be omitted or not performed. Alternatively, the coupling or direct coupling or communication connection shown or discussed with each other may be an indirect coupling or communication connection via some interfaces, devices or units, which may be in electrical, mechanical or other form.
The units described as separate units may or may not be physically separate, and units shown as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution of this embodiment.
In addition, each functional unit in the embodiments of the present invention may be integrated in one processing unit, or each unit may exist alone physically, or two or more units may be integrated in one unit. The integrated units may be implemented in hardware or in hardware plus software functional units.
The integrated units implemented in the form of software functional units described above may be stored in a computer readable storage medium. The software functional unit is stored in a storage medium, and includes several instructions for making a computer device (which may be a personal computer, a physical machine Server, or a network cloud Server, etc., and need to install a Windows or Windows Server operating system) execute part of the steps of the methods described in the embodiments of the present invention. And the aforementioned storage medium includes: a U-disk, a removable hard disk, a Read-Only Memory (ROM), a random access Memory (Random Access Memory, RAM), a magnetic disk, or an optical disk, or other various media capable of storing program codes.
The above description is only of the preferred embodiments of the present invention, and is not intended to limit the present invention in any way, but any simple modification, equivalent variation and modification made to the above embodiments according to the technical substance of the present invention still fall within the scope of the technical solution of the present invention.

Claims (8)

1. A method for synchronizing kafka-based cluster data and files, comprising the steps of:
step S101: a certain node in the cluster receives and analyzes the request, and each node in the cluster corresponds to one consumption group;
step S102: judging an analysis result, if the analysis result is that hot spot data is refreshed into the memory, entering step S103; if the analysis result is file sharing, entering step S104;
step S103: transmitting the hot spot data to a hot spot data storage topic of Kafka, and proceeding to step S105;
step S104: reading file stream information of a corresponding path by adopting a random access file, packaging file json information, sending and storing the packaged file json information to a file data storage topic of Kafka, and entering step S105;
step S105: the other nodes in the cluster respectively store topic and file data from the hot spot data of Kafka by using the corresponding consumption groups;
in the step S101: a node in the cluster receives and parses the request, and before each node in the cluster corresponds to a consumption group, the method further includes:
and sending a hot spot data sharing request or a file sharing request through a browser or an external system to service a certain node in the docking cluster.
2. The kafka-based cluster data and file synchronization method according to claim 1, wherein in the step S104, the encapsulated file json information includes a file path, a name, a file stream, and a stream position of a file.
3. The kafka-based cluster data and file synchronization method according to claim 1, wherein for the file data obtained by consumption, the node parses a file path, a file stream position, a file name according to the character string information, then generates a corresponding file, and writes the generated file into a corresponding directory.
4. A kafka-based cluster data and file synchronization apparatus, the apparatus comprising:
the receiving request module is configured to send a hot spot data sharing request or a file sharing request through a browser or an external system to the service of a certain node in the cluster;
request parsing module: the method comprises the steps that a certain node in a cluster receives and analyzes a request, and each node in the cluster corresponds to one consumption group;
and a judging module: the method comprises the steps of configuring to judge an analysis result;
a first storage module: a hotspot data store topic configured to send hotspot data to Kafka;
and a second storage module: the method comprises the steps of using a random Access File to read file stream information of a corresponding path, packaging file json information, and sending and storing the packaged file json information to a file data storage topic of Kafka;
and a data acquisition module: the other nodes in the cluster are configured to respectively consume hot spot data and file data from hot spot data storage topic and file data storage topic of Kafka by utilizing corresponding consumption groups.
5. The kafka based cluster data and file synchronization device of claim 4, wherein the encapsulated file json information includes file path, name, file stream, stream location of the file.
6. The kafka-based cluster data and file synchronization device according to claim 5, wherein for the file data obtained by consumption, the node parses the file path, the file stream position, the file name according to the character string information, then generates a corresponding file, and writes the generated file into a corresponding directory.
7. A kafka-based cluster data and file synchronization system comprising:
a processor for executing a plurality of instructions;
a memory for storing a plurality of instructions;
wherein the plurality of instructions are for storage by the memory and loading and executing by the processor the kafka based cluster data and file synchronization method according to any of claims 1-3.
8. A computer-readable storage medium having stored therein a plurality of instructions;
the plurality of instructions for loading and executing by a processor the kafka based cluster data and file synchronization method of any one of claims 1-3.
CN202011010531.0A 2020-09-23 2020-09-23 Method and device for synchronizing cluster data and files based on kafka Active CN112202862B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202011010531.0A CN112202862B (en) 2020-09-23 2020-09-23 Method and device for synchronizing cluster data and files based on kafka

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202011010531.0A CN112202862B (en) 2020-09-23 2020-09-23 Method and device for synchronizing cluster data and files based on kafka

Publications (2)

Publication Number Publication Date
CN112202862A CN112202862A (en) 2021-01-08
CN112202862B true CN112202862B (en) 2023-12-05

Family

ID=74016063

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202011010531.0A Active CN112202862B (en) 2020-09-23 2020-09-23 Method and device for synchronizing cluster data and files based on kafka

Country Status (1)

Country Link
CN (1) CN112202862B (en)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113485978B (en) * 2021-06-23 2023-07-21 华泰证券股份有限公司 Method, system and memory for improving read-write throughput capacity of file storage NAS
CN115174423A (en) * 2022-07-12 2022-10-11 中国建设银行股份有限公司 Kafka query method, device, storage medium and equipment

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110209986A (en) * 2019-06-06 2019-09-06 海尔优家智能科技(北京)有限公司 Internal storage state method of data synchronization and device
CN110401724A (en) * 2019-08-22 2019-11-01 北京旷视科技有限公司 File management method, ftp server and storage medium
CN110750562A (en) * 2018-07-20 2020-02-04 武汉烽火众智智慧之星科技有限公司 Storm-based real-time data comparison early warning method and system
CN111221663A (en) * 2019-11-21 2020-06-02 苏州浪潮智能科技有限公司 Message data processing method, device, equipment and readable storage medium

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110750562A (en) * 2018-07-20 2020-02-04 武汉烽火众智智慧之星科技有限公司 Storm-based real-time data comparison early warning method and system
CN110209986A (en) * 2019-06-06 2019-09-06 海尔优家智能科技(北京)有限公司 Internal storage state method of data synchronization and device
CN110401724A (en) * 2019-08-22 2019-11-01 北京旷视科技有限公司 File management method, ftp server and storage medium
CN111221663A (en) * 2019-11-21 2020-06-02 苏州浪潮智能科技有限公司 Message data processing method, device, equipment and readable storage medium

Also Published As

Publication number Publication date
CN112202862A (en) 2021-01-08

Similar Documents

Publication Publication Date Title
LU102666B1 (en) Small-file storage optimization system based on virtual file system in kubernetes user-mode application
CN106021315B (en) Log management method and system for application program
US20170272499A1 (en) Method and device for loading webpage
EP3353671A1 (en) Distributed data processing method and system
CN113452774B (en) Message pushing method, device, equipment and storage medium
WO2011120791A1 (en) Transmission of map-reduce data based on a storage network or a storage network file system
CN111010364B (en) System for offline object-based storage and simulation of REST responses
CN105677251A (en) Storage system based on Redis cluster
CN112202862B (en) Method and device for synchronizing cluster data and files based on kafka
CN104657366A (en) Method and device for writing mass logs in database and log disaster-tolerant system
CN104657435A (en) Storage management method for application data and network management system
CN110837423A (en) Method and device for automatically acquiring data of guided transport vehicle
CN115270033A (en) Data access system, method, equipment and network card
CN104079598A (en) Method and device for realizing collaborative browsing of webpages
CN116303309A (en) File mounting method and device and electronic equipment
CN102867029B (en) A kind of method managing distributive catalogue of document system and distributed file system
EP3349416B1 (en) Relationship chain processing method and system, and storage medium
CN106790521B (en) System and method for distributed networking by using node equipment based on FTP
CN111800519A (en) Communication system, method and device
CN111800511A (en) Processing method, system, equipment and readable storage medium for synchronous login state
CN115580667B (en) Data transmission method, device, equipment and storage medium
CN111597157A (en) Method for improving log processing system architecture
CN108076111B (en) System and method for distributing data in big data platform
CN113360319B (en) Data backup method and device
CN112187916B (en) Cross-system data synchronization method and device

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