CN110046166A - Block chain-based timing task scheduling method and device - Google Patents

Abstract

The embodiment of the invention relates to the technical field of computers, in particular to a block chain-based timing task scheduling method and device, a storage medium and an electronic device. The method comprises the following steps: responding to a task scheduling instruction of a main chain to start service monitoring of the main chain; after monitoring that a timing task is linked on the main chain, carrying out original user state synchronization with the main chain, and executing the timing task after the timing task is synchronously finished with the main chain; synchronizing the user state after the timed task is executed to the main chain in response to a task stop instruction; and after the user state after the timing task is monitored to be synchronized to the main chain, ending the timing task. The method and the device can automatically transfer the timing task of the main chain to the designated side chain for execution, and effectively solve the problem of low execution efficiency of the timing task of the main chain.

Description

Block chain-based timing task scheduling method and device

technical field

The embodiments of the present invention relate to the field of computer technology, and more particularly, the embodiments of the present invention relate to a method and apparatus for scheduling scheduled tasks based on blockchain, a storage medium and an electronic device.

Background technique

This section is intended to provide a background or context for the embodiments of the invention recited in the claims, and the description herein is not admitted to be prior art by inclusion in this section.

As an emerging distributed infrastructure, the essence of blockchain should be a decentralized database, and it has been widely used in many fields such as securities trading, e-commerce, social communication and file storage.

SUMMARY OF THE INVENTION

However, in some technologies, on the one hand, due to the relatively low transaction performance of the existing blockchain platform, the transaction processing speed is slow, which cannot meet the needs of users for frequent transactions and transaction timeliness; Using different business contracts, it is impossible to execute a large number of high-frequency transactions on one blockchain platform.

Therefore, in the prior art, how to transfer the timing task of the main chain to the side chain for execution still lacks a corresponding systematic and standard data processing method.

Therefore, there is a great need for an improved method and device for scheduling scheduled tasks based on blockchain, storage media and electronic equipment, so as to achieve efficient scheduling of scheduled tasks between the main chain and the side chain.

In this context, the embodiments of the present invention are expected to provide a blockchain-based timing task scheduling method and apparatus, storage medium and electronic device.

According to one aspect of the present disclosure, a method for scheduling scheduled tasks based on blockchain is provided, including:

In response to a task scheduling instruction to the main chain, to start business monitoring on the main chain;

After monitoring that the timing task is on the main chain, synchronize the original user state with the main chain, and execute the timing task after the synchronization with the main chain is completed;

In response to a task stop instruction, the user state after executing the scheduled task is synchronized to the main chain;

After monitoring the synchronization of the user state after the execution of the timing task to the main chain, the timing task is ended.

In an exemplary embodiment of the present disclosure, the performing service monitoring on the main chain includes:

Monitor the transaction that submits the scheduled task at the specified address of the main chain through the transfer bridge to obtain its transaction hash;

Obtain the block in the main chain where the transaction submitting the timing task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block;

Calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain to determine Whether the transaction submitting the scheduled task is uploaded in the main chain.

In an exemplary embodiment of the present disclosure, after monitoring that the timing task is on the main chain, the synchronization of the original user state with the main chain includes:

After monitoring that the timed task is on the main chain, initiate a transaction to determine the state of the timed task on the main chain and put it on the chain;

After determining the state of the timing task in the main chain, perform original user state synchronization with the main chain;

After the synchronization operation is completed, the transaction that has completed the synchronization is initiated and uploaded to the chain.

In an exemplary embodiment of the present disclosure, after determining the state of the timing task on the main chain, synchronizing the original user state with the main chain includes:

The main chain synchronization state interface is called through the transfer bridge to initiate a transaction that synchronizes the original user state with the main chain, and the synchronization result is returned to the main chain.

In an exemplary embodiment of the present disclosure, the method further includes:

The transaction of synchronizing the original user state with the main chain is monitored through the transfer bridge to determine whether the operation of synchronizing the original user state is completed.

In an exemplary embodiment of the present disclosure, the performing the timing task includes:

The contract is invoked to execute the scheduled task according to the timing rules in the scheduled task, and the task result is consensus on the chain.

In an exemplary embodiment of the present disclosure, the invoking a contract to execute the timing task according to the timing rules in the timing task, and uploading the task result to the chain by consensus includes:

The timing contract executor of the block-producing node initiates a timing transaction according to the timing contract, and sends the block to be confirmed including the timing transaction to each voting node;

The timing contract executor of the voting node executes the timing transaction, generates a block-producing voting result according to the execution result of the timing transaction, and returns it to the block-producing node;

The block producing node judges whether to produce a block on the chain based on the block producing voting result returned by each of the voting nodes.

In an exemplary embodiment of the present disclosure, the generating of the task stop instruction includes:

Generate a task stop instruction according to the timing rule in the timing task; or

When it is detected that the transaction for stopping the timing task is on the main chain, the transaction for stopping the timing task is initiated to generate a task stop instruction.

In an exemplary embodiment of the present disclosure, the synchronizing the user state after executing the scheduled task to the main chain includes:

The synchronization status interface of the main chain is invoked through the switching bridge to initiate a synchronization transaction that returns the execution result of the timing task to the main chain, so as to synchronize the user status after executing the timing task to the main chain.

In an exemplary embodiment of the present disclosure, after monitoring the synchronization of the user state after the execution of the timed task to the main chain, ending the timed task includes:

After monitoring the synchronization of the user state after the main chain completes the execution of the scheduled task, initiate a transaction completed by the synchronization of the main chain state and upload it to the chain;

Initiating a transaction for the end timing task of the main chain, so that the main chain executes the transaction for ending the timing task.

In an exemplary embodiment of the present disclosure, after listening to the main chain executing the transaction of ending the timing task, the method further includes:

A transaction confirming the end of the timing task is initiated to end the timing task.

According to one aspect of the present disclosure, a method for scheduling scheduled tasks based on blockchain is provided, including:

Based on a task scheduling instruction for the main chain, configure a side chain for the main chain to enable the side chain to enable service monitoring on the main chain;

After monitoring the timing task on the main chain, the side chain performs the original user state synchronization with the main chain, and executes the timing task on the side chain;

In response to a task stop instruction, the side chain synchronizes the user state after executing the scheduled task to the main chain to update the main chain;

After the side chain monitors the synchronization of the user state after the main chain will perform the timing task, the timing task ends on the main chain and the side chain.

In an exemplary embodiment of the present disclosure, enabling the side chain to monitor services on the main chain includes:

The side chain monitors the transactions of the specified address of the main chain for submitting timed tasks through the transfer bridge to obtain its transaction hash;

Obtain the block in the main chain where the transaction submitting the timing task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block;

Calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain to determine Whether the transaction submitting the scheduled task is uploaded in the main chain.

In an exemplary embodiment of the present disclosure, when the main chain submits the scheduled task, the method further includes:

Lock management users on the main chain.

In an exemplary embodiment of the present disclosure, after the side chain monitors the timed task submitted by the main chain, performing original user state synchronization with the main chain includes:

After monitoring that the timing task is on the main chain, the side chain initiates a transaction to determine the status of the timing task on the main chain on the side chain and uploads it to the chain;

After confirming the timing task of the main chain, the side chain initiates a transaction for synchronizing the original user state of the main chain, so as to synchronize the original user state with the main chain;

After the sidechain confirms that the synchronization of the original user state is completed, the sidechain initiates a transaction completed by the sidechain state synchronization and uploads it to the chain.

In an exemplary embodiment of the present disclosure, the side chain initiating a transaction for synchronizing the original user state of the main chain for synchronizing the original user state with the main chain includes:

The side chain invokes the main chain synchronization state interface through the transfer bridge to initiate a transaction for synchronizing the original user state of the main chain, and returns the synchronization result to the main chain.

In an exemplary embodiment of the present disclosure, the method for confirming completion of the original user state synchronization by the side chain includes:

The side chain monitors the transaction of synchronizing the original user state of the main chain through the transit bridge to determine whether the operation of synchronizing the original user state is completed.

In an exemplary embodiment of the present disclosure, the execution of the timing task by the side chain includes:

The side chain node invokes the contract to execute the scheduled task according to the timing rule in the scheduled task, and uploads the task result to the chain by consensus.

In an exemplary embodiment of the present disclosure, the side chain node invokes a contract to execute the timed task according to the timed rules in the timed task, and uploading the task result to the chain by consensus includes:

The timing contract executor of the block-producing node of the side chain invokes the timing contract to initiate a timing transaction, and sends the block to be confirmed including the timing transaction to each voting node;

The timing contract executor of the voting node invokes the timing contract to execute the timing transaction, generates a block-producing voting result according to the execution result of the timing transaction, and returns the block-producing voting result to the block-producing node;

The block producing node judges whether to produce a block on the chain according to the block producing voting result returned by the voting node.

In an exemplary embodiment of the present disclosure, the side chain in response to a task stop instruction includes:

The side chain generates a task stop instruction according to the timing rule in the timing task; or

When the side chain monitors the transaction that ends the timing task initiated by the main chain, the side chain initiates the transaction that ends the timing task and uploads it to the chain.

In an exemplary embodiment of the present disclosure, synchronizing the user state with the main chain to update the main chain includes:

The side chain invokes the main chain synchronization status interface through the transfer bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, so as to return the execution result of the timed task of the side chain to the main chain , so as to update the user status of the main chain.

In an exemplary embodiment of the present disclosure, after the side chain monitors that the main chain will perform the timing task after the user state synchronization is completed, the main chain and the side chain end the timing task include:

After monitoring the completion of the synchronization operation of the main chain, the side chain initiates a transaction to complete the synchronization of the state of the main chain and uploads it to the chain;

The side chain initiates a transaction for the end timing task of the main chain, so that the main chain executes the transaction for the end timing task, and after confirming that the synchronization operation is completed, the transaction for the end timing task is stored in the main chain. The main chain is on-chain to end the timing task.

In an exemplary embodiment of the present disclosure, after the side chain monitors that the transaction of the end timing task of the main chain is on the main chain, the method further includes:

The side chain initiates the transaction of the side chain to confirm the end of the timing task and uploads the transaction, so as to end the timing task on the side chain.

In an exemplary embodiment of the present disclosure, the method further includes:

The main chain unlocks management users.

According to an aspect of the present disclosure, a block chain-based timing task scheduling device is provided, including:

a service monitoring module, used for starting a service monitoring on the main chain in response to a task scheduling instruction on the main chain;

The first task execution module is configured to synchronize the original user state with the main chain after monitoring that the timing task is on the main chain, and execute the timing task after the synchronization with the main chain is completed;

a first task stop module, used for synchronizing the user state after executing the timed task to the main chain in response to a task stop instruction;

The task end module is configured to end the timed task after monitoring the synchronization of the user state and the main chain after the execution of the timed task is completed.

In an exemplary embodiment of the present disclosure, the service monitoring module includes:

The transaction hash acquisition module is used to monitor the transaction of the specified address of the main chain that submits the timed task through the transfer bridge to acquire its transaction hash;

a block header query module, configured to obtain the block in the main chain where the transaction submitting the timing task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block;

The hash value comparison module is used to calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain Compare the hash value of the Er tree to determine whether the transaction that submits the scheduled task is uploaded in the main chain.

In an exemplary embodiment of the present disclosure, the first task execution module includes:

A timing task confirmation module, configured to initiate a transaction to determine the status of the timing task on the main chain after monitoring that the timing task is on the main chain, and upload it to the chain;

a user state synchronization module, configured to synchronize the original user state with the main chain after determining the state of the timing task in the main chain;

The synchronization completion module is used to initiate the synchronization transaction and upload it to the chain after the synchronization operation is completed.

In an exemplary embodiment of the present disclosure, the user state synchronization module includes:

The main chain synchronization state interface calling module is used to call the main chain synchronization state interface through the transfer bridge to initiate a transaction that synchronizes the original user state with the main chain, and returns the synchronization result to the main chain.

In an exemplary embodiment of the present disclosure, the apparatus further includes:

The synchronization result confirmation module is used to monitor the transaction of synchronizing the original user state with the main chain through the transfer bridge, so as to determine whether the operation of synchronizing the original user state is completed.

In an exemplary embodiment of the present disclosure, the first task execution module includes:

The timed task execution module is used to call the contract to execute the timed task according to the timed rules in the timed task, and upload the task result to the chain by consensus.

In an exemplary embodiment of the present disclosure, the timing task execution module includes:

A transaction initiation module, used by the timing contract executor of the block-producing node to initiate timing transactions according to the timing contracts, and sending the blocks to be confirmed including the timing transactions to each voting node;

A block voting result generation module, used for the timing contract executor of the voting node to execute the timing transaction, generate a block voting result according to the execution result of the timing transaction, and return it to the block generation node;

The timing task block generation module is used for the block generation node to determine whether to generate a block for the timing task result and upload it to the chain according to the block generation voting results returned by each of the voting nodes.

In an exemplary embodiment of the present disclosure, the first task stopping module includes:

A stop instruction generation module, configured to generate a task stop instruction according to the timing rule in the timing task; and/or

The stop instruction monitoring module is configured to initiate the transaction to stop the timed task to generate a task stop instruction when the transaction for stopping the timed task is monitored on the main chain.

In an exemplary embodiment of the present disclosure, the first task stopping module further includes:

The task result return module is used to call the synchronization state interface of the main chain through the transfer bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, so as to synchronize the user state after executing the timed task to the main chain.

In an exemplary embodiment of the present disclosure, the task end module includes:

The user state monitoring module is used to initiate a transaction completed by the synchronization of the state of the main chain and upload it to the chain after monitoring the synchronization of the user state after the main chain completes the execution of the timed task;

The main chain timing task ending module is used for initiating a transaction for ending the timing task of the main chain, so that the main chain executes the transaction for ending the timing task.

In an exemplary embodiment of the present disclosure, the apparatus further includes:

The timing task ending module is used for initiating a transaction confirming the ending of the timing task to end the timing task.

According to an aspect of the present disclosure, a block chain-based timing task scheduling device is provided, including:

a side chain allocation module, configured to configure a side chain for the main chain based on a task scheduling instruction to the main chain, so that the side chain enables service monitoring on the main chain;

The second task execution module is used for the side chain to synchronize with the main chain execution user state after monitoring that the timing task is on the main chain, so as to execute the timing task on the side chain;

The second task stop module is used for the side chain to synchronize the user state after executing the scheduled task to the main chain in response to a task stop instruction to update the main chain;

The task completion module is configured to end the scheduled task on the main chain and the side chain after the side chain monitors the synchronization of the user state after the main chain will perform the scheduled task.

In an exemplary embodiment of the present disclosure, the apparatus further includes:

A transaction hash acquisition module, used for the side chain to monitor the transaction of the timed task submission of the specified address of the main chain through the transfer bridge to acquire its transaction hash;

a block header query module, configured to obtain the block in the main chain where the transaction that submits the timing task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block;

The hash value comparison module is used to calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain The hash value of the tree is compared to determine whether the transaction that submits the scheduled task is uploaded in the main chain.

In an exemplary embodiment of the present disclosure, the apparatus further includes:

The user state locking module is used to lock and manage users on the main chain when the main chain submits timed tasks.

In an exemplary embodiment of the present disclosure, the second task execution module includes:

The timing task side chain determination module is used for the side chain to initiate a transaction to determine the status of the timing task in the main chain after monitoring that the timing task is on the main chain, and to initiate a transaction on the side chain to determine the status of the timing task in the main chain. on the chain;

The original user state synchronization module is used for the side chain to initiate a transaction to synchronize the original user state of the main chain after confirming the timing task of the main chain, so as to synchronize the original user state with the main chain;

The original user state side chain confirmation module is used to initiate a transaction completed by the side chain state synchronization on the side chain after the side chain confirms that the synchronization of the original user state is completed and upload it to the chain.

In an exemplary embodiment of the present disclosure, the original user state synchronization module includes:

The main chain synchronization state interface calling module is used for the side chain to call the main chain synchronization state interface through the transfer bridge to initiate a transaction for synchronizing the original user state of the main chain, and return the synchronization result to the main chain.

In an exemplary embodiment of the present disclosure, the original user state side chain confirmation module includes:

The main chain synchronization transaction monitoring module is used for the side chain to monitor the transaction of synchronizing the original user state of the main chain through the transfer bridge to determine whether the operation of synchronizing the original user state is completed.

In an exemplary embodiment of the present disclosure, the second task execution module includes:

The timing task side chain execution module is used for the side chain node to invoke the contract to execute the timing task according to the timing rules in the timing task, and to upload the task result to the chain by consensus.

In an exemplary embodiment of the present disclosure, the timing task side chain execution module includes:

The block-producing node execution module is used for the timing contract executor of the block-producing node of the side chain to call the timing contract to initiate a timing transaction, and send the block to be confirmed containing the timing transaction to each voting node;

The voting node execution module is used for the timing contract executor of the voting node to call the timing contract to execute the timing transaction, generate a block voting result according to the execution result of the timing transaction, and return the block voting result to the Describe the block node;

The task result block generation module is used for the block generation node to determine whether to generate a block for the timed task result and upload it to the chain according to the block generation voting result returned by the voting node.

In an exemplary embodiment of the present disclosure, the second task stop module includes:

A stop instruction side chain generation module, for the side chain to generate a task stop instruction according to the timing rule in the timing task; and/or

A stop command side chain monitoring module is used for the side chain to initiate a transaction to end the timed task on the side chain and upload the transaction when the side chain monitors the transaction initiated on the main chain to end the timed task.

In an exemplary embodiment of the present disclosure, the second task stopping module further includes:

The task result return module is used for the side chain to call the main chain synchronization state interface through the transfer bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, so as to return the timed task of the side chain to the synchronization transaction. The execution result is returned to the main chain, so as to update the user status of the main chain.

In an exemplary embodiment of the present disclosure, the task completion module includes:

The main chain synchronization completion module is used for the side chain to initiate a transaction to complete the synchronization of the main chain state and upload it to the chain after monitoring the completion of the synchronization operation of the main chain;

The timing task main chain end module is used for the side chain to initiate a transaction for the end timing task of the main chain, so that the main chain executes the transaction of the end timing task, and after confirming that the synchronization operation is completed, the The transaction that ends the timing task is chained on the main chain to end the timing task.

In an exemplary embodiment of the present disclosure, the task completion module further includes:

The timing task side chain ending module is used for the side chain to initiate the side chain to confirm the transaction of ending the timing task and upload it to the chain, so as to end the timing task on the side chain.

In an exemplary embodiment of the present disclosure, the apparatus further includes:

The user unlocking module is used for the main chain to unlock the management user.

According to one aspect of the present disclosure, there is provided a storage medium on which a computer program is stored, and when the computer program is executed by a processor, implements the blockchain-based timing task scheduling method described in any of the foregoing embodiments.

According to one aspect of the present disclosure, there is provided an electronic device, comprising:

processor; and

a memory for storing executable instructions for the processor;

Wherein, the processor is configured to execute the block chain-based timing task scheduling method described in any one of the above by executing the executable instructions.

According to the timing task scheduling method of the embodiment of the present invention, by pre-assigning the corresponding side chain to the main chain, the side chain can monitor the transactions submitted on the main chain in real time; The original user state is synchronized to the side chain, so that the side chain can execute the corresponding scheduled tasks, so as to realize the automatic transfer of the scheduled tasks of the main chain to the designated side chain for execution, effectively solving the problem of low execution efficiency of the scheduled tasks of the main chain. And after the side chain finishes the timed task, the user status after executing the timed task is synchronized to the main chain, thereby reducing the total transaction volume of the main chain and the transaction overhead of the main chain.

Description of drawings

The above and other objects, features and advantages of exemplary embodiments of the present invention will become readily understood by reading the following detailed description with reference to the accompanying drawings. In the accompanying drawings, several embodiments of the present invention are shown by way of example and not limitation, wherein:

1 schematically shows a flowchart of a method for scheduling scheduled tasks based on blockchain according to an embodiment of the present invention;

FIG. 2 schematically shows a flow chart of a method for performing service monitoring on a main chain by a side chain according to an embodiment of the present invention;

3 schematically shows a flow chart of a method for synchronizing the original user state between the side chain and the main chain according to an embodiment of the present invention;

FIG. 4 schematically shows a flow chart of a method for a side chain to upload a timed task execution result consensus to the chain according to an embodiment of the present invention;

FIG. 5 schematically shows a flowchart of a method for ending a timing task according to an embodiment of the present invention;

FIG. 6 schematically shows a flowchart of another method for scheduling scheduled tasks based on blockchain according to an embodiment of the present invention;

7 schematically shows a block diagram of a block chain-based timing task scheduling apparatus according to an embodiment of the present invention;

FIG. 8 schematically shows a block diagram of another block chain-based timing task scheduling apparatus according to an embodiment of the present invention;

FIG. 9 shows a schematic diagram of a storage medium according to an embodiment of the present invention; and

Figure 10 schematically shows a block diagram of an electronic device according to an embodiment of the invention.

In the drawings, the same or corresponding reference numerals denote the same or corresponding parts.

Detailed ways

The principles and spirit of the present invention will now be described with reference to several exemplary embodiments. It should be understood that these embodiments are only given for those skilled in the art to better understand and implement the present invention, but not to limit the scope of the present invention 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.

As will be appreciated by those skilled in the art, embodiments of the present invention may be implemented as a system, apparatus, device, method or computer program product. Accordingly, the present disclosure may be embodied in entirely hardware, entirely software (including firmware, resident software, microcode, etc.), or a combination of hardware and software.

According to an embodiment of the present invention, a method for scheduling a scheduled task based on a blockchain, a device for scheduling a scheduled task based on a blockchain, a storage medium and an electronic device are provided.

Herein, any number of elements in the figures is for illustration and not limitation, and any designation is for distinction only and does not have any limiting meaning.

The principles and spirit of the present invention are described in detail below with reference to several representative embodiments of the present invention.

SUMMARY OF THE INVENTION

The inventors found that in the prior art, the existing blockchain platforms suffer from the single-machine execution of transactions, single-machine storage, and the consensus efficiency of a single blockchain, resulting in relatively low transaction performance of the blockchain platforms, which cannot satisfy users’ needs. The need for frequent transactions. In addition, in the existing technical solution, different business contracts are used between the blockchain platforms, so that the timed transaction tasks in each blockchain can only be executed in the blockchain platform where they are located, resulting in the inability to perform transactions in one blockchain. The chain platform frequently executes timed transaction tasks.

In view of the above, the basic idea of the present invention is: by pre-assigning the corresponding side chain to the main chain, on the one hand, the side chain can monitor the transactions submitted and uploaded on the main chain in real time; After that, the original user status of the main chain is synchronized to the side chain, so that the side chain can execute the corresponding scheduled tasks, so as to realize the automatic transfer of the scheduled tasks of the main chain to the designated side chain for execution, and effectively solve the main chain timed task execution efficiency. low problem. On the other hand, by synchronizing the user status after executing the timed task to the main chain after the sidechain finishes the timed task, the total transaction volume of the main chain is further reduced, the transaction overhead of the main chain is reduced, and the transaction speed is improved.

Having introduced the basic principles of the present invention, various non-limiting embodiments of the present invention are described in detail below.

Exemplary method

The block chain-based timing task scheduling method according to an exemplary embodiment of the present invention will be described below with reference to FIG. 1 .

Referring to Figure 1, the blockchain-based timing task scheduling method may include the following steps:

S11, in response to a task scheduling instruction to the main chain, to start monitoring the main chain for services;

S12. After monitoring that the timing task is on the main chain, perform original user state synchronization with the main chain, and execute the timing task after the synchronization with the main chain is completed;

S13, in response to a task stop instruction, synchronize the user state after executing the timed task to the main chain;

S14. After monitoring the synchronization of the user state after the execution of the timed task to the main chain, end the timed task.

In the method for scheduling scheduled tasks based on blockchain in the embodiment of the present invention, by pre-assigning the corresponding side chain to the main chain, the side chain can monitor the transactions submitted on the main chain in real time; After that, the original user status of the main chain is synchronized to the side chain, so that the side chain can execute the corresponding scheduled tasks, so as to realize the automatic transfer of the scheduled tasks of the main chain to the designated side chain for execution, and effectively solve the main chain timed task execution efficiency. low problem. And after the side chain finishes the timed task, the user status after executing the timed task is synchronized to the main chain, thereby reducing the total transaction volume of the main chain and the transaction overhead of the main chain. .

In step S11, in response to a task scheduling instruction to the main chain, the service monitoring of the main chain is started.

In the exemplary embodiment of the present disclosure, for a side chain, a user can assign a corresponding side chain to the main chain, so that the side chain can monitor the transactions submitted and uploaded on the main chain. Among them, the side chain can be a consensus-based blockchain such as POS (Proof of Stake), BFT (Byzantine Fault Tolerance, Byzantine Fault Tolerance). Specifically, the side chain can include a transfer bridge, a side chain contract, and a side chain timing contract executor. Among them, the transfer bridge is a part of the side chain, so that each node of the side chain can monitor the blocks and transactions of the main chain through the transfer bridge. The side chain contract is the contract corresponding to the main chain business contract. The sidechain timed contract executor can be used to rotate and execute timed transactions according to the timed contract.

The switching bridge may have a function of querying user status (quey status), a function of executing a synchronous transaction (execute status status), and a function of executing finish timing (execute finish timing). Specifically, the above function of querying user status is to call the export status method (export StatusResult) in the main chain contract. After the side chain calls the main chain export method, it can export the user state of all related user addresses (relate Address), and initialize the user state of the side chain contract. The above-mentioned synchronous transaction function is to call the main chain synchronization status (sync Status Status) method in the main chain contract to initiate a synchronous transaction, and return the execution result of the side chain timer, that is, the user status result after the side chain executes the timing task, to the main chain. the process of. At the same time, the transfer bridge can also continuously monitor the synchronization transactions of the main chain to determine whether the synchronization is successful. The above execution completion timer function can call the finish Timing method in the main chain contract. After the status of all users in the side chain is synchronized, the side chain initiates the completion timing task transaction on the main chain, thereby completely completing the main chain. The timing task of the chain.

The above-mentioned side chain contract is a contract corresponding to the main chain business contract, which may include sure Sumit Timing. After the transfer bridge monitors the main chain's submission timing task (sumit Timing) transaction and confirms that it is on the chain, the side chain is initiated by the block-producing node to execute the transaction that determines the submission timing task, and brings the main chain's timing task parameters (time Params). ), submitted to the sidechain.

After the blockchain members allocate the corresponding side chains to the main chain, they can also configure the main chain contract address to be monitored and the blockchain account to be used for the side chain. In addition, a main chain can correspond to one or more side chains, that is, the scheduled tasks of the main chain can be assigned to at least one side chain for execution. Since the main chain can contain multiple contracts, the main chain contract and the side chain can have a many-to-many relationship, in which a contract in the main chain can correspond to a side chain that performs its scheduled tasks. After that, the side chain can monitor the transactions (watch_eth) and blocks (watch_block) of the main chain in real time in a side chain/relay mode through the transfer bridge.

Specifically, referring to Figure 2, the side chain's service monitoring on the main chain may include the following steps:

Step S111, monitoring the transaction of submitting the timing task of the designated address of the main chain through the transfer bridge to obtain its transaction hash;

Step S112, obtaining the block in the main chain where the transaction submitting the timing task is located according to the transaction hash, and querying the corresponding hash value according to the block header of the block;

Step S113: Calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain. The comparison is made to determine whether the transaction submitting the timed task is uploaded in the main chain.

In an exemplary embodiment of the present disclosure, the side chain can determine the occurrence of the main chain timer transaction and whether to go on the chain by monitoring the main chain transaction (watch_eth) and block (watch_block). For example, the side chain can determine whether a scheduled task transaction occurs by monitoring all transactions under the business contract corresponding to the main chain. In addition, the side chain can also monitor all the block headers of the main chain that have been on the chain, and add these blocks to the side chain for SPV proof (Simplified Payment Verification). Specifically, after monitoring the transaction of the scheduled task initiated by the main chain at the specified address, the side chain obtains the transaction hash of the transaction; and queries the main chain through the transaction hash to obtain the block where the transaction is located. And, by monitoring the block header of the main chain, the side chain queries and obtains the hash value required to construct the Merkle tree (merkle tree) in the block of the main chain, and calculates the Merkle tree hash (merkle tree) according to the hash value. root hash); and compare the calculated Merkle tree hash with the original Merkle tree hash in the main chain block header to determine whether they are equal. When it is judged to be equal, it proves that the timed task transaction exists in the main chain and has been on the chain. If they are not equal, it proves that the transaction does not exist in the main chain, or there is an error in the data in the block header downloaded from the main chain by the side chain.

In step S12, after monitoring that the timing task is on the main chain, perform original user state synchronization with the main chain, and execute the timing task after the synchronization with the main chain is completed.

In the exemplary embodiment of the present disclosure, when the side chain monitors the timing task on the main chain, it can synchronize the original user state of the main chain to the side chain, and then execute the corresponding operation on the side chain after the synchronization is completed. Scheduled tasks.

Specifically, referring to FIG. 3 , after monitoring that the timing task is on the main chain, the synchronization of the original user state with the main chain may include:

Step S1201, after monitoring that the timed task is on the main chain, initiate a transaction to determine the state of the timed task in the main chain and put it on the chain;

Step S1202, after determining the state of the timing task in the main chain, perform original user state synchronization with the main chain;

In step S1203, after the synchronization operation is completed, a transaction that has completed the synchronization is initiated and uploaded to the chain.

In an exemplary embodiment of the present disclosure, after the side chain monitors the transaction of the submission timing task (sumit Timing) of the main chain through the transition bridge, and determines that the transaction is on the main chain, the side chain initiates the determination of the Transactions of timed tasks in the state of the main chain are uploaded to the chain. After the side chain determines the timing task of the main chain, it can execute the transaction of synchronizing the original user state of the main chain, and synchronize the state of all associated user addresses of the main chain to the side chain. Specifically, the side chain invokes the main chain's export status (export Status Status) method through the transition bridge to initiate the status synchronization of the management user address (relateAddress). The side chain nodes do a good job of uploading each state synchronization until all the original users' state changes are successfully uploaded to the chain.

After the side chain determines that all user status synchronization is completed, it can initiate a transaction to complete the side chain status synchronization (finish SyncUser Status) and upload it to the chain. The side chain can also monitor the transaction of synchronizing the original user state with the main chain through the transfer bridge, so as to determine whether the operation of synchronizing the original user state is completed.

In addition, the contract can also include a specified timed task execution method, and the timed task (executeTiming) is handed over to the timed contract executor of each node of the sidechain to manage the timed task. The timing contract executor is the native module of the side chain. Under the condition that the timing rules of the contract are met, it polls to initiate transactions that specify the timing task execution method for the contract. For example, the timed task execution method may include executing the timed task according to time, executing transactions according to the order of block production, and the number of times each time the transaction is executed.

After synchronizing the original user state of the main chain to the side chain, the timed contract executor of the side chain can continuously call the contract to execute the timed task according to the timed rules in the timed task in the main chain, and upload the task result to the chain by consensus. .

Specifically, referring to Figure 4, the following steps may be included:

Step S1211, the timing contract executor of the block-producing node initiates a timing transaction according to the timing contract, and sends the block to be confirmed including the timing transaction to each voting node;

Step S1212, the timing contract executor of the voting node executes the timing transaction, generates a block-producing voting result according to the execution result of the timing transaction, and returns it to the block-producing node;

Step S1213, the block producing node judges whether to produce a block on the chain based on the block producing voting result returned by each of the voting nodes.

In the exemplary embodiment of the present disclosure, when it is the turn of a node to generate a block on the side chain, the timing contract executor of the block-producing node invokes the corresponding timing task execution method on the contract according to the timing policy to execute the timing transaction. Block-producing nodes package timed transactions and send blocks to be confirmed to voting nodes. Voting nodes also execute timed transactions by their own timed contract executors. The timed contract executor can first judge whether the timed transaction satisfies the timed rules, and then execute the timed transaction according to the timed method in the contract when it is judged that the rules are satisfied. After the voting node timing contract executor finishes executing the timing task, it adds the hash value corresponding to the execution result to the signature verification parameter, and returns it to the block producing node as the block voting result. In order to make the block producing nodes collect the voting results of the voting nodes, when the voting nodes that perform the timed task are larger than a certain proportion, the timed task can be released from the block and uploaded to the chain, and then a round of timed tasks can be completed. In the next round of scheduled tasks, other block-producing nodes will also perform scheduled tasks in turn by polling in this way and upload them to the chain.

In step S13, in response to a task stop instruction, the user state after executing the scheduled task is synchronized to the main chain.

In an exemplary embodiment of the present disclosure, the above-mentioned task stop instruction may be a task stop instruction generated according to a timing rule in the timing task; The task stop instruction is generated at the preset time point; or, after the scheduled task is executed for a predetermined number of times, the scheduled task is ended and the task stop instruction is generated. For example, if the preset number of times to execute the timed task is 500 times, when the timed task execution reaches 500 times, a task stop instruction is generated. Alternatively, it is also possible to initiate a transaction to stop the scheduled task to generate a task stop instruction when the transaction for stopping the scheduled task is monitored on the main chain.

After obtaining the task stop instruction, you can call the synchronization status interface of the main chain through the transfer bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, thereby synchronizing the user status after executing the timed task to the main chain.

In step S14, after monitoring the synchronization of the user state after the execution of the timing task to the main chain, the timing task is ended.

In an exemplary embodiment of the present disclosure, referring to FIG. 5 , the above-mentioned step S14 may include:

Step S141, after monitoring the synchronization of the user state after the main chain completes the execution of the timing task, initiate a transaction completed by the synchronization of the main chain state and upload it to the chain;

Step S142, initiating a transaction for ending the timing task of the main chain, so that the main chain executes the transaction for ending the timing task.

Step S143, initiating a transaction confirming the termination of the timing task to end the timing task.

In some exemplary embodiments of the present disclosure, after the side chain timing task is stopped, the side chain initiates a user status synchronization transaction on the main chain after executing the timing task through the transfer bridge, and synchronizes the status of all management users, thereby changing the main chain. The status of all users in , is set to the same number of tokens as the side chain, and each user who has completed synchronization is marked. The side chain monitors the main chain transactions and blocks, and after confirming that all user status changes on the main chain are completed, the side chain initiates a transaction of finishing Sync Status of the main chain, so that the main chain ends the scheduled task.

Further, after the side chain completes the transaction completed by the synchronization of the state of the main chain, the side chain again initiates a transaction for the end timing task of the main chain through the transfer bridge, so that the main chain executes and completely ends the timing task. After the side chain monitors that the main chain finishes the timing task, the side chain initiates a transaction to confirm the completion of the timing task (sure Finish Timing). After the success of the chain, end the scheduled task on the side chain, so that the scheduled task is completely ended. Among them, the above-mentioned transactions are uploaded in the main chain or side chain, which means that the transaction data is saved in the corresponding blockchain, and a new block is formed.

In other exemplary embodiments of the present disclosure, for the main chain and the side chain, as shown in FIG. 6 , the above-mentioned blockchain-based timing task scheduling method may include the following steps:

Step S21, based on a task scheduling instruction for the main chain, configure a side chain for the main chain to enable the side chain to enable service monitoring on the main chain;

Step S22, after monitoring that the timing task is on the main chain, the side chain synchronizes with the main chain to perform the original user state, and executes the timing task on the side chain;

Step S23, in response to a task stop instruction, the side chain synchronizes the user state after executing the scheduled task to the main chain to update the main chain;

Step S24, after the side chain monitors that the main chain will perform the timing task after the user state synchronization is completed, the main chain and the side chain end the timing task.

The interaction between the main chain and the side chain in the block chain-based timing task scheduling method according to the exemplary embodiment of the present invention will be described in more detail below with reference to the accompanying drawings and examples.

In step S21, based on a task scheduling instruction for the main chain, configure a side chain for the main chain so that the side chain enables service monitoring on the main chain.

In an exemplary embodiment of the present disclosure, a user or a blockchain member may generate a task scheduling instruction in advance according to actual needs, and the instruction may include a designated side that allocates migration to the main chain (main blockchain) and executes timed tasks After the side chain is allocated, the side chain starts to monitor transactions on the main chain. Moreover, one or more side chains can be assigned to the main chain, that is, the main chain and the side chains can be in a one-to-many relationship. The above-mentioned main chain may include multiple business contracts, that is, the main chain contract and the side chain may have a many-to-many relationship, wherein one contract in the main chain corresponds to a side chain that performs its corresponding scheduled task.

For example, the above-mentioned business contract of the main chain may include methods for executing and synchronizing timed tasks. For example, a business contract can include methods for submitting timed tasks, stopping timed tasks, exporting states, synchronizing states, and completing timed tasks. The method for submitting timed tasks may include one or more of the following parameters:

1) The contract address (send Address) that initiates the scheduled task, which must be the blockchain address specified by the contract, to ensure that the scheduled task is initiated by this address to prevent abuse by other accounts.

2) The execution method of the timed task. The execution method of the timed task must be a method existing in the contract, which is used to call the method when the sidechain executes the timed task. The timing method is a method determined by the user service; for example, the value timing exchange method, the data timing trigger method, and the like.

3) Execute the parameters of the timing method (method Param), some timing methods have configuration parameters required to execute the timing task, which are used for the side chain to transfer the configuration parameters to the side chain when executing the timing task, so that the side chain executes according to the configuration parameters. Scheduled tasks.

4) The timed task is associated with the user's address (relate Address). Since the timed task involves mutual value exchange between addresses, different addresses must be involved; therefore, it is necessary to specify the address of the associated user, which is convenient for locking the specified address of the associated user. , that is, the specified address is not allowed to trade on the main chain. If the address of the associated user is not specified, all addresses of the contract can be locked, that is, all addresses cannot be traded on the main chain. By locking transactions, these addresses can be prevented from being changed on the side chain and the main chain at the same time. The locked addresses cannot be changed in the main chain, but are allowed to be changed in the side chain.

5) Time Id, which can be used to uniquely mark the ID of a timed task. Other processing procedures of subsequent timing tasks can also be identified by this ID.

6) Timing task type (type), for example, the timer type includes incremental polling by block, or polling block by time, etc.

7) Timed task strategy (type Info), for example, if it is executed incrementally by block, set several blocks to execute a predetermined number of timed transactions, and the increment of the block is changed according to the incremental change of the side chain, such as each additional one. The block initiates ten transactions. If polling is performed by time, a predetermined number of timed transactions are executed after a predetermined duration, for example, ten transactions are initiated every 10 seconds.

8) Timed task stop condition (stop Require), that is, the stop condition for the sidechain to execute the timed task. For example, it can be set to stop the timed task after executing a predetermined number of tasks, or stop the timed task after executing the task with a predetermined total duration, etc. If the stop condition is not set, the sidechain timer can be stopped by subsequently initiating a transaction to stop the scheduled task.

Specifically, the above-mentioned side chain's business monitoring on the main chain may include:

Step S211, the side chain monitors the transaction of submitting the timing task at the specified address of the main chain through the transfer bridge to obtain its transaction hash;

Step S212, obtaining the block in the main chain where the transaction submitting the timing task is located according to the transaction hash, and querying the corresponding hash value according to the block header of the block;

Step S213: Calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original Merkle tree hash value in the block header in the main chain. The comparison is made to determine whether the transaction submitting the timed task is uploaded in the main chain.

The side chain jointly confirms whether the transaction of the main chain timing task occurs and is on the chain through the monitoring results of the transaction (watch eth) and block (watch block) of the main chain. Specifically, the side chain monitors all transactions under the business contract corresponding to the main chain through the transfer bridge to determine whether transactions related to timed tasks occur; In its own blockchain, SPV proof (Simplified PaymentVerification, simple payment verification).

In step S22, after monitoring that the timing task is on the main chain, the side chain synchronizes with the original user state of the main chain, and executes the timing task on the side chain.

In an exemplary embodiment of the present disclosure, a user can submit a timed task on the main chain, and the timed task can specify the timed rules of the main chain contract. In addition, when the main chain submits timed tasks, the management user can also be locked on the main chain to prevent data changes on the main chain.

Specifically, after the above-mentioned side chain monitors the timing tasks submitted by the main chain, it synchronizes with the main chain to perform the original user state, which may specifically include:

Step S2211, after monitoring that the timing task is on the main chain, the side chain initiates a transaction to determine the status of the timing task on the main chain and uploads it on the side chain;

Step S2212, after confirming the timing task of the main chain, the side chain initiates a transaction for synchronizing the original user state of the main chain, so as to synchronize the original user state with the main chain;

Step S2213, after the side chain confirms that the synchronization of the original user state is completed, the side chain initiates a transaction completed by the side chain state synchronization and uploads it to the chain.

After the side chain monitors the timed task submitted by the main chain to be uploaded, the side chain can also initiate a transaction to determine the state of the timed task in the main chain and upload it to the chain, thereby confirming the timed transaction of the main chain. After the side chain determines the scheduled tasks of the main chain, it can execute transactions that synchronize the original user state of the main chain and upload it to the chain, thereby synchronizing the original user state of the main chain to the side chain.

Specifically, the side chain can call the main chain synchronization state interface through the transfer bridge to call the export state method in the main chain contract to initiate a transaction that synchronizes the original user state of the main chain to derive the original users of all associated user addresses in the main chain state and initialize the sidechain.

At the same time, the synchronization result can also be returned to the main chain, so that the main chain ends the synchronization operation of the original user state. The side chain can also monitor the transaction of synchronizing the original user state of the main chain through the transfer bridge to determine whether the operation of synchronizing the original user state is completed.

After the sidechain completes the synchronization of the original user state, the sidechain node can call the contract to execute the timed task according to the timed rules in the timed task, and upload the task result to the chain by consensus. Specifically, it can include:

Step S2221, the timing contract executor of the block-producing node of the side chain invokes the timing contract to initiate a timing transaction, and sends the block to be confirmed including the timing transaction to each voting node;

Step S2222, the timing contract executor of the voting node invokes the timing contract to execute the timing transaction, generates a block voting result according to the execution result of the timing transaction, and returns the block voting result to the block generating node ;

Step S2223, the block producing node judges whether to produce a block on the chain according to the block producing voting result returned by the voting node.

In an exemplary embodiment of the present disclosure, the timing contract executor of the side chain node initiates a corresponding timing transaction according to the timing policy in the contract to execute the timing task. The state change in the contract must be the above-mentioned designated associated user. If the contract execution process involves the state change of the user outside the address range of the associated user, the execution will fail.

In step S23, in response to a task stop instruction, the side chain synchronizes the user state after executing the scheduled task to the main chain to update the main chain.

In an exemplary embodiment of the present disclosure, the above-mentioned task stop instruction may be a task stop instruction generated by the side chain according to a timing rule in a timed task, that is, a task stop instruction generated according to a method for completing the timed task in the main chain contract. Alternatively, when the method for stopping the scheduled task is not set in the contract, the scheduled task can also be stopped by submitting a transaction to end the scheduled task on the main chain. When the side chain monitors the transaction that ends the timing task initiated on the main chain, the side chain can initiate the transaction to end the timing task and upload it to the chain, thereby ending the timing task.

Specifically, after the side chain stops the timing task, the side chain can call the main chain synchronization status interface through the transition bridge to initiate a synchronization transaction that returns the execution result of the timing task to the main chain, so as to transfer the The execution result of the scheduled task of the side chain is returned to the main chain, so as to update the user status of the main chain. That is, the side chain invokes the main chain synchronization state method through the transfer bridge to initiate a synchronous transaction, and returns the execution result of the side chain's timed task, that is, the user state result after executing the timed task, to the main chain, so that the main chain changes the state of all users and sets into the same number of tokens as the side chain, and mark each user who has completed synchronization.

The caller of the above-mentioned main chain synchronization status interface must be the blockchain account address managed by the side chain, so as to prevent the execution result of the scheduled task of the side chain from being migrated to other main chains or main chain accounts. The incoming parameters can also include address, number of tokens, etc. For example, if the user originally has 10 tokens in the main chain, but after the side chain performs the scheduled task, it is 20 tokens, then the user is set to 20 tokens in the main chain. At the same time, after the user token is successfully set, you can also mark the setting as successful. In addition, the transfer bridge can also continuously monitor the synchronization transactions of the main chain to determine whether the synchronization is successful.

In step S24, after the side chain monitors the synchronization of the user state after the main chain will perform the timing task, the timing task is ended on the main chain and the side chain.

In an exemplary embodiment of the present disclosure, the above-mentioned step S24 may include:

Step S241, after monitoring the completion of the synchronization operation of the main chain, the side chain initiates a transaction to complete the synchronization of the main chain state and uploads it to the chain;

Step S242, the side chain initiates a transaction for the end timing task of the main chain, so that the main chain executes the transaction for ending the timing task, and after confirming that the synchronization operation is completed, the transaction for ending the timing task is completed. On the main chain to end the timing task.

In step S243, the side chain initiates a transaction for confirming the end of the timing task on the side chain and uploads the transaction, so as to end the timing task on the side chain.

By monitoring the transactions and blocks of the main chain, the side chain confirms that the synchronization of the user state after executing the scheduled task with the main chain is completed, and then initiates a transaction that completes the synchronization of the main chain state and uploads it to the chain. At the same time, the locked state of each user in the main chain can also be released.

The side chain can also call the main chain to complete the timed task method through the transfer bridge, initiate a transaction to the main chain's end timed task, and completely end the main chain's timed task. After the side chain monitors that the scheduled task is completely completed on the main chain, the side chain initiates a transaction to confirm the end of the scheduled task. After the side chain is successfully uploaded, the scheduled task is completely completed on the side chain. As a result, the process of submitting, synchronizing, executing, stopping, resynchronizing, and completing a scheduled task is completed on the main chain and side chain.

To sum up, by pre-allocating one or more side chains corresponding to the main chain, when the timed tasks of different contracts are submitted to the main chain, the timed tasks can be transferred to the designated side chain for execution. By using the side chain to cooperate to execute the timing tasks of the main chain, the problems of excessive timing transactions, low efficiency and low performance of a single blockchain are solved; at the same time, the total transaction volume of the main chain and the transaction overhead of the main chain are reduced; at the same time, the side chain The chain can provide transaction queries for specific scheduled tasks.

Exemplary device

After the blockchain-based timing task scheduling method according to the exemplary embodiment of the present invention is introduced, next, the blockchain-based timing task scheduling apparatus according to the exemplary embodiment of the present invention will be described with reference to FIG. 7 .

Referring to FIG. 7 , a blockchain-based timing task scheduling apparatus 10 according to an exemplary embodiment of the present invention may include: a service monitoring module 101 , a first task execution module 102 , a first task stop module 103 and a task end module 104. in:

The service monitoring module 101 may be configured to respond to a task scheduling instruction on the main chain to start service monitoring on the main chain.

The first task execution module 102 can be configured to perform original user state synchronization with the main chain after monitoring that the timing task is on the main chain, and execute the timing after the synchronization with the main chain is completed. Task.

The first task stop module 103 may be configured to, in response to a task stop instruction, synchronize the user state after executing the scheduled task to the main chain.

The task ending module 104 may be configured to end the scheduled task after monitoring that the user state after executing the scheduled task is synchronized with the main chain.

According to an exemplary embodiment of the present disclosure, the service monitoring module 101 may include: a transaction hash acquisition module, a block header query module, and a hash value comparison module (not shown in the figure). in,

The transaction hash obtaining module may be configured to monitor, through a transition bridge, a transaction that submits a timed task at a specified address of the main chain to obtain its transaction hash.

The block header query module may be configured to obtain the block in the main chain where the transaction submitting the timed task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block.

The hash value comparison module can be used to calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original value in the block header in the main chain. Merkle tree hash values are compared to determine whether the transaction submitting the scheduled task is on-chain in the main chain.

According to an exemplary embodiment of the present disclosure, the first task execution module 102 may include: a timing task confirmation module, a user state synchronization module, and a synchronization completion module (not shown in the figure). in,

The timed task confirmation module may be configured to initiate a transaction to determine the state of the timed task on the main chain after monitoring that the timed task is on the main chain, and upload it to the chain.

The user state synchronization module may be configured to perform original user state synchronization with the main chain after determining the state of the timing task in the main chain.

The synchronization completion module may be used to initiate a synchronization completed transaction and upload it to the chain after the synchronization operation is completed.

According to an exemplary embodiment of the present disclosure, the user state synchronization module may include: a main chain synchronization state interface calling module (not shown in the figure).

The main chain synchronization state interface calling module can be used to call the main chain synchronization state interface through the transfer bridge to initiate a transaction that synchronizes the original user state with the main chain, and returns the synchronization result to the main chain.

According to an exemplary embodiment of the present disclosure, the apparatus further includes: a synchronization result confirmation module (not shown in the figure).

The synchronization result confirmation module can be used to monitor the transaction of synchronizing the original user state with the main chain through the switching bridge, so as to determine whether the operation of synchronizing the original user state is completed.

According to an exemplary embodiment of the present disclosure, the first task execution module may include: a timed task execution module (not shown in the figure).

The timed task execution module may be configured to call a contract to execute the timed task according to the timed rules in the timed task, and upload the task result to the chain by consensus.

According to an exemplary embodiment of the present disclosure, the timing task execution module may include: a transaction initiation module, a block generation voting result generation module, and a timing task block generation module (not shown in the figure). in,

The transaction initiation module may be configured to initiate a timed transaction according to the timed contract by the timed contract executor of the block-producing node, and send the block to be confirmed including the timed transaction to each voting node.

The block-producing voting result generation module can be used by the timing contract executor of the voting node to execute the timing transaction, generate a block-producing voting result according to the execution result of the timing transaction, and return it to the block-producing node.

The timing task block generation module can be used by the block generation node to determine whether to generate a block for the timing task result and upload it to the chain according to the block generation voting results returned by each of the voting nodes.

According to an exemplary embodiment of the present disclosure, the first task stop module 103 may include: a stop instruction generating module and/or a stop instruction monitoring module (not shown in the figure). in,

The stop instruction generating module may be configured to generate a task stop instruction according to a timing rule in the timing task.

The stop instruction monitoring module may be configured to initiate the transaction for stopping the timing task to generate a task stop instruction when monitoring that the transaction for stopping the timing task is on the main chain.

According to an exemplary embodiment of the present disclosure, the first task stopping module further includes: a task result returning module (not shown in the figure).

The task result returning module can be used to call the synchronization status interface of the main chain through the switching bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, so that the user after the timed task is executed. The state is synchronized to the main chain.

According to an exemplary embodiment of the present disclosure, the task ending module includes: a user status monitoring module and a main chain timing task ending module (not shown in the figure). in,

The user state monitoring module may be configured to initiate a transaction completed by the synchronization of the state of the main chain and upload it to the chain after monitoring the synchronization of the user state after the main chain completes the execution of the timed task.

The main chain timing task ending module may be configured to initiate a transaction for the main chain to end the timing task, so that the main chain executes the transaction for ending the timing task.

According to an exemplary embodiment of the present disclosure, the apparatus further includes: a timing task ending module (not shown in the figure).

The timed task ending module may be configured to initiate a transaction confirming the end of the timed task to end the timed task.

Referring to FIG. 8 , another block chain-based timing task scheduling apparatus 20 according to an exemplary embodiment of the present invention may include: a side chain allocation module 201 , a second task execution module 202 , a second task stop module 203 and a task End block 204 . in,

The side chain allocation module 201 may be configured to configure a side chain for the main chain based on a task scheduling instruction to the main chain, so that the side chain enables service monitoring of the main chain.

The second task execution module 202 can be used for the side chain to synchronize with the main chain execution user state after monitoring that the timing task is on the main chain, so as to be used for executing the side chain. Scheduled tasks.

The second task stop module 203 can be used for the side chain to synchronize the user state after executing the scheduled task to the main chain in response to a task stop instruction to update the main chain.

The task completion module 204 may be configured to end the scheduled task on the main chain and the side chain after the side chain monitors the synchronization of the user state after the main chain will perform the scheduled task.

According to an exemplary embodiment of the present disclosure, the apparatus further includes: a transaction hash acquisition module, a block header query module, and a hash value comparison module (not shown in the figure). in,

The transaction hash obtaining module can be used for the side chain to monitor the transaction that submits the timed task at the specified address of the main chain through the transfer bridge to obtain its transaction hash.

The block header query module may be configured to obtain the block in the main chain where the transaction submitting the timed task is located according to the transaction hash, and query the corresponding hash value according to the block header of the block.

The hash value comparison module can be used to calculate the Merkle tree hash value according to the hash value, and compare the Merkle tree hash value with the original value in the block header in the main chain. Merkle tree hash values are compared to determine whether the transaction submitting the scheduled task is on-chain in the main chain.

According to an exemplary embodiment of the present disclosure, the apparatus further includes: a user state locking module (not shown in the figure).

The user state locking module can be used to lock and manage users on the main chain when the main chain submits a timed task.

According to an exemplary embodiment of the present disclosure, the second task execution module includes: a timing task side chain determination module, an original user state synchronization module, and an original user state side chain confirmation module (not shown in the figure). in,

The timing task side chain determination module can be used for the side chain to initiate a process to determine the status of the timing task on the main chain after the side chain monitors that the timing task is on the main chain. Transaction and on-chain.

The original user state synchronization module can be used for the side chain to initiate a transaction for synchronizing the original user state of the main chain after confirming the scheduled task of the main chain, so as to synchronize the original user state with the main chain.

The original user state side chain confirmation module can be used to initiate a transaction completed by the side chain state synchronization on the side chain after the side chain confirms that the synchronization of the original user state is completed, and upload it to the chain.

According to an exemplary embodiment of the present disclosure, the original user state synchronization module includes: a main chain synchronization state interface calling module (not shown in the figure).

The main chain synchronization state interface calling module can be used for the side chain to call the main chain synchronization state interface through the transfer bridge to initiate a transaction that synchronizes the original user state of the main chain, and returns the synchronization result to the main chain .

According to an exemplary embodiment of the present disclosure, the original user state side chain confirmation module includes: a main chain synchronization transaction monitoring module (not shown in the figure).

The main chain synchronization transaction monitoring module can be used for the side chain to monitor the transaction of synchronizing the original user state of the main chain through the transfer bridge to determine whether the operation of synchronizing the original user state is completed.

According to an exemplary embodiment of the present disclosure, the second task execution module includes: a timing task side chain execution module (not shown in the figure).

The timed task sidechain execution module can be used by the sidechain node to call a contract to execute the timed task according to the timed rules in the timed task, and to upload the task result to the chain by consensus.

According to an exemplary embodiment of the present disclosure, the timing task side chain execution module may include: a block producing node execution module, a voting node execution module, and a task result block producing module (not shown in the figure). in,

The block-producing node execution module can be used by the timing contract executor of the block-producing node of the side chain to call the timing contract to initiate a timing transaction, and send the block to be confirmed including the timing transaction to each voting node.

The voting node execution module can be used by the timing contract executor of the voting node to call the timing contract to execute the timing transaction, generate a block voting result according to the execution result of the timing transaction, and return the block generation voting result. to the block producing node.

The task result block generation module can be used by the block generation node to determine whether to generate a block for the timed task result and upload it to the chain according to the block generation voting result returned by the voting node.

According to an exemplary embodiment of the present disclosure, the second task stop module includes: a stop instruction side chain generation module and/or a stop instruction side chain generation module (not shown in the figure). in,

The stop instruction side chain generation module may be used for the side chain to generate a task stop instruction according to a timing rule in the timing task.

The stop command side chain monitoring module can be used for the side chain to initiate a transaction to end the timed task on the side chain and upload the transaction when the side chain monitors the transaction initiated on the main chain to end the timed task.

According to an exemplary embodiment of the present disclosure, the second task stop module further includes: a task result return module (not shown in the figure).

The task result return module can be used by the side chain to call the main chain synchronization status interface through the transfer bridge to initiate a synchronization transaction that returns the execution result of the timed task to the main chain, so as to return the side chain's synchronization status. The execution result of the scheduled task is returned to the main chain, so as to update the user status of the main chain.

According to an exemplary embodiment of the present disclosure, the task completion module includes: a main chain synchronization completion module and a timing task main chain completion module (not shown in the figure). in,

The main chain synchronization completion module can be used for the side chain to initiate a transaction to complete the main chain state synchronization and upload to the chain after monitoring the completion of the synchronization operation of the main chain.

The timing task main chain end module can be used for the side chain to initiate a transaction for the end timing task of the main chain, so that the main chain executes the transaction for ending the timing task, and after confirming that the synchronization operation is completed The transaction that ends the timing task is chained on the main chain to end the timing task.

According to an exemplary embodiment of the present disclosure, the task completion module further includes: a timing task side chain completion module (not shown in the figure).

The timing task side chain termination module may be used by the side chain to initiate a transaction of the side chain to confirm the termination of the timing task and upload it to the chain, so as to end the timing task on the side chain.

According to an exemplary embodiment of the present disclosure, the apparatus further includes: a user unlocking module (not shown in the figure).

The user unlocking module can be used for the main chain to unlock management users.

Since the functional modules of the block chain-based timing task scheduling apparatus according to the embodiment of the present invention are the same as those in the above-mentioned inventive embodiments of the block chain-based timing task scheduling apparatus method, they will not be repeated here.

Exemplary Storage Media

After introducing the audio playing method and apparatus, and the audio sharing method and apparatus according to the exemplary embodiment of the present invention, next, the storage medium of the exemplary embodiment of the present invention will be described with reference to FIG. 9 .

Referring to FIG. 9, a program product 700 for implementing the above method is described according to an embodiment of the present invention, which may adopt a portable compact disc read only memory (CD-ROM) and include program code, and may be stored in a device such as run on a personal computer. However, the program product of the present invention is not limited thereto, and in this document, a readable storage medium may be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device.

The program product may employ any combination of one or more readable media. The readable medium may be a readable signal medium or a readable storage medium. The readable storage medium may be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus or device, or a combination of any of the above. More specific examples (non-exhaustive list) of readable storage media include: electrical connections with one or more wires, portable disks, hard disks, random access memory (RAM), read only memory (ROM), erasable programmable read only memory (EPROM or flash memory), optical fiber, portable compact disk read only memory (CD-ROM), optical storage devices, magnetic storage devices, or any suitable combination of the foregoing.

A computer readable signal medium may include a propagated data signal in baseband or as part of a carrier wave with readable program code embodied thereon. Such propagated data signals may take a variety of forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A readable signal medium can also be any readable medium, other than a readable storage medium, that can transmit, propagate, or transport the program for use by or in connection with the instruction execution system, apparatus, or device.

Program code embodied on a readable medium may be transmitted using any suitable medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.

Program code for carrying out operations of the present invention may be written in any combination of one or more programming languages, including object-oriented programming languages - such as Java, C++, etc., as well as conventional procedural Programming Language - Such as "C" language or similar programming language. The program code may execute entirely on the user computing device, partly on the user computing device and partly on a remote computing device, or entirely on the remote computing device or server. In the case of a remote computing device, the remote computing device may be connected to the user computing device through any kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computing device (eg, using an Internet service provider business via an Internet connection).

Exemplary Electronics

After introducing the storage medium of the exemplary embodiment of the present invention, next, the electronic device of the exemplary embodiment of the present invention will be described with reference to FIG. 10 .

The electronic device 800 shown in FIG. 10 is only an example, and should not impose any limitation on the function and scope of use of the embodiments of the present invention.

As shown in FIG. 10, electronic device 800 takes the form of a general-purpose computing device. Components of the electronic device 800 may include, but are not limited to: the above-mentioned at least one processing unit 810 , the above-mentioned at least one storage unit 820 , a bus 830 connecting different system components (including the storage unit 820 and the processing unit 810 ), and a display unit 840 .

Wherein, the storage unit stores program codes, and the program codes can be executed by the processing unit 810, so that the processing unit 810 executes various exemplary methods according to the present invention described in the above-mentioned "Exemplary Methods" section of this specification Implementation steps. For example, the processing unit 810 may perform steps S11 to S14 as shown in FIG. 1 , or the processing unit 810 may perform steps S21 to S24 as shown in FIG. 6 .

The storage unit 820 may include a volatile storage unit, such as a random access storage unit (RAM) 8201 and/or a cache storage unit 8202 , and may further include a read only storage unit (ROM) 8203 .

The storage unit 820 may also include a program/utility 8204 having a set (at least one) of program modules 8205 including, but not limited to, an operating system, one or more application programs, other program modules, and program data, An implementation of a network environment may be included in each or some combination of these examples.

The bus 830 may include a data bus, an address bus, and a control bus.

Electronic device 800 may also communicate with one or more external devices 900 (eg, keyboards, pointing devices, Bluetooth devices, etc.), such communication may be through input/output (I/O) interface 850 . The electronic device 800 also includes a display unit 840 connected to an input/output (I/O) interface 850 for display. Also, the electronic device 800 may communicate with one or more networks (eg, a local area network (LAN), a wide area network (WAN), and/or a public network such as the Internet) through a network adapter 860 . As shown, network adapter 860 communicates with other modules of electronic device 800 via bus 830 . It should be understood that, although not shown, other hardware and/or software modules may be used in conjunction with electronic device 800, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives and data backup storage systems.

It should be noted that although several modules or sub-modules of the audio playback device and the audio sharing device are mentioned in the above detailed description, this division is merely exemplary and not mandatory. Indeed, the features and functions of two or more units/modules described above may be embodied in one unit/module according to embodiments of the present invention. Conversely, the features and functions of one unit/module described above may be further subdivided to be embodied by multiple units/modules.

Furthermore, although the operations of the methods of the present invention are depicted in the figures in a particular order, this does not require or imply that the operations must be performed in the particular order, or that all illustrated operations must be performed to achieve desirable results. Additionally or alternatively, certain steps may be omitted, multiple steps may be combined to be performed as one step, and/or one step may be decomposed into multiple steps to be performed.

While the spirit and principles of the present invention have been described with reference to a number of specific embodiments, it should be understood that the invention is not limited to the specific embodiments disclosed, nor does the division of aspects imply that features of these aspects cannot be combined to perform Benefit, this division is only for convenience of presentation. The invention is intended to cover various modifications and equivalent arrangements included within the spirit and scope of the appended claims.

Claims (10)

1. A timing task scheduling method based on a block chain is characterized by comprising the following steps:

responding to a task scheduling instruction of a main chain to start service monitoring of the main chain;

after monitoring that a timing task is linked on the main chain, carrying out original user state synchronization with the main chain, and executing the timing task after the timing task is synchronously finished with the main chain;

synchronizing the user state after the timed task is executed to the main chain in response to a task stop instruction;

and after the user state after the timing task is monitored to be synchronized to the main chain, ending the timing task.

2. The method of claim 1, wherein the listening for traffic to the backbone comprises:

monitoring the transaction of the main chain designated address submitting the timing task through a transfer bridge to obtain transaction hash of the main chain designated address;

acquiring a block where the transaction submitting the timing task is located in the main chain according to the transaction hash, and inquiring a corresponding hash value according to a block head of the block;

and calculating a Mercker tree hash value according to the hash value, and comparing the Mercker tree hash value with an original Mercker tree hash value in the block head in the main chain to judge whether the transaction submitting the timing task is uplink in the main chain.

3. The method of claim 1, wherein the synchronizing with the primary chain for original user status after monitoring that the timed task is uplink on the primary chain comprises:

after monitoring that the timing task is on the main chain, initiating a transaction for determining the state of the timing task on the main chain and carrying out chain connection;

after the state of the timing task in the main chain is determined, carrying out original user state synchronization with the main chain;

after the synchronous operation is completed, the transaction for completing the synchronization is initiated and linked up.

4. The method of claim 3, wherein after determining the state of the timed task at the backbone, synchronizing an original user state with the backbone comprises:

and calling a main chain synchronous state interface through the transfer bridge to initiate a transaction of synchronizing the original user state with the main chain, and returning a synchronization result to the main chain.

5. The method of claim 4, further comprising:

and monitoring the transaction of the original user state synchronized with the main chain through the transit bridge to determine whether the operation of synchronizing the original user state is finished.

6. A timing task scheduling method based on a block chain is characterized by comprising the following steps:

configuring a side chain for a main chain based on a task scheduling instruction of the main chain so that the side chain starts service monitoring of the main chain;

after monitoring that a timing task is uplink on the main chain, the side chain is synchronous with the original user state executed by the main chain and executes the timing task on the side chain;

the side chain responds to a task stopping instruction and synchronizes the user state after the timed task is executed to the main chain so as to update the main chain;

and after the side chain monitors that the main chain synchronously completes the user state after the timing task is executed, finishing the timing task at the main chain and the side chain.

7. A block chain based timed task scheduler, comprising:

the service monitoring module is used for responding to a task scheduling instruction of the main chain so as to start service monitoring on the main chain;

the first task execution module is used for carrying out original user state synchronization with the main chain after monitoring that a timing task is linked on the main chain, and executing the timing task after the timing task is synchronously finished with the main chain;

the first task stopping module is used for responding to a task stopping instruction and synchronizing the user state after the timing task is executed to the main chain;

and the task ending module is used for ending the timing task after monitoring that the user state after the timing task is executed and the main chain are synchronously finished.

8. A block chain based timed task scheduler, comprising:

the side chain allocation module is used for configuring a side chain for the main chain based on a task scheduling instruction of the main chain so as to enable the side chain to start service monitoring of the main chain;

a second task execution module, configured to synchronize, by the sidelink, with a user state executed by the main chain after the timed task is monitored to be uplink on the main chain, so as to execute the timed task on the sidelink;

the second task stopping module is used for the side chain responding to a task stopping instruction and synchronizing the user state after the timing task is executed to the main chain so as to update the main chain;

and the task ending module is used for ending the timing task at the main chain and the side chain after the side chain monitors that the main chain synchronously finishes the user state after the timing task is executed.

9. A storage medium having stored thereon a computer program, wherein the computer program, when executed by a processor, implements the method of block chain based timing task scheduling of any of claims 1 to 5 or 6.

10. An electronic device, comprising:

a processor; and

a memory for storing executable instructions of the processor;

wherein the processor is configured to perform the block chain based timing task scheduling method of any one of claims 1 to 5 or 6 via execution of the executable instructions.