CN114138888B - Processing method, system, medium and equipment for distributed data routing - Google Patents
Processing method, system, medium and equipment for distributed data routing Download PDFInfo
- Publication number
- CN114138888B CN114138888B CN202111466536.9A CN202111466536A CN114138888B CN 114138888 B CN114138888 B CN 114138888B CN 202111466536 A CN202111466536 A CN 202111466536A CN 114138888 B CN114138888 B CN 114138888B
- Authority
- CN
- China
- Prior art keywords
- database
- database connection
- data source
- target
- data
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000003672 processing method Methods 0.000 title abstract 2
- 238000000034 method Methods 0.000 claims abstract 10
- 238000004590 computer program Methods 0.000 claims 1
- 230000000977 initiatory effect Effects 0.000 claims 1
Images
Classifications
-
- 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/25—Integrating or interfacing systems involving database management systems
-
- 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
- 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/28—Databases characterised by their database models, e.g. relational or object models
- G06F16/284—Relational databases
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the invention provides a processing method, a system, a medium and equipment of a distributed data route, wherein the method comprises the following steps: the transaction manager sends a request for acquiring database connection to the data transfer module; the data switching module establishes a plurality of database connection agents according to the request for acquiring the database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to the database management module; and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager. The embodiment of the invention solves the problem of the access requirement of a distributed system to multiple databases, supports the write operation of the multiple databases in one transaction, ensures the consistency of the transaction, and can flexibly configure the routing rule of the data source without code intrusion.
Description
Technical Field
The present invention relates to the field of information technologies, and in particular, to a method, a system, a medium, and a device for processing a distributed data route.
Background
The technical development of the financial industry is changing day by day, and as the construction of a distributed system enters a normal state, the data storage also faces multi-center separated storage. Therefore, a distributed system needs to solve the problem of accessing multiple data sources to acquire data for processing. Second, accessing multiple data sources for data write operations also faces the problem of distributed transactions. The access requirements of the distributed system to multiple data sources are not constant, and need to be dynamically adjusted according to the traffic and the request amount. A distributed system has a plurality of applications, and the plurality of applications may connect to a plurality of databases, respectively, but one application may also connect to a plurality of databases.
The method has important significance for the construction of the distributed system for solving the problems of simultaneous access of the distributed system to a plurality of databases and the connectivity between one application in the distributed system and the plurality of databases.
Disclosure of Invention
In view of this, embodiments of the present invention provide a processing method, an apparatus, a medium, and a device for distributed data routing, which can enable a distributed system to simultaneously access multiple databases and solve the technical problem of connectivity between one application in the distributed system and the multiple databases.
In order to achieve the above object, a first aspect of the present invention provides a processing method for distributed data routing, where the processing method includes the following steps:
the transaction manager sends a request for acquiring database connection to the data transfer module;
the data switching module establishes a plurality of database connection agents according to the request for acquiring the database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to the database management module;
and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager.
In some possible embodiments, the sending, by the transaction manager, a request for acquiring a database connection to the data forwarding module specifically includes:
and the transaction manager sends a plurality of sql commands to the data transfer module through the data source interface so as to obtain a database connection request corresponding to each sql command.
In some possible embodiments, before the data forwarding module establishes a plurality of database connection proxies according to the request of the database connection, the method further includes:
intercepting each sql command by an interceptor;
and analyzing each intercepted sql command through the interceptor to obtain the command ID and the command content of the sql command.
In some possible embodiments, before creating and sending a database connection task to the corresponding database management module by each database connection agent, the method further includes:
the database connection agent connection compares a routing rule pre-configured by the data transfer module with the command ID to obtain the name of each analyzed data source to be accessed by each sql command;
and the database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source.
In some possible embodiments, the creating, by the database connection broker, a database connection task corresponding to the name of the data source according to the name of the data source specifically includes:
the database connection agent selects a corresponding target data source from a plurality of actual data sources according to the name of the data source; the name of the target data source is the same as that of the data source to be accessed;
and the database connection agent establishes a corresponding database connection task aiming at the selected target data source.
In some possible embodiments, the selecting, by the database management module, a corresponding database according to the database connection task to execute the database connection task specifically includes:
the database management module determines the name of the target database according to the target data source and acquires the actual address of the target database according to the name of the target database;
the database management module triggers the target data source to create a target database connection according to the name of the target database;
the target database is connected with an execution plan for sending the sql command to the target database through the actual address of the target database;
and the target database performs data read-write operation according to the command content in the sql command and returns the result of the read-write operation to the transaction manager.
In some possible embodiments, after the performing, by the target database, data read-write operation according to the command content in the sql command, and returning a result of the read-write operation to the transaction manager, the method further includes:
the transaction manager judges whether the execution result of the corresponding target database is correct or not;
if the result is correct, the transaction manager initiates a commit operation for storing and executing the transaction to a target database corresponding to each sql command in sequence;
and if the result is wrong, the transaction manager initiates a rollback operation for executing the transaction to the target database corresponding to each sql command in sequence.
In a second aspect, the present invention provides a processing system for distributed data routing, including:
the transaction manager is used for sending a request for acquiring database connection to the data transfer module;
the data switching module is used for establishing a plurality of database connection agents according to the request for acquiring the database connection, respectively establishing a database connection task through each database connection agent and sending the database connection task to the database management module;
and the database management module is used for selecting a corresponding database according to the database connection task to execute the database connection task, obtaining an execution result of the database connection task, and returning the execution result to the transaction manager.
In a third aspect, the present invention provides a computer-readable storage medium, on which a computer program is stored, which when executed by a processor, implements any one of the processing methods for distributed data routing as described above.
In a fourth aspect, an embodiment of the present invention provides an electronic device, including:
a processor;
a memory for storing the processor-executable instructions;
wherein the processor is configured to execute the instructions to implement the processing method of distributed data routing as any one of the above.
The technical scheme has the following beneficial effects:
the invention provides a processing method, a system, a medium and a device of a distributed data route, wherein the method comprises the following steps: the transaction manager sends a request for acquiring database connection to the data transfer module; the data switching module establishes a plurality of database connection agents according to the request for acquiring the database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to the database management module; and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager. The embodiment of the invention can solve the problem of the access requirement of a distributed system to multiple databases, support the write operation of multiple databases in one transaction and ensure the consistency of the transaction, and simultaneously can flexibly configure the routing of multiple data sources without intruding codes.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the drawings without creative efforts.
Fig. 1 is a flowchart of a processing method of distributed data routing according to an embodiment of the present invention;
FIG. 2 is a schematic structural diagram of an interceptor intercepting an sql command according to an embodiment of the present invention;
FIG. 3 is a flow chart of a method of data routing in accordance with an embodiment of the present invention;
FIG. 4 is a schematic diagram of a database routing configuration rule according to an embodiment of the present invention;
fig. 5 is an overall flow deployment diagram of a distributed data routing processing method according to an embodiment of the present invention;
FIG. 6 is a block diagram of a processing system for first distributed data routing of an embodiment of the present invention;
FIG. 7 is a functional block diagram of a computer-readable storage medium of an embodiment of the present invention;
fig. 8 is a functional block diagram of an electronic device according to an embodiment of the present invention.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
Example one
Fig. 1 is a flowchart of a processing method of distributed data routing according to an embodiment of the present invention, and as shown in fig. 1, the processing method includes the following steps:
s110, the transaction manager sends a request for acquiring database connection to the data transfer module. Specifically, when a business operation needs to access a database for read-write operation, a data source needs to be accessed through the transaction manager, the database is operated through the data source, a database connection is created, and the data connection is returned. The transaction refers to a database transaction (transaction), and when multiple database operations are performed on a database (for example, multiple database connections are sequentially established to complete an sql command), the database transaction is an inseparable whole, and command operations in the transaction are either all executed or all are not executed. A transaction consists of all database operations performed between the beginning of the transaction and the end of the transaction. The start of the transaction and the end of the transaction are controlled by the transaction manager.
A data source is a source of data, either a device or raw media that provides some desired data. All information for establishing a database connection is stored in the data source. Just as files can be found in a file system by specifying the file name, the corresponding database connection can be found by providing the correct data source name, as an example, if the data is water, the database is a reservoir, the data source is a conduit connecting the reservoir, and the end user sees the data set as water flowing from the conduit.
And S120, the data switching module establishes a plurality of database connection agents according to the request for acquiring the database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to the database management module.
The data transfer module may create multiple database connection agents through which multiple different databases may be accessed since the data transfer module may connect multiple actual databases. Specifically, the data forwarding module configures a plurality of routing rules in advance, the obtained data in the database connection request has an identifier, the name of the database which the request wants to access can be obtained through the identifier, the database connection agent compares the name of the data source with the routing rules, the name of the database connection request can be obtained, and the database connection agent creates a database connection task for the database of the name and sends the database connection task to the database management module. The data transfer module may be understood as a data source agent, and the data source agent may create a plurality of database connection agents, and access a plurality of actual data sources through the plurality of database connection agents. The database connection task is required to be created when communication between the distributed system and the database is performed, and can also be called database connection, and the database connection is one of network communication sockets and is a communication mode in a database communication protocol based on socket communication specifications.
S130, the database management module selects the corresponding database according to the database connection task to execute the database connection task, obtains the execution result of the database connection task, and returns the execution result to the transaction manager.
After receiving the database connection task created by the database connection agent, the database management module creates a target database connection for the target database to be accessed, issues a task execution command, obtains an execution result after the target database executes the task according to the command content, and returns the execution result to the transaction manager. Here, a database management module may be understood as a data source, through which a database connection is established, and through which a connection is established with a corresponding database.
The embodiment of the invention can solve the problem of the access requirement of a distributed system to multiple databases, support the write operation of multiple databases in one transaction and ensure the consistency of the transaction, and can flexibly configure the routing of multiple data sources without intruding codes.
In some embodiments, the transaction manager issues a plurality of sql commands to the data forwarding module through the data source interface to obtain a connection request of the database corresponding to each sql command.
In this embodiment, the data source interface may be a javax.sql.datasource interface, which is a specification in the JDBC2.0 standard and is a database link acquired in the manner of drivermanager.getconnection () in the 1.0 standard. There are also two interface methods javax. sql. datasource: getConnection () method with and without a reference. The data sources can provide database connection in a reusable mode, most of the data sources are realized by adopting a connection pool, and resources can be reused.
In some embodiments, as shown in fig. 2, fig. 2 is a schematic structural diagram of an interceptor intercepting sql command according to an embodiment of the present invention, where before the data forwarding module establishes a plurality of database connection proxies according to a request of database connection, the method further includes: intercepting each sql command by an interceptor; and the interceptor analyzes each intercepted sql command to acquire the command ID and the command content of the sql command. In addition, after the interceptor intercepts and analyzes each sql command, the name of the data source of each command can be set for subsequent personalized extension.
Specifically, through yusdatasource (data source agent), database connection, namely YuspConnection (database connection agent), is obtained through javax.sql.datasource interface, intercepting transmitted sql content by a DataRouteNameInterreceptor (interceptor), analyzing in a DataRouteHandler (data routing handler) after interception, wherein the data routing handler is a handler in the interceptor, each intercepted sql command is analyzed in the data routing handler to obtain the command ID and the command content of the sql, the name of a data source to be connected with each sql can be obtained through the command ID, the YuspConnection (database connection agent) obtains the name of a target data source (getConnectionname) corresponding to each sql command according to the obtained name of the data source and a routing rule obtained from a javax. sql. Connection interface and configured in advance, and the YuspConnection (database connection agent) creates a database connection task (creating prefix) for each command; the database connection broker may also create an execution plan (create Statement), perform rollback of data (rollback), Commit of data (Commit), set auto Commit (setauto Commit), close data connection (colse), set connection read only (setReadOnly), and the like.
In addition, the interceptor in java is the object for dynamically intercepting the action calls, and provides a mechanism which enables a developer to define the code to be executed before and after the execution of an action, and also prevents the execution of the action before the execution of the action, and also provides a way to extract the reusable part in the action. In AOP (Aspect-Oriented Programming) interceptors are used to intercept and then add certain operations before or after a certain method or field is accessed.
In some embodiments, before creating and sending a database connection task to the corresponding database management module by each database connection agent, the method further includes: the database connection agent connection compares a routing rule pre-configured by the data transfer module with the command ID to obtain the name of the data source to be accessed by each sql command after analysis; and the database connection agent establishes a database connection task corresponding to the name of the data source according to the name of the data source.
Specifically, fig. 3 is a flowchart of a method for data routing according to an embodiment of the present invention, and fig. 4 is a schematic diagram of a database routing configuration rule according to an embodiment of the present invention. The sql command of each sql command executed by the database comprises: command ID, a string of characters, shaped as: mod ulea; command content, a standard sql statement, shaped as: select from user 1. For example, the data routing configuration rule cn. module a → a, cn. module a → B … …, where A, B and the like are names of databases, the database connection agent compares the command ID in the sql command with the data routing configuration rule, accesses the a database beginning with cn. module a in the sql command ID, that is, the name of the data source accessed by cn. module a in the sql command is a, and after obtaining the name of the data source to be accessed, the database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source.
As an example, the database routing configuration rule is as follows:
in the route configuration rule of the data source, the name of the visiting database corresponding to the ID in the sql command is configured, and if there is no matching database, the first database visited is defaulted, namely, database a.
In some embodiments, the creating, by the database connection broker, a database connection task corresponding to the name of the data source according to the name of the data source specifically includes: selecting a corresponding target data source which is the same as the name of the data source obtained by comparison from a plurality of actual data sources according to the name of the data source obtained by comparison by the data proxy connection; because the name of the data source obtained after comparison is the name of the target data source to be accessed, the database connection agent creates a corresponding database connection task for the selected target data source. The database connection broker is connected to a plurality of actual databases, so that the database connection broker can access any one of the databases according to the data routing configuration rule.
In some embodiments, the selecting, by the database management module, the corresponding database according to the database connection task to execute the database connection task specifically includes: the database management module determines the name of the target database according to the target data source, and obtains the actual address of the target database according to the name of the target database, for example, the database management module determines the name a of the target database according to the target data source, and in the # a data source configuration, the actual address of the target database may be obtained, for example, "jdbc-ur 1: jdbc: oracle: thin @127.0.0.1:1521: orc 1', the database management module triggers the target data source to create a target database connection according to the name of the target database, the target database connection sends an execution plan of the sql command to the target database according to the actual address of the target database, the target database performs data read-write operation according to the command content in the sql command, and returns the result of the read-write operation to the transaction manager. The execution plan of the sql command means that before the sql command is executed, the database needs to be notified to execute check of sql content in advance, whether a low-level syntax error exists is checked, the sql command is executed only after the check is passed, and the check operation before the execution is called as the execution plan. A database is software that is deployed on a server and that a program accessing the software needs the actual server address on which it is deployed, i.e., the actual address of the database mentioned above.
In some embodiments, after the target database performs a read-write operation on data according to the command content in the sql command, and returns the result of the read-write operation to the transaction manager, the method further includes: and the transaction manager judges whether the execution result of the corresponding target database is correct, if so, the transaction manager sequentially initiates a commit operation for storing and executing the transaction to the target database corresponding to each sql command, and if not, the transaction manager sequentially initiates a rollback operation for executing the transaction to the target database corresponding to each sql command. Specifically, when a program executes business operation, a transaction manager is automatically opened, an sql command is executed through the created database connection, and after the execution of the sql command is completed, if no error report occurs, the transaction manager considers that the operation of the sql command is correct and submits the operation; if an error occurs, the transaction manager considers the operation of the sql command to be incorrect and performs a rollback.
The method can realize that a plurality of applications in the distributed system simultaneously access a plurality of databases, also can realize that one application in the distributed system simultaneously accesses a plurality of data sources, solves the problem of connectivity between one application and a plurality of databases in the distributed system, can ensure that the write operation of the plurality of databases is supported in one transaction and the consistency of the transaction is ensured, and simultaneously can flexibly configure a plurality of data source routing rules without intruding codes.
The flow of operating the database is as follows: the method comprises the steps of obtaining a database connection from a data source, creating an execution plan through the database connection, and executing an sql command through the execution plan, wherein the process is generally called a transaction. If no error report occurs in the execution process, which indicates that the data processing is correct, the transaction manager sequentially initiates a commit operation for storing the executed transaction to the target database corresponding to each sql command, so that the operation data falls into the database, and if an error report occurs in one place in the execution process, the database cannot write the data into the database, and at this time, rollback operation, reconnection and other read-write operations are required.
In order to make those skilled in the art understand the technical solution provided by the embodiment of the present invention, a detailed description is given below of a processing method for distributed data routing provided by the embodiment of the present invention. Fig. 5 is an overall flowchart deployment diagram of a processing method of distributed data routing according to an embodiment of the present invention. The method specifically comprises the following steps:
s1, the affair manager sends the request for obtaining database connection to the data source agent;
s2, the data source agent creates a database connection agent;
s3, creating a database connection task for the data source A to obtain the connection with the database A through the data source A, namely when the first sql needs to be executed, the database connection agent selects the data source A according to the sql command route;
s4, creating a database connection A by the data source A;
s5, connecting the database A with the database A, and executing S6 after the database A returns the connection result to the database A;
s6, the database is connected with the database A to send an execution task for executing the first sql command, and the database A returns the execution result to the transaction manager after the execution of the task is finished;
s7, after the database connection agent receives the return result, the database connection agent creates a second database connection task to the data source B to obtain the connection with the database B through the data source B, namely, the second sql command is executed, and the database connection agent selects the data source B according to the sql command route;
s8, creating a database connection B by the data source B;
s9, connecting the database B with the database B, and executing 10 after the database B returns the connection result to the database;
s10, the database connection B sends an execution task for executing the second sql command, and the database B returns the execution result to the transaction manager after the execution of the task is finished;
by analogy with the above steps, multiple sql commands may be executed until S11 is executed after the last sql command is executed and the execution result is returned to the transaction manager.
S11, the transaction manager judges whether the execution result is normal, and sequentially initiates commit/rollback commands to the database A and the database B through the database connection agent, namely if the execution result is normal, sequentially initiates data storage operations (commit commands) to the database A and the database B through the database connection agent, namely transaction commit operations, and if the execution result is abnormal, sequentially initiates data revocation operations (rollback commands) to the database A and the database B through the database connection agent, namely transaction rollback operations;
s12, the database connection agent sends a commit/rollback command to the database connection A;
s13, the database connection agent A sends the commit/rollback command to the database A, after the commit/rollback command is executed by the database A, the execution result is returned to the database connection agent, and the database connection agent executes S14;
s14, the database connection agent initiates a commit/rollback command to the database connection B;
s15, the database connection B sends the commit/rollback command to the database B, and after the commit/rollback command is executed by the database B, the execution result is returned to the database connection agent; and repeating the steps until the execution commit/rollback command corresponding to the last sql command is finished.
The embodiment of the invention sends a request for acquiring database connection to a data transfer module through a transaction manager, the data transfer module establishes a plurality of database connection agents according to the request for database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to a database management module; and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager. The method can realize that a plurality of applications in the distributed system simultaneously access a plurality of databases, also can realize that one application in the distributed system simultaneously accesses a plurality of data sources, solves the problem of connectivity between one application and a plurality of databases in the distributed system, can ensure that the write operation of the plurality of databases is supported in one transaction and the consistency of the transaction is ensured, and simultaneously can flexibly configure a plurality of data source routing rules without intruding codes.
Example two
Fig. 6 is a processing system for distributed data routing according to an embodiment of the present invention, and as shown in fig. 6, the processing system includes:
the transaction manager 210 is configured to issue a request for obtaining a database connection to the data forwarding module.
Specifically, when a business operation needs to access the database for a read-write operation, the transaction manager 210 needs to access the data source first, operate the database through the data source, create a database connection, and return the database connection.
A data source is a source of data, either a device or raw media that provides some desired data. All information for establishing a database connection is stored in the data source. Just as files can be found in a file system by specifying the file name, the corresponding database connection can be found by providing the correct data source name, as an example, if the data is water, the database is a reservoir, the data source is a conduit connecting the reservoir, and the end user sees the data set as water flowing from the conduit. The transaction refers to a database transaction (transaction), and when multiple database operations are performed on the database (for example, multiple database connections are sequentially established to complete an sql command operation), the database transaction is an inseparable whole, and command operations in the transaction are either all executed or not executed, so that the consistency of the transaction is ensured. A transaction consists of all database operations performed between the beginning of the transaction and the end of the transaction. The start of the transaction and the end of the transaction are controlled by the transaction manager.
The data forwarding module 220 is configured to establish a plurality of database connection agents according to the database connection request, respectively create a database connection task through each database connection agent, and send the database connection task to the database management module.
The data transfer module 220 may create multiple database connection agents through which multiple different databases may be accessed since the data transfer module 220 may connect multiple actual databases. Specifically, the data forwarding module 220 may pre-configure a plurality of routing rules, and the obtained data in the database connection request may have an identifier, and the name of the database that the request wants to access may be obtained through the identifier, so that the database connection agent may obtain the name of the database connection request by comparing the name of the data source with the routing rule, and the database connection agent may create a database connection task for the database of the name and send the database connection task to the database management module 230. The data forwarding module 220 may be understood as a data source agent, and the data source agent may create a plurality of database connection agents, and access a plurality of actual data sources through the plurality of database connection agents.
The database management module 230 is configured to select a corresponding database according to the database connection task to execute the database connection task, obtain an execution result of the database connection task, and return the execution result to the transaction manager.
After receiving the database connection task created by the database connection agent, the database management module 230 creates a target database connection to the target database to be accessed, and issues a command for executing the task, and the target database executes the task according to the content of the command to obtain an execution result, and returns the execution result to the transaction manager. Here, the database management module 230 may be understood as a data source through which a database connection is established and through which a database is connected.
In the embodiment of the invention, through the data transfer module 220, a plurality of applications in the distributed system can simultaneously access a plurality of databases, and one application in the distributed system can simultaneously access a plurality of data sources, so that the problem of connectivity between one application and a plurality of databases in the distributed system is solved, the write operation of the plurality of databases can be supported in one transaction, the consistency of the transaction is ensured, meanwhile, a plurality of data source routing rules can be flexibly configured, and the code is not invaded.
In some embodiments, the transaction manager 210 issues a plurality of sql commands to the data forwarding module 220 via the data source interface to obtain a connection request for the database corresponding to each sql command.
In this embodiment, the data source interface is a javax.sql.datasource interface, which is a specification in the JDBC2.0 standard, and is a database link acquired in the 1.0 standard in a manner of drivermanager.getconnection (). The data source interface method also comprises two methods, namely a getConnection () method with and without parameters, and the data sources can provide database connection in a reusable mode, most of the data sources are realized by adopting a connection pool, and resources can be reused.
In some embodiments, as shown in fig. 3, fig. 3 is a schematic structural diagram of an interceptor intercepting sql command according to an embodiment of the present invention, where before the data forwarding module establishes a plurality of database connection proxies according to a request of database connection, the method further includes: intercepting each sql command by an interceptor; and the interceptor analyzes each intercepted sql command to acquire the command ID and the command content of the sql command. In addition, after the interceptor intercepts and analyzes each sql command, the name of the data source of each command can be set for subsequent personalized extension.
Specifically, the data of the database connection request is acquired through yusdatasource (data source agent) through javax.sql.datasource interface, intercepting the message being sent by a DataRouteNameInterreceptor (interceptor), intercepting the message in a DataRouteHandler (a data routing processing program), analyzing the intercepted sql command in the data routing processing program, analyzing each intercepted sql command by the interceptor to obtain a command ID and command content of the sql command, the name of each data source to be connected can be acquired through the command ID, YuspConnection (database connection agent) compares the acquired name of the data source with a routing rule acquired from a java.sql.Connection interface and configured in advance to acquire a target data source corresponding to each sql command, and YuspConnection (database connection agent) creates a database connection task for each command.
In addition, the interceptor in java is the object for dynamically intercepting the action calls, and provides a mechanism which enables a developer to define the code to be executed before and after the execution of an action, and also prevents the execution of the action before the execution of the action, and also provides a way to extract the reusable part in the action. In AOP (Aspect-Oriented Programming) an interceptor is used to intercept and then add certain operations before or after a certain method or field is accessed.
In some embodiments, before creating and sending a database connection task to the corresponding database management module by each database connection agent, the method further includes: the database connection agent connection compares a routing rule pre-configured by the data transfer module with the command ID to obtain the name of the data source to be accessed by each sql command after analysis; and the database connection agent establishes a database connection task corresponding to the name of the data source according to the name of the data source.
Specifically, as shown in fig. 3 and fig. 4, fig. 3 is a block diagram of a data routing method according to an embodiment of the present invention, fig. 4 is a schematic diagram of a database routing configuration rule according to an embodiment of the present invention, where an sql command of an sql command executed by each database includes: command ID, a string of characters, shaped as: mod ulea; command content, a standard sql statement, shaped as: select from user 1. For example, the data routing configuration rule cn. module a → a, cn. module a → B … …, where A, B and the like are names of databases, the database connection agent compares the command ID in the sql command with the data routing configuration rule, and obtains the name of the data source to be accessed, and then the database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source. In some embodiments, the creating, by the database connection broker, a corresponding database connection task according to the name of the data source specifically includes: selecting a corresponding target data source with the same name as the name of the data source obtained by comparison from a plurality of actual data sources according to the name of the data source obtained by comparison by the data proxy connection; because the name of the data source obtained after comparison is the name of the target data source to be accessed, the data proxy connection creates a corresponding database connection task for the selected target data source. The database connection broker is connected to a plurality of actual databases, so that the database connection broker can access any one of the databases according to the data routing configuration rule.
In some embodiments, the database management module 230 selects a corresponding database according to the database connection task to perform the database connection task, which specifically includes: the database management module 230 determines the name of the target database according to the target data source and obtains the actual address of the target database according to the name of the target database, for example, the database management module determines the name a of the target database according to the target data source, and in the # a data source configuration, the actual address of the target database may be obtained, for example, "jdbc-ur 1: jdbc: oracle: thin @127.0.0.1:1521: orc1 ", the database management module 230 creates a target database connection through the target data source, the target database connection sends an execution plan of the sql command to the target database according to the actual address of the target database, the target database performs data read-write operation according to the command content in the sql command, and returns the result of the read-write operation to the transaction management 210. The execution plan of the sql command means that before the sql command is executed, the database needs to be notified to execute check of sql content in advance, whether a low-level syntax error exists is checked, the sql command is executed only after the check is passed, and the check operation before the execution is called as the execution plan.
A database is a software deployed on a server, and a program accessing the software needs a real server address deployed for the software, namely, the above-mentioned real address of the database.
In some embodiments, after the target database performs a read/write operation on data according to the command content in the sql command, and returns the result of the read/write operation to the transaction manager 210, the method further includes: the transaction manager 210 determines whether the execution result of the corresponding target database is correct, if so, the transaction manager 210 sequentially initiates a commit operation for storing the executed transaction to the target database corresponding to each sql command, and if not, the transaction manager 210 sequentially initiates a rollback operation for executing the transaction to the target database corresponding to each sql command. Specifically, when a program executes business operation, a transaction manager is automatically opened, an sql command is executed through the created database connection, and after the execution of the sql command is completed, if no error report occurs, the transaction manager considers that the operation of the sql command is correct and submits the operation; if an error occurs, the transaction manager considers the operation of the sql command to be incorrect and performs a rollback.
The flow of operating the database is as follows: the method comprises the steps of obtaining a database connection from a data source, creating an execution plan through the database connection, and executing an sql command through the plan, wherein the process is generally called a transaction. If no error report occurs in the execution process, which indicates that the data processing is correct, the transaction manager sequentially initiates a commit operation for storing the executed transaction to the target database corresponding to each sql command, so that the operation data falls into the database, and if an error report occurs in one place in the execution process, the database cannot write the data into the database, and at this time, rollback operation, reconnection and other read-write operations are required.
In the embodiment of the present invention, a request for acquiring database connection is sent to the data transfer module 220 through the transaction manager 210, the data transfer module 220 establishes a plurality of database connection agents according to the request for acquiring database connection, and each database connection agent respectively creates a database connection task and sends the database connection task to the database management module 230;
the database management module 230 selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager. The embodiment of the invention solves the problem of the requirement of a distributed system for accessing multiple databases, supports the write operation of the multiple databases in one transaction, ensures the consistency of the transaction, and can flexibly configure the routing of the multiple databases without code intrusion.
The invention has the following beneficial effects:
1. the method can realize that a plurality of applications in the distributed system simultaneously access a plurality of databases;
2. one application of the distributed system can access a plurality of data sources at the same time, and the problem of connectivity between the application and a plurality of databases in the distributed system is solved;
3. the method can ensure that the write operation of a plurality of databases is supported in one transaction, the transaction consistency is ensured, meanwhile, a plurality of data source routing rules can be flexibly configured, and the method is non-intrusive to codes.
It will be apparent to those skilled in the art that, for convenience and brevity of description, only the above-mentioned division of the functional units and modules is illustrated, and in practical applications, the above-mentioned function distribution may be performed by different functional units and modules according to needs, that is, the internal structure of the apparatus is divided into different functional units or modules, so as to perform all or part of the functions described above. Each functional unit and module in the embodiments may be integrated in one processing unit, or each unit may exist alone physically, or two or more units are integrated in one unit, and the integrated unit may be implemented in a form of hardware, or in a form of software functional unit. In addition, specific names of the functional units and modules are only for convenience of distinguishing from each other, and are not used for limiting the protection scope of the present invention. The specific working processes of the units and modules in the system may refer to the corresponding processes in the foregoing method embodiments, and are not described herein again.
EXAMPLE III
As shown in fig. 7, an embodiment of the present invention further provides a computer-readable storage medium 300, a computer program 310 is stored in the computer-readable storage medium 300, and when executed by a processor, the computer program 310 implements:
the transaction manager sends a request for acquiring database connection to the data transfer module;
the data switching module establishes a plurality of database connection agents according to the request for acquiring the database connection, and each database connection agent respectively establishes a database connection task and sends the database connection task to the database management module;
and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager.
The integrated modules/units described in fig. 1 and 5, if implemented as software functional units and sold or used as stand-alone products, may be stored in a computer readable storage medium. Based on such understanding, all or part of the flow of the method according to the embodiments of the present invention may also be implemented by a computer program, which may be stored in a computer-readable storage medium, and when the computer program is executed by a processor, the steps of the method embodiments may be implemented. Wherein the computer program comprises computer program code, which may be in the form of source code, object code, an executable file or some intermediate form, etc. The computer-readable medium may include: any entity or device capable of carrying the computer program code, recording medium, usb disk, removable hard disk, magnetic disk, optical disk, computer Memory, Read-Only Memory (ROM), Random Access Memory (RAM), electrical carrier wave signals, telecommunications signals, software distribution medium, and the like. Of course, there are other ways of storing media that can be read, such as quantum memory, graphene memory, and so forth. It should be noted that the computer readable medium may contain content that is subject to appropriate increase or decrease as required by legislation and patent practice in jurisdictions, for example, in some jurisdictions, computer readable media does not include electrical carrier signals and telecommunications signals as is required by legislation and patent practice.
Example four
Referring to fig. 8, an embodiment of the invention further provides an electronic device. Fig. 8 is a schematic structural diagram of an electronic device according to an embodiment of the present invention. Referring to fig. 8, at a hardware level, the electronic device includes a processor, and optionally further includes an internal bus, a network interface, and a memory. The Memory may include a Memory, such as a Random-Access Memory (RAM), and may further include a non-volatile Memory, such as at least 1 disk Memory. Of course, the electronic device may also include hardware required for other services.
The processor, network interface and memory may be interconnected by an internal bus, which may be an Industry Standard Architecture (ISA) bus, a Peripheral Component Interconnect (PCI) bus, an extended EISA bus, or the like. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, only one double-headed arrow is shown in FIG. 7, but this does not indicate only one bus or one type of bus.
And the memory is used for storing programs. In particular, the program may include program code comprising computer operating instructions. The memory may include both memory and non-volatile storage and provides instructions and data to the processor. The processor reads a corresponding computer program from the nonvolatile memory to the memory and then runs the computer program to form the automatic disaster recovery system based on centralized configuration on a logic level. The processor executes the program stored in the memory, and is specifically configured to execute any one of the processing methods for distributed asynchronous data communication shown in fig. 1 and 3.
The processing method of the distributed data routing disclosed in the embodiments shown in fig. 1 and fig. 5 can be applied to a processor or implemented by a processor. The processor may be an integrated circuit chip having signal processing capabilities. In implementation, the steps of the above method may be performed by integrated logic circuits of hardware in a processor or instructions in the form of software. The Processor may be a general-purpose Processor, including a Central Processing Unit (CPU), a Network Processor (NP), and the like; but also Digital Signal Processors (DSPs), Application Specific Integrated Circuits (ASICs), Field Programmable Gate Arrays (FPGAs) or other Programmable logic devices, discrete Gate or transistor logic devices, discrete hardware components. The various methods, steps and logic blocks disclosed in the embodiments of the present invention may be implemented or performed. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like. The steps of the method disclosed in connection with the embodiments of the present invention may be directly implemented by a hardware decoding processor, or implemented by a combination of hardware and software modules in the decoding processor. The software modules may be located in ram, flash, rom, prom, or eprom, registers, etc. as is well known in the art. The storage medium is located in a memory, and a processor reads information in the memory and completes the steps of the method in combination with hardware of the processor.
Of course, besides the software implementation, the electronic device of the present invention does not exclude other implementations, such as a logic device or a combination of software and hardware, and the like, that is, the execution main body of the following processing flow is not limited to each logic unit, and may also be hardware or a logic device. The systems, devices, modules or units illustrated in the above embodiments may be implemented by a computer chip or an entity, or by a product with certain functions. One typical implementation device is a computer. In particular, the computer may be, for example, a personal computer, a laptop computer, a vehicle-mounted human-computer interaction device, a cellular telephone, a camera phone, a smart phone, a personal digital assistant, a media player, a navigation device, an email device, a game console, a tablet computer, a wearable device, or a combination of any of these devices.
Although the present invention provides method steps as described in the examples or flowcharts, more or fewer steps may be included based on conventional or non-inventive means. The order of steps recited in the embodiments is merely one manner of performing the steps in a multitude of sequences, and does not represent a unique order of performance. When an actual apparatus or end product executes, it may execute sequentially or in parallel (e.g., parallel processors or multi-threaded environments, or even distributed data processing environments) according to the method shown in the embodiment or the figures.
The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus, and computer program products according to embodiments of the invention. It will be understood that each flow and/or block of the flow diagrams and/or block diagrams, and combinations of flows and/or blocks in the flow diagrams and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
It should be noted that, in this document, relational terms such as first and second, and the like are used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
All the embodiments in the present specification are described in a related manner, and the same and similar parts among the embodiments may be referred to each other, and each embodiment focuses on the differences from the other embodiments. In particular, as for the device, the electronic device and the readable storage medium embodiments, since they are substantially similar to the method embodiments, the description is simple, and the relevant points can be referred to the partial description of the method embodiments.
The above description is only for the preferred embodiment of the present invention, and is not intended to limit the scope of the present invention. Any modification, equivalent replacement, or improvement made within the spirit and principle of the present invention shall fall within the protection scope of the present invention.
Claims (10)
1. A method for processing distributed data routing, the method comprising:
the transaction manager sends a request for acquiring database connection to the data transfer module, and the request specifically includes: the transaction manager sends a plurality of sql commands to the data transfer module through a data source interface so as to obtain a database connection request corresponding to each sql command;
intercepting each sql command by an interceptor;
analyzing each intercepted sql command through the interceptor to obtain a command ID and command content of the sql command;
the data transfer module establishes a plurality of database connection agents according to the request for acquiring database connection, and each database connection agent compares a routing rule pre-configured by the data transfer module with the command ID to obtain the name of a data source to be accessed by each parsed sql command; each database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source and sends the database connection task to a database management module;
and the database management module selects a corresponding database according to the database connection task to execute the database connection task to obtain an execution result of the database connection task, and returns the execution result to the transaction manager.
2. The method according to claim 1, wherein the database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source, and specifically includes:
the database connection agent selects a corresponding target data source from a plurality of actual data sources according to the name of the data source; the name of the target data source is the same as that of the data source to be accessed;
and the database connection agent establishes a corresponding database connection task aiming at the selected target data source.
3. The method according to claim 2, wherein the database management module selects a corresponding database according to the database connection task to execute the database connection task, specifically comprising:
the database management module determines the name of a target database according to the target data source and acquires the actual address of the target database according to the name of the target database;
the database management module triggers the target data source to create a target database connection according to the name of the target database;
the target database is connected with an execution plan for sending the sql command to the target database through the actual address of the target database;
and the target database performs data read-write operation according to the command content in the sql command and returns the result of the read-write operation to the transaction manager.
4. The method of claim 3, wherein after the target database performs a read/write operation on data according to the command content in the sql command and returns the result of the read/write operation to the transaction manager, the method further comprises:
the transaction manager judges whether the execution result of the corresponding target database is correct or not;
if the result is correct, the transaction manager initiates a commit operation for storing and executing the transaction to a target database corresponding to each sql command in sequence;
and if the target database is wrong, the transaction manager initiates a rollback operation for executing the transaction to the target database corresponding to each sql command in sequence.
5. A system for processing distributed data routing, comprising:
the transaction manager is used for sending a request for acquiring database connection to the data transfer module; the method specifically comprises the following steps: the transaction manager sends a plurality of sql commands to the data transfer module through a data source interface so as to obtain a database connection request corresponding to each sql command;
the data transfer module is used for intercepting each sql command through the interceptor; analyzing each intercepted sql command through the interceptor to obtain a command ID and command content of the sql command; establishing a plurality of database connection agents according to the request for acquiring database connection, and comparing a routing rule pre-configured by the data transfer module with the command ID through each database connection agent to obtain the name of a data source to be accessed by each parsed sql command; each database connection agent creates a database connection task corresponding to the name of the data source according to the name of the data source and sends the database connection task to a database management module;
and the database management module is used for selecting a corresponding database according to the database connection task to execute the database connection task, obtaining an execution result of the database connection task, and returning the execution result to the transaction manager.
6. The system of claim 5, wherein the database connection broker is configured to:
selecting a corresponding target data source from a plurality of actual data sources according to the name of the data source; the name of the target data source is the same as that of the data source to be accessed;
and creating a corresponding database connection task aiming at the selected target data source.
7. The system of claim 6,
the database management module is used for determining the name of a target database according to the target data source, acquiring the actual address of the target database according to the name of the target database, and triggering the target data source to establish a target database connection according to the name of the target database;
the target database connection is used for sending an execution plan of the sql command to the target database through the actual address of the target database;
and the target database is used for performing data read-write operation according to the command content in the sql command and returning the result of the read-write operation to the transaction manager.
8. The system of claim 7, wherein the transaction manager is further configured to:
judging whether the execution result of the corresponding target database is correct or not;
if the result is correct, a commit operation for storing and executing the transaction is initiated to the target database corresponding to each sql command in sequence;
and if the result is wrong, initiating a rollback operation for executing the transaction to the target database corresponding to each sql command in sequence.
9. A computer-readable storage medium, on which a computer program is stored which, when being executed by a processor, carries out a method of processing a distributed data route according to any one of claims 1 to 4.
10. An electronic device, comprising:
a processor;
a memory for storing the processor-executable instructions;
wherein the processor is configured to execute the instructions to implement a method of processing distributed data routing according to any one of claims 1-4.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111466536.9A CN114138888B (en) | 2021-12-03 | 2021-12-03 | Processing method, system, medium and equipment for distributed data routing |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111466536.9A CN114138888B (en) | 2021-12-03 | 2021-12-03 | Processing method, system, medium and equipment for distributed data routing |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114138888A CN114138888A (en) | 2022-03-04 |
| CN114138888B true CN114138888B (en) | 2022-07-05 |
Family
ID=80387651
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111466536.9A Active CN114138888B (en) | 2021-12-03 | 2021-12-03 | Processing method, system, medium and equipment for distributed data routing |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114138888B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113127102B (en) * | 2021-05-18 | 2024-10-01 | 中国农业银行股份有限公司 | Service data processing method, device, equipment, storage medium and program |
| CN117407453B (en) * | 2023-10-24 | 2024-06-14 | 武汉大学人民医院（湖北省人民医院） | Parallel use method and device of relational database and big database |
Family Cites Families (11)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US6816873B2 (en) * | 2001-05-15 | 2004-11-09 | International Business Machines Corporation | Method for managing distributed savepoints across multiple DBMS's within a distributed transaction |
| CN105608086B (en) * | 2014-11-17 | 2021-07-27 | 中兴通讯股份有限公司 | Transaction processing method and device for distributed database system |
| CN104572077B (en) * | 2014-12-12 | 2018-03-06 | 百度在线网络技术（北京）有限公司 | The processing method and operation system of db transaction |
| CN106909563B (en) * | 2015-12-23 | 2021-01-08 | 上海热璞网络科技有限公司 | Distributed system |
| CN109408201B (en) * | 2017-08-18 | 2022-07-12 | 中国银联股份有限公司 | Transaction management method based on distributed database |
| CN111045794B (en) * | 2019-12-17 | 2023-04-25 | 深圳前海环融联易信息科技服务有限公司 | Distributed transaction processing method, device, system, computer equipment and storage medium |
| CN111259083A (en) * | 2020-02-13 | 2020-06-09 | 神州数码融信软件有限公司 | Distributed transaction processing method and device |
| CN111367983B (en) * | 2020-03-10 | 2023-08-15 | 中国联合网络通信集团有限公司 | Database access method, system, device and storage medium |
| CN113296897B (en) * | 2020-07-21 | 2023-12-26 | 阿里巴巴集团控股有限公司 | Distributed transaction processing method, device, equipment and machine-readable medium |
| CN111858641A (en) * | 2020-07-30 | 2020-10-30 | 中国工商银行股份有限公司 | Transaction processing method and device, electronic equipment and readable storage medium |
| CN111984665B (en) * | 2020-09-10 | 2023-07-25 | 度小满科技(北京)有限公司 | Distributed transaction processing method, device and system |
-
2021
- 2021-12-03 CN CN202111466536.9A patent/CN114138888B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN114138888A (en) | 2022-03-04 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US12068912B2 (en) | Implementation of compliance settings by a mobile device for compliance with a configuration scenario | |
| CN114138888B (en) | Processing method, system, medium and equipment for distributed data routing | |
| US9020949B2 (en) | Method and system for centralized issue tracking | |
| CN111461887B (en) | Block chain consensus processing method and device and electronic equipment | |
| CN112818014B (en) | Block chain data analysis method and device and electronic equipment | |
| CN111447069B (en) | Low-frequency access data processing method based on block chain | |
| CN110851207A (en) | State transition management method and device, electronic equipment and computer readable storage medium | |
| CN111598575A (en) | Business process control method and device, electronic equipment and readable storage medium | |
| CN111831365A (en) | Interface route forwarding method, system, computer equipment and readable storage medium | |
| CN110580305A (en) | Method, apparatus, system, and medium for generating identifier | |
| CN111767144A (en) | Transaction routing determination method, device, equipment and system for transaction data | |
| CN113778725A (en) | Data verification method and device | |
| CN111225018A (en) | Request message processing method and device and electronic equipment | |
| CN112925589A (en) | Calling method and device of expansion interface | |
| CN110262854A (en) | Multi-source data processing method and terminal device | |
| CN113282347A (en) | Plug-in operation method, device, equipment and storage medium | |
| CN110532810B (en) | Information processing method and device, electronic equipment and readable storage medium | |
| CN109345063B (en) | Data processing method and device for wind control system and storage medium | |
| CN111652580B (en) | Method and device for processing data of nodes | |
| CN115023931B (en) | Method and network entity for service API release | |
| CN115328734A (en) | Cross-service log processing method and device and server | |
| CN114201241A (en) | Business processing method, device, equipment, storage medium and program | |
| CN113077241A (en) | Approval processing method, device, equipment and storage medium | |
| CN110990170A (en) | Data structure, communication method, device, storage medium and equipment | |
| CN113989011B (en) | Market data processing method and device, computer equipment and readable storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |