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

CN113890875B - Task allocation method and device - Google Patents

Task allocation method and device Download PDF

Info

Publication number
CN113890875B
CN113890875B CN202111163554.XA CN202111163554A CN113890875B CN 113890875 B CN113890875 B CN 113890875B CN 202111163554 A CN202111163554 A CN 202111163554A CN 113890875 B CN113890875 B CN 113890875B
Authority
CN
China
Prior art keywords
task
information
import
target
record
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
CN202111163554.XA
Other languages
Chinese (zh)
Other versions
CN113890875A (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.)
Industrial and Commercial Bank of China Ltd ICBC
Original Assignee
Industrial and Commercial Bank of China Ltd ICBC
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 Industrial and Commercial Bank of China Ltd ICBC filed Critical Industrial and Commercial Bank of China Ltd ICBC
Priority to CN202111163554.XA priority Critical patent/CN113890875B/en
Publication of CN113890875A publication Critical patent/CN113890875A/en
Application granted granted Critical
Publication of CN113890875B publication Critical patent/CN113890875B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

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/06—Protocols specially adapted for file transfer, e.g. file transfer protocol [FTP]
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
    • G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
    • G06F9/5011—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resources being hardware resources other than CPUs, Servers and Terminals
    • G06F9/5022—Mechanisms to release resources
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/08—Configuration management of networks or network elements
    • H04L41/0803—Configuration setting
    • H04L41/0813—Configuration setting characterised by the conditions triggering a change of settings
    • H04L41/082—Configuration setting characterised by the conditions triggering a change of settings the condition being updates or upgrades of network functionality
    • Y—GENERAL 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
    • Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02D—CLIMATE 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/00—Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Software Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Databases & Information Systems (AREA)
  • Computing Systems (AREA)
  • Data Mining & Analysis (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

The specification relates to the technical field of file transmission, and particularly discloses a task allocation method and device, wherein the method comprises the following steps: acquiring a task import summary table, wherein the task import summary table comprises task information of a plurality of file transmission tasks to be distributed; reading first task information from a database of a first file transmission system and reading second task information from a database of a second file transmission system; generating a first information import table and a second information import table according to the task import table, the first task information and the second task information; updating task information in a database of the first file transfer system based on the first information import table; task information in a database of the second file transfer system is updated based on the second information import table. The scheme can reasonably distribute the tasks to the first file transmission system and the second file transmission system, and can ensure stable switching among different file transmission systems.

Description

Task allocation method and device
Technical Field
The present disclosure relates to the field of file transfer technologies, and in particular, to a task allocation method and apparatus.
Background
Currently, the amount of data to be exchanged between business application systems of an enterprise organization is huge, file transfer tools are flexible and various, and a need exists to replace old file transfer tools with new file transfer tools. In the scene of replacing the file transmission tool, a parallel period with a certain time is necessarily existed in order to ensure the stability of transmission.
However, during parallel operation of the file transfer tools, the file transfer tasks are generally manually distributed to different file transfer tools for the new addition, deletion and modification of the transfer nodes and the transfer tasks, which is low in distribution efficiency and prone to errors.
In view of the above problems, no effective solution has been proposed at present.
Disclosure of Invention
The embodiment of the specification provides a task allocation method and a task allocation device, which are used for solving the problems of low task allocation efficiency and easy error in the switching process of a file transmission system in the prior art.
The embodiment of the specification provides a task allocation method, which comprises the following steps: acquiring a task import summary table, wherein the task import summary table comprises task information of a plurality of file transmission tasks to be distributed; reading first task information from a database of a first file transmission system and reading second task information from a database of a second file transmission system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system; generating a first information import table and a second information import table according to the task import table, the first task information and the second task information, wherein the first information import table comprises task information allocated to the first file transmission system and corresponding processing mode identifiers, and the second information import table comprises task information allocated to the second file transmission system and corresponding processing mode identifiers; updating task information in a database of the first file transfer system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
The embodiment of the specification also provides a task allocation device, which comprises: the system comprises an acquisition module, a task importing module and a task managing module, wherein the acquisition module is used for acquiring a task importing total table, and the task importing total table comprises task information of a plurality of file transmission tasks to be distributed; the reading module is used for reading the first task information from the database of the first file transmission system and reading the second task information from the database of the second file transmission system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system; the generation module is used for generating a first information import table and a second information import table according to the task import total table, the first task information and the second task information, wherein the first information import table comprises task information distributed to the first file transmission system and corresponding processing mode identifiers, and the second information import table comprises task information distributed to the second file transmission system and corresponding processing mode identifiers; an updating module, configured to update task information in a database of the first file transfer system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
The embodiments of the present disclosure also provide a computer device, including a processor and a memory for storing instructions executable by the processor, where the processor executes the instructions to implement the steps of the task allocation method described in any of the embodiments above.
The present description also provides a computer-readable storage medium having stored thereon computer instructions that, when executed, implement the steps of the task allocation method described in any of the above embodiments.
In the embodiment of the present disclosure, a task allocation method is provided, which may obtain a task import summary table, where the task import summary table includes task information of a plurality of file transfer tasks to be allocated, read first task information of the file transfer tasks running on a first file transfer system from a database of the first file transfer system, and read second task information of the file transfer tasks running on a second file transfer system from a database of the second file transfer system; generating a first information import table and a second information import table according to a task import table, first task information and second task information, wherein the first information import table comprises task information allocated to a first file transmission system and corresponding processing mode identifiers, the second information import table comprises task information allocated to a second file transmission system and corresponding processing mode identifiers, and then the task information in a database of the first file transmission system can be updated based on the first information import table; task information in a database of the second file transfer system is updated based on the second information import table. In the scheme, the first information import table and the second information import table can be generated according to the task import summary table and the first task information and the second task information so as to distribute the tasks in the task import summary table to the first file transmission system and the second file transmission system, smooth switching between the first file transmission system and the second file transmission system can be realized, task distribution efficiency is improved, and problems such as conflicts caused by the fact that the same file transmission task is distributed to two file transmission systems at the same time are avoided.
Drawings
The accompanying drawings are included to provide a further understanding of the specification, and are incorporated in and constitute a part of this specification. In the drawings:
FIG. 1 illustrates a flow chart of a task allocation method in an embodiment of the present description;
FIG. 2 shows a schematic diagram of a task assigning device in an embodiment of the present description;
fig. 3 shows a GTP architecture block diagram;
fig. 4 shows an ETRAN architecture block diagram;
FIG. 5 shows a block diagram of an introducer in an embodiment of the present disclosure;
FIG. 6 shows a flowchart of the processing of the lead-in device in one embodiment of the present disclosure;
FIG. 7 shows a flow chart of an automatic upgrade apparatus process in one embodiment of the present description;
fig. 8 shows an automatic ETRAN upgrade flowchart in an embodiment of the present description.
Fig. 9 shows a schematic diagram of a computer device in an embodiment of the present description.
Detailed Description
The principles and spirit of the present specification will be described below with reference to several exemplary embodiments. It should be understood that these embodiments are presented merely to enable one skilled in the art to better understand and practice the present description, and are not intended to limit the scope of the present description in any way. Rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the scope of the disclosure to those skilled in the art.
Those skilled in the art will appreciate that the embodiments of the present description may be implemented as a system, apparatus, method, or computer program product. Accordingly, the present disclosure may be embodied in the form of: complete hardware, complete software (including firmware, resident software, micro-code, etc.), or a combination of hardware and software.
The embodiment of the specification provides a task allocation method. FIG. 1 shows a flow chart of a task allocation method in an embodiment of the present description. Although the present description provides methods and apparatus structures as shown in the following examples or figures, more or fewer steps or modular units may be included in the methods or apparatus based on conventional or non-inventive labor. In the steps or the structures of the apparatuses, which logically do not have the necessary cause and effect relationship, the execution order or the structure of the modules of the apparatuses are not limited to the execution order or the structure of the modules shown in the drawings and described in the embodiments of the present specification. The described methods or module structures may be implemented sequentially or in parallel (e.g., in a parallel processor or multithreaded environment, or even in a distributed processing environment) in accordance with the embodiments or the method or module structure connection illustrated in the figures when implemented in a practical device or end product application.
Specifically, as shown in fig. 1, the task allocation method provided in an embodiment of the present disclosure may include the following steps:
step S101, a task import summary table is obtained, wherein the task import summary table comprises task information of a plurality of file transmission tasks to be distributed.
The method in the specification can be applied to a task distribution node, and the task distribution node can be a single server or a module on the server. The task distribution node may obtain a task import summary table. The task import summary table comprises task information of a plurality of file transmission tasks to be distributed. The task information of the file transfer task may include at least one of the following: task identification, task status, task name, operation type, source node name, source node directory, destination node name, destination node directory, task status, integrity check switch, busy check switch, encryption algorithm, compression transmission switch, task abnormality alarm switch, number of file failure retransmissions, etc.
In one embodiment, the user may unify the entry of file transfer tasks into one task import template. The task distribution node may read task information from the task import template and store the task information in a task import summary table. In one embodiment, the task information in the task import summary may be stored in a Concurrent Hash Map (concurrent hash map) structure.
Step S102, reading first task information from a database of a first file transmission system and reading second task information from a database of a second file transmission system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system.
The task distribution node may read task information of a file transfer task running on the first file transfer system, i.e. the first task information, from a database of the first file transfer system. Wherein the first task information may include at least one of: information such as task name, source node name, source directory, destination node name, destination directory, etc. The task distribution node may read task information of the file transfer task running on the second file transfer system, i.e. the second task information, from a database of the second file transfer system. Wherein the second task information may include at least one of: information such as task name, source node name, source directory, destination node name, destination directory, etc.
Step S103, generating a first information import table and a second information import table according to the task import table, the first task information and the second task information, wherein the first information import table includes task information allocated to the first file transmission system and a corresponding processing mode identifier, and the second information import table includes task information allocated to the second file transmission system and a corresponding processing mode identifier.
Step S104, updating task information in a database of the first file transmission system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
After obtaining the task import summary, the first task information, and the second task information, the first information import table and the second information import table may be generated according to the task import summary, the first task information, and the second task information. The first information import table comprises task information distributed to the first file transmission system and corresponding processing mode identifiers. The processing mode identifier recorded in the first information import table may include modification or deletion, so as to modify or delete corresponding task information in the database of the first file transfer system. The second information import table comprises task information distributed to the second file transmission system and corresponding processing mode identifiers. The processing mode identifier recorded in the second information import table may include adding, modifying or deleting task information in the database of the second file transfer system, or modifying or deleting task information in the database of the second file transfer system.
After the first information import table and the second information import table are obtained, if the task distribution node, the first file transmission system and the second file transmission system are deployed on the same server, the task distribution node may call the first import interface of the first file transmission system to update task information in the database of the first file transmission system based on the first information import table. The file distribution node may invoke a second import interface of a second file transfer system to update the task information in the database of the second file transfer system based on a second information import table.
If the task distribution node, the first file transfer system and the second file transfer system are deployed on separate servers, the task distribution node may establish a communication connection with the first file transfer system and the second file transfer system. The task distribution node may send the first information import table to the first file transfer system such that the first file transfer system updates task information in a database of the first file transfer system based on the first information import table. The task distribution node may send the second information import table to the second file transfer system such that the second file transfer system updates task information in a database of the second file transfer system based on the second information import table.
In the scheme of the embodiment, the first information import table and the second information import table can be generated according to the task import summary table and the first task information and the second task information so as to distribute the tasks in the task import summary table to the first file transmission system and the second file transmission system, so that stable switching between the first file transmission system and the second file transmission system can be realized, task distribution efficiency is improved, and problems such as collision caused by simultaneous distribution of the same file transmission task to the two file transmission systems are avoided.
In some embodiments of the present disclosure, generating the first information import table and the second information import table according to the task import summary table, the first task information, and the second task information may include: determining whether the information processing type corresponding to the target task information in the task import summary table is a newly added task; and under the condition that the information processing type corresponding to the target task information is determined to be a new task, generating a new task record in a second information import table, wherein the new task record comprises the target task information.
Specifically, the task distribution node may determine whether the information processing type corresponding to the target task information in the task import summary table is a newly added task. In one embodiment, the information processing type may be carried in the task information of the task import summary. In another embodiment, task information of different information processing types is recorded in different task import tables, and the information processing type corresponding to the task information can be determined according to the name or the identifier of the task import table. In still another embodiment, the task information may include a task identifier, and the task distribution node may query whether the task identifier exists in the first task information and the second task information, and may determine an information processing type corresponding to the task information as a newly added task if the task identifier does not exist in both the first task information and the second task information.
In the case that the information processing type corresponding to the target task information is determined to be a new task, the task distribution node may generate a new task record in the second information import table. The new task record may include target task information. The new task record may further include a new processing identifier, so as to write the target task information into a database of the second file transfer system. By the method, the newly added task can be written into the second file transmission system, and switching from the first file transmission system to the second file transmission system is ensured.
In some embodiments of the present disclosure, generating the first information import table and the second information import table according to the task import summary table, the first task information, and the second task information may include: determining whether the information processing type corresponding to the target task information in the task import summary table is a modification task; under the condition that the information processing type corresponding to the target task information is determined to be a modification task, determining whether a target task identifier in the target task information exists in the first task information; and generating a modified task record in the first information import table and generating a new task record in the first information import table under the condition that the target task identification exists in the first task information, wherein the modified task record and the new task record both comprise the target task information.
Specifically, the task distribution node may determine whether the information processing type corresponding to the target task information in the task import table is a modification task. In one embodiment, the information processing type may be carried in the task information of the task import summary. In another embodiment, task information of different information processing types is recorded in different task import tables, and the information processing type corresponding to the task information can be determined according to the name or the identifier of the task import table.
And under the condition that the information processing type corresponding to the target task information is determined to be a modification task, the task distribution node determines whether a target task identifier in the target task information exists in the first task information. And generating a modified task record in the first information import table by the task distribution node under the condition that the target task identification exists in the first task information, and generating a new task record in the first information import table. The modification task record may include target task information. The modification task record may further include a modification process identifier, and the modification of the state of the task information corresponding to the target task information in the second file transfer system is stopped. The new task record may further include a new processing identifier, so as to write the target task information into a database of the second file transfer system. By the method, the original task information corresponding to the modification task can be deleted, the modified task information is written into the second file transmission system, and the switching from the first file transmission system to the second file transmission system is ensured.
In some embodiments of the present disclosure, generating the first information import table and the second information import table according to the task import summary table, the first task information, and the second task information may include: determining whether the information processing type corresponding to the target task information in the task import summary table is a deletion task; determining whether a target task identifier in the target task information exists in the first task information and the second task information under the condition that the information processing type corresponding to the target task information is determined to be a deletion task; generating a deletion task record in the first information import table under the condition that the target task identifier exists in the first task information, wherein the deletion task record comprises the target task identifier; and generating a deletion task record in the second information import table under the condition that the target task identifier exists in the second task information, wherein the deletion task record comprises the target task identifier.
Specifically, the task distribution node may determine whether the information processing type corresponding to the target task information in the task import table is a deletion task. In one embodiment, the information processing type may be carried in the task information of the task import summary. In another embodiment, task information of different information processing types is recorded in different task import tables, and the information processing type corresponding to the task information can be determined according to the name or the identifier of the task import table.
And under the condition that the target task identifier exists in the first task information, the task distribution node can generate a deletion task record in the first information import table, wherein the deletion task record comprises the target task identifier so that the corresponding task information in the first file transmission system can be deleted according to the target task identifier. And under the condition that the target task identifier exists in the second task information, the task distribution node can generate a deletion task record in the second information import table, wherein the deletion task record comprises the target task identifier so that the corresponding task information in the first file transmission system can be deleted according to the target task identifier. By the method, the task information on the file transmission system can be deleted.
In some embodiments of the present disclosure, the target task information includes a source node identifier and a destination node identifier; correspondingly, when determining that the information processing type corresponding to the target task information is a new task, generating a new task record in the second information import table may include: under the condition that the information processing type corresponding to the target task information is determined to be a new task, performing connectivity test based on the source node identifier and the destination node identifier; and generating a new task record in the second information import table under the condition that the test result of the connectivity test is that the test is passed.
Specifically, the target task information in the task import summary table may include a source node identifier and a destination node identifier. Wherein the source node identification is used for identifying a sender node in the file transfer system and the destination node identification is used for identifying a receiver node in the file transfer system. Information such as an IP or a port identifier of the source node and information such as an IP or a port identifier of the destination node can be obtained based on the source node identifier and the destination node identifier. Thereafter, connectivity tests may be performed on the source node and the destination node based on the obtained information. And generating a new task identifier in the second information import table only when the test passes. In the scheme, connectivity test is performed before the task information is newly added, so that the transmission efficiency and success rate of the file transmission task can be improved.
In some embodiments of the present disclosure, updating task information in the database of the first file transfer system based on the first information import table may include at least one of: when the target record in the first information import table is a new task record, task information in the new task record is newly added in a database of the first file transmission system; when the target record in the first information import table is a modified task record, modifying a task state corresponding to task information corresponding to the modified task record in a database of the first file transmission system into a stop state; and deleting task information corresponding to the deletion task record in the database of the first file transmission system when the target record in the first information import table is the deletion task record.
Specifically, the first information import table may include a new task record, where the new task record includes task information and a new processing identifier. When the target record in the first information import table is a new task record, task information corresponding to the new task record can be added in a database of the first file transmission system. The first information import table may include a modification task record including task information and a modification process identification. When the target record in the first information import table is a modified task record, the state of the task information corresponding to the target record in the database of the first file transfer system may be modified to be stopped. The first information import table may include a deletion task record, and the deletion task record may include task information/task identification and deletion process identification. When the target record in the first information import table is a deletion task record, task information corresponding to the target record in the database of the first file transfer system may be deleted. In the above manner, the task information in the database of the first file transfer system can be updated based on the first information import table.
In some embodiments of the present disclosure, the second file transfer system includes a plurality of file transfer nodes, the plurality of file transfer nodes having file transfer software installed thereon; accordingly, the method may further include: acquiring node information and updated version information of a target file transmission node to be upgraded; establishing connection with a corresponding target file transmission node according to the node information of the target file transmission node to be upgraded, and pushing an installation package corresponding to the updated version information to the target file transmission node to be upgraded; and receiving an updating result returned by the target file transmission node to be updated.
In general, the second file transfer system may include a plurality of file transfer nodes, and file transfer software is installed on each file transfer node. Node information and updated version information of the target file transfer node to be upgraded can be obtained. And then, establishing connection with the corresponding target file transmission node according to the node information of the target file transmission node to be upgraded, and pushing an installation package corresponding to the updated version information to the target file transmission node to be upgraded. And then, the task distribution node can also receive the updating result returned by the target file transmission node to be updated. By the method, the transmission software on the plurality of file transmission nodes can be updated in time, the consistency of the transmission software is ensured, and the efficiency and the success rate of file transmission are improved.
In this specification, each embodiment is described in a progressive manner, and identical and similar parts of each embodiment are all referred to each other, and each embodiment mainly describes differences from other embodiments. Specific reference may be made to the foregoing description of related embodiments of the related process, which is not described herein in detail.
The foregoing describes specific embodiments of the present disclosure. Other embodiments are within the scope of the following claims. In some cases, the actions or steps recited in the claims can be performed in a different order than in the embodiments and still achieve desirable results. In addition, the processes depicted in the accompanying figures do not necessarily require the particular order shown, or sequential order, to achieve desirable results. In some embodiments, multitasking and parallel processing are also possible or may be advantageous.
Based on the same inventive concept, a task allocation device is also provided in the embodiments of the present specification, as described in the following embodiments. Since the principle of the task allocation device for solving the problem is similar to that of the task allocation method, the implementation of the task allocation device can refer to the implementation of the task allocation method, and the repetition is not repeated. As used below, the term "unit" or "module" may be a combination of software and/or hardware that implements the intended function. While the means described in the following embodiments are preferably implemented in software, implementation in hardware, or a combination of software and hardware, is also possible and contemplated. Fig. 2 is a block diagram of a task assigning apparatus according to an embodiment of the present specification, as shown in fig. 2, including: the configuration of the acquisition module 201, the reading module 202, the generation module 203, and the update module 204 is described below.
The obtaining module 201 is configured to obtain a task import summary table, where the task import summary table includes task information of a plurality of file transmission tasks to be allocated.
The reading module 202 is configured to read first task information from a database of a first file transfer system and read second task information from a database of a second file transfer system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system.
The generating module 203 is configured to generate a first information import table and a second information import table according to the task import table, the first task information and the second task information, where the first information import table includes task information allocated to the first file transfer system and a corresponding processing mode identifier, and the second information import table includes task information allocated to the second file transfer system and a corresponding processing mode identifier.
The updating module 204 is configured to update task information in a database of the first file transfer system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
In some embodiments of the present description, the generating module may be specifically configured to: determining whether the information processing type corresponding to the target task information in the task import summary table is a newly added task; and under the condition that the information processing type corresponding to the target task information is determined to be a new task, generating a new task record in a second information import table, wherein the new task record comprises the target task information.
In some embodiments of the present description, the generating module may be specifically configured to: determining whether the information processing type corresponding to the target task information in the task import summary table is a modification task; under the condition that the information processing type corresponding to the target task information is determined to be a modification task, determining whether a target task identifier in the target task information exists in the first task information; and generating a modified task record in the first information import table and generating a new task record in the first information import table under the condition that the target task identification exists in the first task information, wherein the modified task record and the new task record both comprise the target task information.
In some embodiments of the present description, the generating module may be specifically configured to: determining whether the information processing type corresponding to the target task information in the task import summary table is a deletion task; determining whether a target task identifier in the target task information exists in the first task information and the second task information under the condition that the information processing type corresponding to the target task information is determined to be a deletion task; generating a deletion task record in the first information import table under the condition that the target task identifier exists in the first task information, wherein the deletion task record comprises the target task identifier; and generating a deletion task record in the second information import table under the condition that the target task identifier exists in the second task information, wherein the deletion task record comprises the target task identifier.
In some embodiments of the present disclosure, the target task information includes a source node identifier and a destination node identifier; correspondingly, when the information processing type corresponding to the target task information is determined to be a new task, generating a new task record in a second information import table, including: under the condition that the information processing type corresponding to the target task information is determined to be a new task, performing connectivity test based on the source node identifier and the destination node identifier; and generating a new task record in the second information import table under the condition that the test result of the connectivity test is that the test is passed.
In some embodiments of the present disclosure, the update module is specifically configured to: when the target record in the first information import table is a new task record, task information in the new task record is newly added in a database of the first file transmission system; when the target record in the first information import table is a modified task record, modifying a task state corresponding to task information corresponding to the modified task record in a database of the first file transmission system into a stop state; and deleting task information corresponding to the deletion task record in the database of the first file transmission system when the target record in the first information import table is the deletion task record.
In some embodiments of the present disclosure, the second file transfer system includes a plurality of file transfer nodes, the plurality of file transfer nodes having file transfer software installed thereon; correspondingly, the device further comprises an upgrading module, and the upgrading module is specifically used for: acquiring node information and updated version information of a target file transmission node to be upgraded; establishing connection with a corresponding target file transmission node according to the node information of the target file transmission node to be upgraded, and pushing an installation package corresponding to the updated version information to the target file transmission node to be upgraded; and receiving an updating result returned by the target file transmission node to be updated.
The above method and apparatus are described below in connection with a specific embodiment, however, it should be noted that this specific embodiment is only for better illustrating the present description, and is not meant to be a undue limitation on the present description.
Currently, the amount of data to be exchanged between banking application systems is huge, and file transfer tools are flexible and various. GTP products are generally used as the main point-to-point data file transmission tools at present, and are mainly applied to file transmission between a host and a platform and between platforms.
GTP products are widely applied and have the use characteristics of multiple nodes, wide use range and large transmission capacity. About 500 production environment GTP product headquarter centralized application nodes, about 900 domestic branch nodes and 14 overseas localization center nodes; the average number of transmission files on a common day is about 70 ten thousand (about 80 ten thousand at the end of a month), and the average transmission file size reaches 2.2T (3.7T at the end of a month).
Referring to fig. 3, a block diagram of the structure of GTP is shown. The GTP transmission node is installed in each application server, and the transmission node information is registered in the GTP management console. The sending and receiving tasks of each node are recorded in a database task table and are sent to each transmission node through a management console. However, when the function is newly added or the problem of the bottom layer is related to the GTP, the GTP needs to be realized through purchasing service, and the response speed is low. Based on the above, in order to improve the autonomous grasping capability of the core technology of the file transmission auxiliary tool and ensure the stability of the data exchange system, the inventor develops a transmission tool capable of replacing GTP, which can be called ETRAN.
ETRAN is based on a high-performance asynchronous communication framework Netty, realizes a NIO server/client transmission platform, utilizes a thread pool mode and a zero copy mechanism provided by Netty, and cooperates with an Lz4 compression algorithm and a custom encoding and decoding to realize a high-concurrency and high-speed file transmission function, thereby solving the problem of high-speed and reliable transmission of a large number of files. The system supports simultaneous multi-to-multi transmission processing of more than 1000 transmission nodes.
Referring to fig. 4, there is shown a block diagram of an ETRAN, as shown in fig. 4, the system comprising: a console 1, a file transmission device 2 (i.e., a file transmission end) and a file reception device 3 (i.e., a file reception end), wherein the console 1 manages the file transmission device 2 and the file reception device 3 registered thereon, including addition, deletion, modification, and start-stop of the file transmission and reception devices. The console 1 also manages the file tasks transmitted by the file transmission device 2. The file receiving device 3 and the file transmitting device 2 transmit the file through a communication connection established therebetween, the file transmitting device 2 may be located at one transmission node, and the file receiving device 3 may be located at another transmission node (may also be referred to as a destination node).
In the process of gradually replacing GTP products by using ETRAN, a parallel period with a certain time is necessarily existed in order to ensure the stability of transmission. During the parallel running of the tool, the stable switching of the two systems is ensured for the new addition, deletion and modification of the transmission node and the transmission task, so that the problems of conflict and the like caused by the existence of one transmission task in the two systems are avoided. Therefore, the application designs a set of self-adaptive import equipment which is suitable for the parallel use period of two transmission products and is configured on different transmission systems, and the equipment automatically judges the deployment condition of the ETRAN of the upstream node and the downstream node. For tasks that already exist on the GTP system, they remain running on the GTP system. For the tasks of adding, modifying and deleting, the task switching from GTP to ETRAN is automatically realized through the configuration importing equipment.
The new adding, modifying and deleting of the task mainly aims at the operation of transmitting task information. Such as adding transmission tasks between ETRAN nodes, modifying a send directory or a receive directory, etc.
The task information may include the following information, as shown in table 1:
TABLE 1
Firstly, GTP products and ETRAN products are required to be installed on each application file transmission server. Specific implementation details of the present solution are described below.
Referring to fig. 5, a schematic diagram of a task introduction device is shown. As shown in fig. 5, the task introduction device is composed of six modules including: the system comprises a task reading module, a task exporting module, a task identifying module, a task distributing module, a database operating module and a connectivity testing module. The modules are described in detail below.
The task reading module is responsible for reading the task configuration table (task import template. Xls) information. ETRAN tasks and GTP tasks are uniformly input into a task import template xls. The data structures of the ETRAN task and the GTP task are compatible with each other, and the task attributes comprise: task name, task ID, operation identification, source node name, source directory, destination node name, target directory, subdirectory scan identification, overlay policy, encryption switch, busy data verification, compression switch, etc. The task information is stored in a task summary table main task by adopting a ConcurrentHashMap structure, and the data structure is shown in the following table 2:
TABLE 2
The task export module is responsible for obtaining the stock transmission tasks of the existing GTP node and ETRAN node on the server. And respectively connecting the GTP database and the ETRAN database, acquiring TASK information, and storing the TASK information in the GTP_OLD_TASK table and the ETRAN_OLD_TASK table. The table structure is shown in table 3 below:
TABLE 3 Table 3
Task name
Source node name
Source catalog
Destination node name
Target directory
The task identification module is mainly responsible for identifying the tasks in the task summary table main task. The ETRAN node name and node ID ensure full network uniqueness. And it needs to ensure that there is a one-to-one mapping relationship between the ETRAN node names and GTP node names. If the GTP node is named as gtp_F-xxx_01, the corresponding ETRAN node is named as etran_F-xxx_01. And the task identification module is used for determining the processing modes of the GTP stock task and the ETRAN task according to node names and information processing types (newly added, deleted and modified) recorded in the main task of the task summary list. The task type is modified if the NodeName@taskId exists in the GTP system or the ETRAN system. If the task does not exist in both systems, the task is newly added. When the task is modified, the old task is deleted and then the new task is added. If the task is modified, the corresponding GTP node is matched according to the ETRAN node name recorded in the main task, and the original task in the corresponding GTP node is deleted when the ETRAN task is newly installed. And finally, the identification results are respectively recorded into two tables of ETRAN_NEW_TASK and GTP_NEW_TASK.
For the newly added ETRAN transmission task, the connectivity test module needs to judge the connectivity between the source node and the destination node first. If the connectivity test passes, the original GTP task is deleted and a new task is loaded onto the ETRAN. Connectivity testing is based on an asynchronous communication framework Netty implementation. And transmitting the IP and PORT of the destination node as parameters to a connectivity test module. Initializing a thread group client group with a type of NioEventLoopGroup, starting a data forwarder process director with a type of Bootstrap, and setting a channel type of the client group as NioSocketChannel; the parameter CONNECT TIMEOUT is set to 10 seconds. The connection is initiated using the sync mode, and a ChannelfuryListener is set for listening for connection responses. The ETRAN sending node initiates a connection to the ETRAN receiving node, monitors the connection result through a channel FutureListener, and if the result is the succc, the ETRAN sending node and the receiving node can communicate and transmit files.
The TASK dispatch module takes as input the table ETRAN_NEW_TASK, GTP_NEW_TASK. And calling an ETRAN import interface and a GTP import interface to import the task information into a database of the ETRAN and the GTP.
The task importer processing logic is described below. Fig. 6 shows a flowchart of the task introduction device processing in an embodiment of the present specification. As shown in fig. 6, a task configuration table (task import template. Xls) may be read to acquire GTP tasks and ETRAN tasks to be imported. And connecting databases of the existing GTP node and ETRAN node to acquire stock task information. If the TASK to be imported is a newly added transmission TASK, firstly calling an ETRAN connectivity test according to the information of a source node and a destination node, and generating a newly added TASK record in an ETRAN_NEW_TASK TASK table if the test passes, otherwise, not generating the ETRAN import TASK. If the task to be imported is a task of a modification type, comparing the task to be imported with the GTP node stock task, and if the stock task does not have the task, processing according to the newly added ETRAN task. If the task exists in the stored GTP task, the ETRAN connectivity test is called, the test passes, a piece of task modification information is recorded in a GTP task list, the state of the corresponding GTP task is changed into a stop state, and a new ETRAN transmission task is generated. If the task type to be imported is deletion, the GTP task list and the ETRAN task list need to be queried and deleted at the same time. After traversing all import tasks in this way, each generates a GTP import information table and an ETRAN import information table. And respectively calling a GTP task import interface and an ETRAN task import interface according to records in the two tables, and respectively importing task information into respective databases.
Considering that the automatic importing device for the task needs to meet the requirement that the transmitting end server and the receiving end server are all provided with ETRAN products with the same version when in use. Thus, the ETRAN can be automatically upgraded. In a banking system, about 500 total-line centralized application nodes, about 900 branch nodes and huge node quantity are adopted, and for upgrading of new version ETRAN products, automatic upgrading is supported so as to reduce the manual operation cost.
Referring to fig. 7, a flowchart of an automatic upgrade apparatus processing procedure in an embodiment of the present disclosure is shown. As shown in fig. 7, the upgrade control CENTER update_center acquires node information to be upgraded and UPDATE version information from a table t_update_info of the database, communicates with each ETRAN transmission node (update_client), pushes version packets, and collects UPDATE results. Each ETRAN transport node (update_client) initiates an Update upgrade monitoring process for communicating with an automatic Update control node update_center. The update_center communicates with the ETRAN transmission node update_client and the transmission of UPDATE packets is implemented based on the Netty framework. The device architecture diagram is shown in fig. 7.
The upgrade control CENTER update_center reads node information to be upgraded from a table t_update_info of the database. The structure of the T_UPDATE_INFO table is shown in Table 4 below:
TABLE 4 Table 4
Field name Field type Use of the same
nodeName VARchar2 Node name
ip VARchar2 IP
port VARchar2 Port (port)
new_version VARchar2 Updating version number
old_version VARchar2 Old version number
upt_begin_time DATE Upgrade start time
upt_end_time DATE Upgrade end time
result VARchar2 Upgrade results
priority VARchar2 Upgrade priority
upt_flag VARchar2 Upgrade identification
The update_center process includes a client thread and a server thread, and is implemented by a Netty framework. The Client thread connects the nodes and sends a software installation package named etran_version_xx. The Server thread is used for receiving the node upgrade feedback information and updating the table T_UPDATE_INFO.
Fig. 8 shows an automatic ETRAN upgrade flowchart in an embodiment of the present description. As shown in fig. 8, the client thread is used to: the upgrade node information read in the database is stored in a local data structure; concurrently linking each server (the link port is the current server receiving port +5); send Header (including update_center itself IP, install package name, etc.); and sending the installation package and waiting for receiving the corresponding installation package. The Server thread is used for: receiving version information and running conditions fed back by each node after restarting; updating the database and recording the upgrade information of each node. The UPDATE thread is a server thread, and is only used for receiving the upgrade installation package, and other times are always in a port monitoring state. The UPDATE snoop port is file accept port +5.
The processing flow comprises the following steps: after receiving the Heaer message sent by the UPDATE_CENTER, creating an UPDATE catalog/UPDATE under the current path; recording an update_center end IP for returning upgrade result information; receiving an installation package and returning an installation result; invoking an update.
The script functions include: closing the ETRAN process of the node; backing up old programs to a/bak catalog; updating the new program; the ETRAN process and the master control program are restarted.
The UPT_RSP thread acquires the current version after the transmission tool is started, and sends information such as node name and the like to the UPDATE_CENTER.
The method and the device in the embodiment can automatically judge the deployment condition of the ETRAN of the upstream node and the downstream node, keep the tasks stored on the GTP system running on the GTP system, and automatically realize the task switching from the GTP to the ETRAN through the configuration importing equipment for the tasks which are newly added, modified and deleted, thereby improving the task allocation efficiency and the accuracy. From the above description, it can be seen that the following technical effects are achieved in the embodiments of the present specification: the first information import table and the second information import table can be generated according to the task import summary table and the first task information and the second task information so as to distribute the tasks in the task import summary table to the first file transmission system and the second file transmission system, smooth switching between the first file transmission system and the second file transmission system can be realized, task distribution efficiency is improved, and problems such as conflict caused by simultaneous distribution of the same file transmission task to the two file transmission systems are avoided.
The embodiment of the present disclosure further provides a schematic structural diagram of a computer device, which may specifically refer to fig. 9, where the schematic structural diagram is based on the task allocation method provided by the embodiment of the present disclosure, and the computer device may specifically include an input device 91, a processor 92, and a memory 93. Wherein the memory 93 is configured to store processor-executable instructions. The processor 92, when executing the instructions, implements the steps of the task allocation method described in any of the embodiments above.
In this embodiment, the input device may specifically be one of the main apparatuses for exchanging information between the user and the computer system. The input device may include a keyboard, mouse, camera, scanner, light pen, handwriting input board, voice input device, etc.; the input device is used to input raw data and a program for processing these numbers into the computer. The input device may also acquire and receive data transmitted from other modules, units, and devices. The processor may be implemented in any suitable manner. For example, the processor may take the form of, for example, a microprocessor or processor, and a computer-readable medium storing computer-readable program code (e.g., software or firmware) executable by the (micro) processor, logic gates, switches, an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), a programmable logic controller, and an embedded microcontroller, among others. The memory may in particular be a memory device for storing information in modern information technology. The memory may comprise a plurality of levels, and in a digital system, may be memory as long as binary data can be stored; in an integrated circuit, a circuit with a memory function without a physical form is also called a memory, such as a RAM, a FIFO, etc.; in the system, the storage device in physical form is also called a memory, such as a memory bank, a TF card, and the like.
In this embodiment, the specific functions and effects of the computer device may be explained in comparison with other embodiments, and will not be described herein.
There is also provided in an embodiment of the present specification a computer storage medium based on a task allocation method, the computer storage medium storing computer program instructions which, when executed, implement the steps of the task allocation method described in any of the embodiments above.
In the present embodiment, the storage medium includes, but is not limited to, a random access Memory (Random Access Memory, RAM), a Read-Only Memory (ROM), a Cache (Cache), a Hard Disk (HDD), or a Memory Card (Memory Card). The memory may be used to store computer program instructions. The network communication unit may be an interface for performing network connection communication, which is set in accordance with a standard prescribed by a communication protocol.
In this embodiment, the functions and effects of the program instructions stored in the computer storage medium may be explained in comparison with other embodiments, and are not described herein.
It will be apparent to those skilled in the art that the modules or steps of the embodiments described above may be implemented in a general purpose computing device, they may be concentrated on a single computing device, or distributed across a network of computing devices, they may alternatively be implemented in program code executable by computing devices, so that they may be stored in a storage device for execution by computing devices, and in some cases, the steps shown or described may be performed in a different order than herein, or they may be separately fabricated into individual integrated circuit modules, or multiple modules or steps within them may be fabricated into a single integrated circuit module. Thus, embodiments of the present specification are not limited to any specific combination of hardware and software.
It is to be understood that the above description is intended to be illustrative, and not restrictive. Many embodiments and many applications other than the examples provided will be apparent to those of skill in the art upon reading the above description. The scope of the disclosure should, therefore, be determined not with reference to the above description, but instead should be determined with reference to the appended claims, along with the full scope of equivalents to which such claims are entitled.
The above description is only of the preferred embodiments of the present invention and is not intended to limit the present invention, but various modifications and variations can be made to the embodiments of the present invention by those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present specification should be included in the protection scope of the present specification.

Claims (10)

1. A method of task allocation, comprising:
acquiring a task import summary table, wherein the task import summary table comprises task information of a plurality of file transmission tasks to be distributed;
reading first task information from a database of a first file transmission system and reading second task information from a database of a second file transmission system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system;
Generating a first information import table and a second information import table according to the task import table, the first task information and the second task information, wherein the first information import table comprises task information allocated to the first file transmission system and corresponding processing mode identifiers, and the second information import table comprises task information allocated to the second file transmission system and corresponding processing mode identifiers;
updating task information in a database of the first file transfer system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
2. The method of claim 1, wherein generating a first information import table and a second information import table from the task import summary table, the first task information, and the second task information comprises:
determining whether the information processing type corresponding to the target task information in the task import summary table is a newly added task;
and under the condition that the information processing type corresponding to the target task information is determined to be a new task, generating a new task record in a second information import table, wherein the new task record comprises the target task information.
3. The method of claim 1, wherein generating a first information import table and a second information import table from the task import summary table, the first task information, and the second task information comprises:
determining whether the information processing type corresponding to the target task information in the task import summary table is a modification task;
under the condition that the information processing type corresponding to the target task information is determined to be a modification task, determining whether a target task identifier in the target task information exists in the first task information;
and generating a modified task record in the first information import table and generating a new task record in the first information import table under the condition that the target task identification exists in the first task information, wherein the modified task record and the new task record both comprise the target task information.
4. The method of claim 1, wherein generating a first information import table and a second information import table from the task import summary table, the first task information, and the second task information comprises:
determining whether the information processing type corresponding to the target task information in the task import summary table is a deletion task;
Determining whether a target task identifier in the target task information exists in the first task information and the second task information under the condition that the information processing type corresponding to the target task information is determined to be a deletion task;
generating a deletion task record in the first information import table under the condition that the target task identifier exists in the first task information, wherein the deletion task record comprises the target task identifier;
and generating a deletion task record in the second information import table under the condition that the target task identifier exists in the second task information, wherein the deletion task record comprises the target task identifier.
5. The method according to claim 2, wherein the target task information includes a source node identifier and a destination node identifier;
correspondingly, when the information processing type corresponding to the target task information is determined to be a new task, generating a new task record in a second information import table, including:
under the condition that the information processing type corresponding to the target task information is determined to be a new task, performing connectivity test based on the source node identifier and the destination node identifier;
And generating a new task record in the second information import table under the condition that the test result of the connectivity test is that the test is passed.
6. The method of claim 1, wherein updating the task information in the database of the first file transfer system based on the first information import table comprises at least one of:
when the target record in the first information import table is a new task record, task information in the new task record is newly added in a database of the first file transmission system;
when the target record in the first information import table is a modified task record, modifying a task state corresponding to task information corresponding to the modified task record in a database of the first file transmission system into a stop state;
and deleting task information corresponding to the deletion task record in the database of the first file transmission system when the target record in the first information import table is the deletion task record.
7. The method of claim 1, wherein the second file transfer system comprises a plurality of file transfer nodes having file transfer software installed thereon;
Correspondingly, the method further comprises the steps of:
acquiring node information and updated version information of a target file transmission node to be upgraded;
establishing connection with a corresponding target file transmission node according to the node information of the target file transmission node to be upgraded, and pushing an installation package corresponding to the updated version information to the target file transmission node to be upgraded;
and receiving an updating result returned by the target file transmission node to be updated.
8. A task assigning apparatus, comprising:
the system comprises an acquisition module, a task importing module and a processing module, wherein the acquisition module is used for acquiring a task importing total table, and the task importing total table comprises task information of a plurality of file transmission tasks to be distributed;
the reading module is used for reading the first task information from the database of the first file transmission system and reading the second task information from the database of the second file transmission system; wherein the first task information includes task information of a file transfer task running on the first file transfer system, and the second task information includes task information of a file transfer task running on the second file transfer system;
the generation module is used for generating a first information import table and a second information import table according to the task import total table, the first task information and the second task information, wherein the first information import table comprises task information distributed to the first file transmission system and corresponding processing mode identifiers, and the second information import table comprises task information distributed to the second file transmission system and corresponding processing mode identifiers;
An updating module, configured to update task information in a database of the first file transfer system based on the first information import table; and updating task information in a database of the second file transmission system based on the second information import table.
9. A computer device comprising a processor and a memory for storing processor-executable instructions which when executed by the processor implement the steps of the method of any one of claims 1 to 7.
10. A computer readable storage medium having stored thereon computer instructions, which when executed by a processor, implement the steps of the method of any of claims 1 to 7.
CN202111163554.XA 2021-09-30 2021-09-30 Task allocation method and device Active CN113890875B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202111163554.XA CN113890875B (en) 2021-09-30 2021-09-30 Task allocation method and device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202111163554.XA CN113890875B (en) 2021-09-30 2021-09-30 Task allocation method and device

Publications (2)

Publication Number Publication Date
CN113890875A CN113890875A (en) 2022-01-04
CN113890875B true CN113890875B (en) 2023-11-24

Family

ID=79005166

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202111163554.XA Active CN113890875B (en) 2021-09-30 2021-09-30 Task allocation method and device

Country Status (1)

Country Link
CN (1) CN113890875B (en)

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
DE102005014365A1 (en) * 2005-03-30 2006-11-30 Schall, Richard, Dr.-Ing. Data e.g. text files, transferring method for electronic data processing system, involves directly loading export data of clients to transfer server, and determining recipient addresses from logical links between export and import objects
CN101820635A (en) * 2010-05-20 2010-09-01 中兴通讯股份有限公司 Method and device for acquiring mobile communication data
CN112732660A (en) * 2021-01-05 2021-04-30 中国工商银行股份有限公司 Intervention type file transmission method, device and system
CN112817828A (en) * 2021-01-29 2021-05-18 中国农业银行股份有限公司 GTP monitoring method, device and equipment
CN113312336A (en) * 2021-06-22 2021-08-27 中国农业银行股份有限公司 Data processing method, data processing apparatus, electronic device, storage medium, and program product

Family Cites Families (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11196797B2 (en) * 2018-08-21 2021-12-07 International Business Machines Corporation Transferring files between computer nodes on different networks

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
DE102005014365A1 (en) * 2005-03-30 2006-11-30 Schall, Richard, Dr.-Ing. Data e.g. text files, transferring method for electronic data processing system, involves directly loading export data of clients to transfer server, and determining recipient addresses from logical links between export and import objects
CN101820635A (en) * 2010-05-20 2010-09-01 中兴通讯股份有限公司 Method and device for acquiring mobile communication data
CN112732660A (en) * 2021-01-05 2021-04-30 中国工商银行股份有限公司 Intervention type file transmission method, device and system
CN112817828A (en) * 2021-01-29 2021-05-18 中国农业银行股份有限公司 GTP monitoring method, device and equipment
CN113312336A (en) * 2021-06-22 2021-08-27 中国农业银行股份有限公司 Data processing method, data processing apparatus, electronic device, storage medium, and program product

Also Published As

Publication number Publication date
CN113890875A (en) 2022-01-04

Similar Documents

Publication Publication Date Title
US7636868B2 (en) Data replication in a distributed system
US8055735B2 (en) Method and system for forming a cluster of networked nodes
US20180367610A1 (en) Data storage method and server applicable to distributed server cluster
US5854895A (en) Network distribution information management system
CN110138588A (en) Configuration file automatic management method and system, configuration management platform and client
US9614646B2 (en) Method and system for robust message retransmission
CN110990432B (en) Device and method for synchronizing distributed cache clusters across machine room
US20100023564A1 (en) Synchronous replication for fault tolerance
US20140059315A1 (en) Computer system, data management method and data management program
CN102012944B (en) Distributed NOSQL (not only structured query language) database capable of providing replication property
CN102333029A (en) Routing method in server cluster system
CN105808274A (en) Software upgrading method and system as well as corresponding clients and servers
CN109639773A (en) A kind of the distributed data cluster control system and its method of dynamic construction
CN112214377B (en) Equipment management method and system
CN104793981A (en) Online snapshot managing method and device for virtual machine cluster
US20230004465A1 (en) Distributed database system and data disaster backup drilling method
JP2020184325A (en) Method for processing replica, node, storage system, server, and readable storage medium
US10776392B2 (en) Apparatus and method to establish a connection between apparatuses while synchronization of connection information thereof is suspended
CN110798358B (en) Distributed service identification method and device, computer readable medium and electronic equipment
CN113890875B (en) Task allocation method and device
US8301750B2 (en) Apparatus, system, and method for facilitating communication between an enterprise information system and a client
CN116414915A (en) Distributed database cluster management and control method and device and database management and control platform
CN109992447B (en) Data copying method, device and storage medium
CN111241200A (en) sSQLite database-based main and standby synchronous processing method and device
CN112214466B (en) Distributed cluster system, data writing method, electronic equipment and storage 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