CN108023908B - Data updating method, device and system - Google Patents
Data updating method, device and system Download PDFInfo
- Publication number
- CN108023908B CN108023908B CN201610933755.6A CN201610933755A CN108023908B CN 108023908 B CN108023908 B CN 108023908B CN 201610933755 A CN201610933755 A CN 201610933755A CN 108023908 B CN108023908 B CN 108023908B
- Authority
- CN
- China
- Prior art keywords
- data
- information
- updating
- field
- target
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 63
- 238000012163 sequencing technique Methods 0.000 claims abstract description 17
- 230000007246 mechanism Effects 0.000 claims abstract description 14
- 230000007717 exclusion Effects 0.000 claims description 29
- 230000004044 response Effects 0.000 claims description 22
- 239000000284 extract Substances 0.000 claims description 12
- 238000000605 extraction Methods 0.000 claims description 5
- 230000005540 biological transmission Effects 0.000 abstract description 11
- 230000008569 process Effects 0.000 description 17
- 238000010586 diagram Methods 0.000 description 9
- 230000006870 function Effects 0.000 description 4
- 238000005516 engineering process Methods 0.000 description 3
- 230000001960 triggered effect Effects 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 230000003247 decreasing effect Effects 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 239000002699 waste material Substances 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
- H04L67/5682—Policies or rules for updating, deleting or replacing the stored data
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/70—Software maintenance or management
- G06F8/71—Version control; Configuration management
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Computer Security & Cryptography (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention discloses a data updating method, a device and a system, and belongs to the technical field of networks. The method comprises the following steps: receiving a data updating request sent by a service server, wherein the data updating request comprises data updating information and sequencing information; adding the data updating information in the data updating request to an information queue according to the sorting information; and when the data updating information is positioned at the designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server. The invention provides a queuing mechanism which can sequence the data updating information of a plurality of data updating requests in an information queue, avoids the conflict caused by updating the same target data at the same time, reduces the transmission times, saves the transmission resources and improves the speed and the efficiency of data updating.
Description
Technical Field
The present invention relates to the field of network technologies, and in particular, to a data updating method, apparatus, and system.
Background
With the rapid development of network technology and the gradual expansion of network scale, the types of network services are more and more, and a service server generally needs to process a large amount of service data in the process of processing various services. In order to avoid the occupation of a storage space by the service data, the service server stores the service data in the storage server, and the service data in the storage server can be updated in the operation process of the service server.
Taking the target data in the storage server as an example, when the business server needs to update the target data, a reading request for the target data is sent to the storage server, and the storage server receives the reading request, reads the target data and returns the target data to the business server. And when the business server receives the target data, updating the version number in the target data, and sending the updated target data to the storage server, wherein the updated target data comprises the updated version number. When the storage server receives the updated target data, in order to avoid a conflict caused by the fact that a plurality of service servers update the target data at the same time, the version number in the updated target data can be obtained, the version number is compared with the version number of the target data in the storage server, if the version number is newer than the version number of the target data, the updated target data is stored, if the version number of the target data is newer than the version number, which indicates that other service servers have updated the target data, the updated target data of the service server is abandoned to be stored, and the service server fails to update, and only the updating process can be executed again.
In the process of implementing the invention, the inventor finds that the related art has at least the following problems:
the data updating process includes multiple transmissions between the service server and the storage server, and the multiple transmissions consume transmission resources, resulting in slow data updating speed and low efficiency.
Disclosure of Invention
In order to solve the problems of the related art, embodiments of the present invention provide a data updating method, apparatus, and system. The technical scheme is as follows:
in a first aspect, a data updating method is provided, and is applied to a storage server, where the method includes:
receiving a data updating request sent by a service server, wherein the data updating request comprises data updating information and sequencing information;
adding the data updating information in the data updating request to an information queue according to the sorting information;
and when the data updating information is positioned at the designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server.
In a second aspect, a data updating method is provided, which is applied in a service server, and the method includes:
acquiring data updating information and sequencing information;
sending a data updating request to a storage server, wherein the data updating request comprises the data updating information and the sorting information, and the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
and receiving the updated target data fed back by the storage server.
In a third aspect, a data updating method is provided, the method including:
the method comprises the steps that a service server sends a data updating request to a storage server, wherein the data updating request comprises data updating information and sequencing information;
when the storage server receives the data updating request, adding the data updating information in the data updating request to an information queue according to the sorting information; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue; updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
and the service server receives the updated target data.
In a fourth aspect, there is provided a data updating apparatus, which is applied in a storage server, the apparatus including:
the system comprises a receiving module, a sending module and a receiving module, wherein the receiving module is used for receiving a data updating request sent by a service server, and the data updating request comprises data updating information and sequencing information;
the adding module is used for adding the data updating information in the data updating request to an information queue according to the sorting information;
the extracting module is used for extracting the data updating information from the information queue when the data updating information is positioned at a specified position in the information queue;
the updating module is used for updating the corresponding target data based on the extracted data updating information;
and the feedback module is used for feeding back the updated target data to the service server.
In a fifth aspect, there is provided a data updating apparatus, which is applied in a service server, and the apparatus includes:
the acquisition module is used for acquiring data updating information and sequencing information;
the sending module is used for sending a data updating request to a storage server, wherein the data updating request comprises the data updating information and the sorting information, the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information, and the data in the information queue is configured to be processed according to a first-in first-out processing mechanism; extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
and the receiving module is used for receiving the updated target data fed back by the storage server.
In a sixth aspect, a data update system is provided, the system comprising:
the service server is used for sending a data updating request to the storage server, wherein the data updating request comprises data updating information and sequencing information;
the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information when receiving the data updating request; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue; updating corresponding target data based on the extracted data updating information; feeding back the updated target data to the service server;
and the service server is also used for receiving the updated target data.
The technical scheme provided by the embodiment of the invention has the following beneficial effects:
according to the method, the device and the system provided by the embodiment of the invention, after the business server sends the data updating request to the storage server, the storage server receives the data updating request, the data updating information in the data updating request is added to the information queue, when the data updating information is positioned at the specified position in the information queue, the data updating request is extracted from the information queue, the corresponding target data is updated based on the extracted data updating information, and the updated target data is fed back to the business server. The embodiment of the invention provides a queuing mechanism, which can sort the data updating information of a plurality of data updating requests according to the sorting information in an information queue by a storage server, thereby not only avoiding the conflict caused by the simultaneous updating of the same target data by a plurality of data updating requests, but also reducing the transmission times between the service server and the storage server, saving transmission resources and improving the speed and efficiency of data updating because the service server only needs to send the data updating request to the storage server once.
Drawings
In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the drawings needed to be used in the description of the embodiments will be briefly introduced below, and it is obvious that the drawings in the following description are only some embodiments of the present invention, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without creative efforts.
FIG. 1 is a schematic structural diagram of a data update system according to an embodiment of the present invention;
FIG. 2A is a flow chart of a data updating method according to an embodiment of the present invention;
FIG. 2B is a schematic diagram of a FIFO queue according to an embodiment of the present invention;
FIG. 3 is a schematic structural diagram of a data update apparatus according to an embodiment of the present invention;
FIG. 4 is a schematic structural diagram of a data update apparatus according to an embodiment of the present invention;
fig. 5 is a schematic structural diagram of a data updating apparatus according to an embodiment of the present invention.
Detailed Description
In order to make the objects, technical solutions and advantages of the present invention more apparent, embodiments of the present invention will be described in detail with reference to the accompanying drawings.
Fig. 1 is a schematic structural diagram of a data updating system according to an embodiment of the present invention. Referring to fig. 1, the data update system includes a service server 101 and a storage server 102, and the service server 101 is connected to the storage server 102.
And the service server 101 is configured to obtain the data update information and the ranking information, and send a data update request to the storage server 102, where the data update request includes the update information and the ranking information.
The storage server 102 is configured to add the data update information in the data update request to an information queue according to the sorting information; and when the data updating information is positioned at the designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server.
The service server 101 is further configured to receive the target data.
The service server 101 is a device for processing various services in a network, and the service server 101 may be a server, a server cluster composed of a plurality of servers, or a cloud computing service center. The storage server 102 is used for storing the service data of the service server, and the storage server 102 may be a cache storage server, a main storage server, an external storage server, or the like.
The embodiment of the invention can be applied to various scenes needing data updating, wherein the scenes can comprise social applications, game applications, payment applications and the like, and the embodiment of the invention is not limited to the above.
In one possible implementation, the data of the public social network identifier may be updated, and the public social network identifier may be a public number or the like registered in the social application. Specifically, when the service server needs to update the data of the public social network identifier, a data update request including data update information and sequencing information is sent to the storage server, the storage server receives the data update request, queues the data update information in an information queue until the data update information is located at a specified position of the information queue, the data update information can be extracted from the information queue, and updates the data of the public social network identifier based on the data update information, so that the plurality of service servers are ensured to update the data of the public social network identifier respectively without causing conflict.
Further, the data of the public social network identifier may include a plurality of fields, such as an avatar field for storing the avatar of the public social network identifier, an attention amount field for storing the attention amount of the public social network identifier, a function introduction field for storing the function introduction text data of the public social network identifier, and the like.
When a new user subscribes a message of a public social network identifier, the field of the amount of interest of the public social network identifier needs to be updated, the business server sends a data updating request comprising data updating information and sequencing information to the storage server, the data updating information comprises the public social network identifier and the field identifier, the storage server receives the data updating request, and after queuing is carried out in an information queue corresponding to the public social network identifier, the field of the amount of interest in the data of the public social network identifier is updated.
In another possible implementation manner, data of a certain user identifier may be updated in a manner similar to that of the data of the public social network identifier, and details are not repeated here. The user identifier is used to determine a unique corresponding user, and may be a user account, a phone number, or the like.
Fig. 2A is a flowchart of a data updating method according to an embodiment of the present invention. The embodiment of the present invention is applied to the system shown in fig. 1, where the interaction subject includes a service server and a storage server, and referring to fig. 2A, the method includes:
201. and the service server acquires the data updating information and the sequencing information and sends a data updating request to the storage server.
In daily life, a service server needs to process a large amount of services at any time, the requirement on processing resources is high, and if the service server stores service data, the service processing speed of the service server is slow, and the efficiency is low. Therefore, the service server usually stores the service data in a storage server, and the service data can be subsequently extracted from the storage server.
During the operation of the service server, some service data in the storage server may need to be updated. For example, the service server receives a service processing request sent by any device, and needs to update corresponding service data according to the service processing request, or the service server needs to update corresponding service data according to its current operating state.
Therefore, when the business server needs to update the target data, the data update information and the sorting information corresponding to the target data are obtained, and a data update request is sent to the storage server, wherein the data update request comprises the data update information and the sorting information. The storage server may determine target data to be updated from at least one piece of data stored in the storage server based on the data update information in the data update request, and update the target data.
Wherein the data update information includes the data identification, the field identification, and the update information. In practice, the storage server may store at least one piece of data, and each piece of data includes at least one field, the data identification is used to determine target data to be updated from the at least one piece of data stored in the storage server, and may be a name, a number, and the like of the target data, the field identification is used to determine a target field to be updated in the target data, and may be a name, a number, and the like of the field, the update information is used to determine an update manner of the target field, and the target field may be updated according to the update information.
The ordering information may be a time stamp or a priority of the data update request. The timestamp may be a timestamp added by the service server before sending the data update request, and may be used to indicate the morning and evening of the sending time of the data update request, and correspondingly, it may also be considered that the timestamp can be used to indicate the morning and evening of the time when the storage server receives the data update request. The priority is used to indicate the instantaneity requirement of the data update request, and the higher the priority of the data update request is, the data update request should be processed preferentially. The sorting information may indicate a time stamp or a priority of the data update information, and the storage server may sort the data update information in the data update request with other data update information according to the sorting information in the data update request.
Further, the storage server may provide an RPC (Remote Procedure call protocol) interface for the service server, the service server may send a data update request to the storage server by calling the RPC interface, and the storage server may receive the data update request through the RPC interface.
202. And the storage server receives a data updating request sent by the service server, and adds data updating information in the data updating request to the information queue according to the sequencing information.
In practical applications, the storage server may receive a large number of data update requests for the target data, and the data update requests are all requests for updating the target data. Therefore, in order to avoid conflict between the data update requests when the data update requests are processed, the storage server can generate an information queue, and the data update information in the data update requests is added to the information queue according to the sorting information.
Further, when the data update information includes a data identifier, the information queue may correspond to the data identifier of the target data, and then, each time the storage server receives a data update request, the data update information in the data update request is added to the information queue corresponding to the data identifier.
The information queue is configured to sort the data update information according to the sorting information, that is, the storage server may sort the corresponding at least one piece of data update information according to the sorting information in the at least one data update request, and then process the data update information arranged at the designated position in the information queue according to the sorting order each time, so as to avoid a collision between the data update requests.
The type of the information queue may be a first-in first-out queue, a priority queue, or another type of queue.
In a possible implementation manner, the type of the information queue may be a first-in first-out queue, the sorting information includes a timestamp, the timestamp is used for indicating the receiving time of the data updating information, and the information in the information queue is configured to be processed according to a first-in first-out processing mechanism. Then, each time the storage server receives a data update request, the data update information in the data update request may be directly added to the tail of the information queue, that is, after all the data update information in the information queue.
In another possible implementation manner, the type of the information queue may be a priority queue, the sorting information includes a priority, and then the information in the information queue is configured to be processed according to the order of the priority from high to low. Then, each time the storage server receives a data update request, the location of the data update information may be determined according to the priority of the data update information and the priorities of other data update information already stored in the information queue, and the data update information may be added to the location of the information queue such that other data update information having a higher priority than the data update information is located before the data update information and other data update information having a lower priority than the data update information is located after the data update information.
203. When the data updating information is located at the designated position in the information queue, the storage server extracts the data updating information from the information queue.
In a possible implementation manner, when the type of the information queue is a first-in first-out queue, the information in the information queue is configured to be processed according to a first-in first-out processing mechanism, and then the specified position is the first bit in the information queue, and the storage server extracts the data update information located at the first bit from the information queue each time. Therefore, when the data update information is the data update information with the earliest time stamp in the information queue, the data update information is positioned at the first position in the information queue, and the storage server extracts the data update information from the information queue.
Specifically, referring to fig. 2B, in the fifo queue, the data update information with the earliest timestamp is arranged at the head of the queue, and the data update information with the latest timestamp is arranged at the tail of the queue, each time the fifo queue reads the data update information, the data update information at the head of the queue is actually read, and each time a new data update request is received, the data update information in the new data update request can be arranged at the tail of the queue, so that the purpose of arranging the data update information in the order of the timestamps from the beginning to the end is achieved.
In another possible implementation manner, when the type of the information queue is a priority queue, and the information in the information queue is configured to be processed in an order from high priority to low priority, the specified position may be the first position of the information queue, and the storage server extracts the data update information with the highest priority from the information queue each time. Therefore, when the data updating information is the data updating information with the highest priority in the information queue, the data updating information is positioned at the first position in the information queue, and the storage server extracts the data updating information from the information queue.
The priority of the data update information may be determined by the service server, or determined by the storage server according to the update type of the data update information, or determined according to other parameters.
In addition, the data update information in the information queue may also be configured to be processed in other orders, for example, the storage server may set a preset ordering rule, and then the storage server orders the data update information in the information queue according to the preset ordering rule, and extracts the data update information arranged at the specified position from the information queue each time.
Further, the storage server may set a mutual exclusion lock for the information queue, where the mutual exclusion lock is an exclusive lock interface and can only be called by one party. Then, each time the storage server adds data update information to the information queue or extracts data update information from the information queue, the data update information can be executed on the premise that the mutual exclusion lock is successfully invoked.
That is, the step 202 may include: and when receiving the data updating request, the storage server calls the mutual exclusion lock of the information queue, adds the data updating information in the data updating request into the information queue, and releases the mutual exclusion lock after adding.
This step 203 may include: when the data updating information is located at the designated position in the information queue, the storage server calls the mutual exclusion lock of the information queue, extracts the data updating information from the information queue, and releases the mutual exclusion lock after extraction.
The mutual exclusion lock can ensure that data updating information cannot be added to the information queue or extracted from the information queue as long as the mutual exclusion lock is in a called state, and the data updating information can be added or extracted only after the mutual exclusion lock is released.
Correspondingly, in the process that the storage server adds one piece of data updating information to the information queue, if the storage server receives other data updating requests, the data updating information in the data updating requests can be added to the information queue only after the addition process is finished, so that the data updating information in one data updating request can be added to the information queue at any time, and the conflict caused by adding a plurality of pieces of data updating information at the same time is avoided. Or, if a piece of data update information is to be extracted from the information queue, the data update information must be extracted after the adding process is finished, so that management confusion is avoided.
In the process of extracting a piece of data updating information from the information queue by the storage server, if the information queue comprises other data updating information, the data updating information can be extracted only after the extraction process is finished, so that only one piece of data updating information is extracted from the information queue at any moment, and the conflict caused by the fact that target data are updated simultaneously when a plurality of pieces of data updating information are extracted simultaneously is avoided. Or, if a piece of data update information is to be added to the information queue, the data update information must be added after the extraction process is finished, so that management confusion is avoided.
It should be noted that, the embodiment of the present invention is only described by taking the storage server as an execution subject, and actually, a receiving thread and an updating thread may be run in the storage server, where the receiving thread is used to receive a data updating request and add data updating information in the data updating request to the information queue, and the updating thread is used to extract data updating information from the information queue and update based on the extracted data updating information.
In the process of operation, the receiving thread may add the data update information to the information queue on the premise of successfully calling the mutex lock, and at this time, other threads may not be successfully called when trying to call the mutex lock, and may only call the mutex lock after the mutex lock is released. Or, the update thread may extract the data update information from the information queue on the premise that the call of the mutex lock is successful, and at this time, other threads may not be successfully called when trying to call the mutex lock, and may only call the mutex lock by waiting for the mutex lock to be released.
204. The storage server updates the corresponding target data based on the extracted data update information.
The storage server reads target data corresponding to the data identifier according to the data identifier, extracts a target field corresponding to the field identifier from the target data according to the field identifier, updates the target field according to the update information to obtain an updated target field, combines other fields except the target field in the target data with the updated target field to obtain updated target data, and stores the updated target data.
The format of the target data may be PB (Protocol Buffer) format, or other formats.
In one possible implementation, the update information includes an update type, and the storage server may update the target field according to the update type. Wherein the update type may be increasing a specified number, decreasing a specified number, deleting, etc.
For example, as shown in table 1, when a new user pays attention to the user, the amount of attention of the user should be increased by 1, and the data update request triggered at this time includes the user identifier "ID 1", the field identifier "amount of attention field", and the update type "+ 1", the storage server reads the user data according to the user identifier "ID 1", and increases 1 to the amount of attention field in the user data, and after the update, the amount of attention of the user changes from 300 to 301.
TABLE 1
In another possible implementation, the update information includes an updated target field. The storage server may directly replace the target field with the updated target field.
For example, as shown in table 1, when the user wishes to change the signature, the data update information in the triggered data update request includes the user identifier "ID 1", the field identifier "signature field", and the updated signature field "sequence 2", and then the storage server reads the user data according to the user identifier "ID 1", and modifies the signature field in the user data to "sequence 2".
It should be noted that the storage server may store the data by using a "key-value" data structure, where the data identifier may be a key, the target data may be a value, and the target data may include one or more fields. And, in order to distinguish different fields, the storage server sets a corresponding field identifier for each field.
In addition, the storage server may also format convert the target fields for updating. Specifically, the step 204 may include the following steps 2041-2043:
2041. and the storage server carries out deserialization on the target field to obtain a first field.
The storage server typically stores the target field in binary format, which is inconvenient to modify when the target field is in binary format. Thus, before performing the update, the storage server deserializes the target field, and converts the format of the target field into a modified format, such as a data structure, an object, etc., resulting in the first field.
2042. And the storage server updates the first field according to the updating information to obtain an updated second field.
In a first possible implementation manner, the update information includes an update type, and the storage server may update the first field according to the update type to obtain an updated second field.
In a second possible implementation manner, the update information includes an updated field, and the storage server may directly replace the first field with the updated field as the second field.
2043. And the storage server serializes the second field to obtain an updated target field.
Since the format of the second field is usually a format that is not convenient for storage, such as a data structure, an object, and the like, the storage server serializes the second field, converts the format of the second field into a format that is convenient for storage, such as a binary format, and obtains an updated target field.
205. And the storage server feeds the updated target data back to the service server.
206. And the service server receives the updated target data.
When the storage server updates the target data, the storage server may send a data update response message to the service server, where the data update response message includes the updated target data, so as to feed back the updated target data to the service server.
Further, when the storage server sends the updated target data to the service server, only the updated target field may be sent, that is, the data update response message includes the updated target field, and the service server may obtain the updated target field according to the data update response message.
In addition, the data update response message may include the data identification, or the data update response message may also include the data identification and the field identification. The service server can know that the updating is successful according to the data updating response message.
Specifically, the storage server may send a data update response message to the service server by calling an RPC interface with the service server, and the service server receives the data update response message sent by the storage server through the RPC interface.
In the embodiment of the present invention, if the data update request is sent to the service server by the terminal device, the service server may send the updated target data to the terminal device after receiving the data update response message, so as to ensure that the terminal device can obtain the updated target data in time. Further, after the terminal device obtains the updated target data, the updated target data can be provided for the user, so that the requirement that the user can obtain the updated result in time is met.
In the related art, when data stored in a storage server needs to be updated, the data is read from the storage server by a service server, and an update operation on the data is performed. When a plurality of data update requests received by the service server are all used for requesting to update the same target data, in order to avoid conflict among the plurality of data update requests, an "optimistic lock" mechanism may be set.
The "optimistic lock" mechanism refers to: after the service server reads the target data to be updated from the storage server, and updates the version number after the service server updates the target data, that is, the version number in the target data is replaced with the updated version number, for example, the version number is increased by 1. And then, the service server sends the updated target data to the storage server. After receiving the updated target data, the storage server acquires a version number in the updated target data, compares the version number with the version number of the target data in the storage server, stores the updated target data if the version number is newer than the version number of the target data in the storage server, and abandons the storage of the updated target data if the version number of the target data in the storage server is newer than the version number.
For example, when the version number of the target data is 1.0, and when a service server a and a service server B need to update the target data at the same time, both the service server a and the service server B read the target data, at this time, the service server a updates the target data first, and after modifying the version number to 2.0, stores the updated target data in the storage server. And then, after the service server B updates the target data and modifies the version number to 2.0, the storage server does not store the target data updated by the service server B because the version number on the storage server is the same as the version number updated by the service server B, so that the service server B fails to update. At this time, the service server B can only read the target data with the version number of 2.0 from the server again, and after the target data is updated, the version number is modified to 3.0, and the storage server will store the target data updated by the service server B.
With the related technology of the "optimistic lock" mechanism, when the number of data update requests for target data is large, the service server frequently faces the situation of update failure and continuously retries, and the process of retries will result in the waste of network resources.
In the embodiment of the present invention, a plurality of data update requests for the same target data are added to the same information queue for sorting, only one data update information is extracted from the information queue each time, and after the corresponding target data is updated according to the extracted data update information, the target data is updated again according to the next data update information in the information queue. And the adding and extracting processes can be carried out only after the mutual exclusion lock is called successfully, so that the conflict is avoided.
That is, by adopting a mechanism combining the "mutual exclusion lock" and the "queuing lock", it can be ensured that multiple data update requests for the same target data are queued for processing, thereby ensuring that multiple data update requests do not conflict with each other, avoiding the risk of repeated failure retry, reducing the overhead of network resources, and improving the efficiency of data update. Moreover, compared with an optimistic lock mechanism, the service server only needs to send a data updating request to the storage server once, so that the transmission times between the service server and the storage server are reduced, transmission resources are saved, the speed and efficiency of data updating are improved, and the problem of low performance in a high-conflict scene is solved.
The embodiment of the invention provides a queuing mechanism, which can sort the data updating information of a plurality of data updating requests according to the sorting information in an information queue by a storage server, thereby not only avoiding the conflict caused by the simultaneous updating of the same target data by a plurality of data updating requests, but also reducing the transmission times between the service server and the storage server, saving transmission resources and improving the speed and efficiency of data updating because the service server only needs to send the data updating request to the storage server once.
Further, in the related art, target data usually needs to be encoded and decoded to be transmitted between the service server and the storage server, but in the embodiment of the present invention, the storage server updates the target data stored in itself, which avoids a process of transmitting the target data to the service server, so that encoding and decoding are not required, and the efficiency of data update is improved.
Furthermore, by adopting a 'mutual exclusion lock' mechanism, the conflict is avoided, the network resource overhead is reduced, and the data updating efficiency is improved.
All the above optional technical solutions may be combined arbitrarily to form the optional embodiments of the present disclosure, and are not described herein again.
Fig. 3 is a schematic structural diagram of a data updating apparatus according to an embodiment of the present invention. The device is applied to a storage server, and referring to fig. 3, the device comprises: a receiving module 301, an adding module 302, an extracting module 303, an updating module 304 and a feedback module 305.
The receiving module 301 is configured to perform the receiving step in step 202 in the embodiment shown in fig. 2.
The adding module 302 is configured to perform the adding step in step 202 in the embodiment shown in fig. 2.
The extraction module 303 is configured to perform step 203 in the embodiment shown in fig. 2.
The update module 304 is used to execute step 204 in the embodiment shown in fig. 2.
The feedback module 305 is configured to perform step 205 in the embodiment shown in fig. 2.
Optionally, the extracting module 303 is further configured to extract the oldest time-stamped data update request from the information queue.
Optionally, the extracting module 303 is further configured to extract a data update request with the highest priority from the information queue.
Optionally, the adding module 302 includes a calling unit and a releasing unit.
The calling unit is used for calling the mutual exclusion lock of the information queue and adding the data updating information into the information queue, and the releasing unit is used for releasing the mutual exclusion lock.
Optionally, the extracting module 303 includes a calling unit and a releasing unit.
The calling unit is used for calling the mutual exclusion lock of the information queue and extracting the data updating information, and the releasing unit is used for releasing the mutual exclusion lock.
Optionally, the update module 304 includes: the device comprises a reading unit, an extracting unit, an updating unit and a combining unit.
The reading unit is used for reading target data, the extracting unit is used for extracting a target field, the updating unit is used for updating the target field, and the combining unit is used for combining other fields and the updated target field.
Optionally, the updating module 304 is configured to update the target field according to an update type, or replace the target field with an updated target field.
Optionally, the updating module 304 includes: the device comprises an deserializing unit, an updating unit and a serializing unit.
The deserializing unit is used for deserializing the target field, the updating unit is used for updating, and the serializing unit is used for serializing the second field.
Optionally, the receiving module 301 is further configured to receive the data update request through an RPC interface with the service server.
Optionally, the feedback module 305 is further configured to send a data update response message to the service server by calling an RPC interface with the service server, where the data update response message includes the updated target data.
Fig. 4 is a schematic structural diagram of a data updating apparatus according to an embodiment of the present invention. The device is applied to a service server, and referring to fig. 4, the device comprises: an acquisition module 401, a sending module 402 and a receiving module.
The obtaining module 401 is configured to perform the obtaining step in step 201 in the embodiment shown in fig. 2.
The sending module 402 is configured to execute the sending step in step 201 in the embodiment shown in fig. 2.
The receiving module 403 is configured to execute step 206 in the embodiment shown in fig. 2.
Optionally, the sending module 402 is further configured to call an RPC interface with the storage server to send the data update request.
Optionally, the receiving module 403 is further configured to receive, through an RPC interface with the storage server, a data update response message sent by the storage server, where the data update response message includes the updated target data.
It should be noted that: in the data updating apparatus provided in the foregoing embodiment, when updating data, only the division of the functional modules is illustrated, and in practical applications, the function distribution may be completed by different functional modules according to needs, that is, the internal structures of the storage server and the service server are divided into different functional modules, so as to complete all or part of the functions described above. In addition, the data updating apparatus provided in the above embodiments and the data updating method embodiments belong to the same concept, and specific implementation processes thereof are described in the method embodiments and are not described herein again.
Fig. 5 is a block diagram illustrating a data update apparatus 500 according to an example embodiment. For example, the apparatus 500 may be provided as a storage server or a business server. Referring to fig. 5, apparatus 500 includes a processing component 522 that further includes one or more processors and memory resources represented by memory unit 532 for storing data and possibly instructions executable by processing component 522, such as an application program. The application programs stored in the storage unit 532 may include one or more modules each corresponding to a set of instructions. Further, the processing component 522 is configured to execute instructions to perform the above-described data update method on data stored in the storage unit 532.
The apparatus 500 may also include a power component 526 configured to perform power management of the apparatus 500, a wired or wireless network interface 550 configured to connect the apparatus 500 to a network, and an input/output (I/O) interface 558. The apparatus 500 may operate based on an operating system stored in the storage unit 532, such as Windows ServerTM，Mac OS XTM，UnixTM，LinuxTM，FreeBSDTMOr the like.
The apparatus 500 may be used to perform the steps performed by the storage server and the service server in the above embodiments.
It will be understood by those skilled in the art that all or part of the steps for implementing the above embodiments may be implemented by hardware, or may be implemented by a program instructing relevant hardware, and the program may be stored in a computer-readable storage medium, and the above-mentioned storage medium may be a read-only memory, a magnetic disk or an optical disk, etc.
The above description is only exemplary of the present invention and should not be taken as limiting the invention, as any modification, equivalent replacement, or improvement made within the spirit and principle of the present invention should be included in the protection scope of the present invention.
Claims (25)
1. A data updating method is applied to a storage server, and the method comprises the following steps:
receiving a data updating request sent by a service server, wherein the data updating request comprises data updating information and sequencing information;
adding the data updating information in the data updating request to an information queue according to the sorting information;
when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
the data updating information includes a data identifier, a field identifier and updating information, the data identifier is used for determining target data to be updated, the field identifier is used for determining a target field to be updated in the target data, the updating information is used for determining an updating mode of the target field, and the corresponding target data is updated based on the extracted data updating information, including:
reading the target data corresponding to the data identification, and extracting the target field corresponding to the field identification from the target data;
updating the target field according to the updating information to obtain an updated target field;
combining other fields except the target field in the target data with the updated target field to obtain updated target data;
the updating the target field according to the update information to obtain an updated target field includes:
deserializing the target field to obtain a first field;
updating the first field according to the updating information to obtain an updated second field;
and serializing the second field to obtain the updated target field.
2. The method of claim 1, wherein the ordering information includes a timestamp indicating a time of receipt of the data update information, and wherein the information in the information queue is configured to be processed according to a first-in-first-out processing scheme, and wherein extracting the data update information from the information queue when the data update information is located in a specified position in the information queue comprises:
and when the data updating information is the data updating information with the earliest time stamp in the information queue, the data updating information is positioned at the first position in the information queue, and the data updating information is extracted from the information queue.
3. The method of claim 1, wherein the ordering information includes a priority, wherein the information in the information queue is configured to be processed in order of priority from high to low, and wherein extracting the data update information from the information queue when the data update information is located at a specified position in the information queue comprises:
and when the data updating information is the data updating information with the highest priority in the information queue, the data updating information is positioned at the first position in the information queue, and the data updating information is extracted from the information queue.
4. The method of claim 1, wherein the adding the data update information in the data update request to an information queue comprises:
calling a mutual exclusion lock of the information queue, and adding the data updating information into the information queue, wherein the mutual exclusion lock can be called only by one party;
and releasing the mutual exclusion lock after the data updating information is added to the information queue.
5. The method of claim 1, wherein extracting the data update information from the information queue when the data update information is located at a specified position in the information queue comprises:
when the data updating information is positioned at the designated position in the information queue, calling a mutual exclusion lock of the information queue, and extracting the data updating information from the information queue, wherein the mutual exclusion lock can be called only by one party;
and releasing the mutual exclusion lock after the data updating information is extracted from the information queue.
6. The method of claim 1, wherein the updating the target field according to the update information to obtain an updated target field comprises:
when the updating information comprises an updating type, updating the target field according to the updating type to obtain the updated target field; or,
and when the updated information comprises the updated target field, replacing the target field with the updated target field.
7. The method according to any one of claims 1-6, wherein the receiving the data update request sent by the service server comprises:
and receiving the data updating request through a remote procedure call protocol (RPC) interface between the service server and the service server.
8. The method according to any of claims 1-6, wherein the feeding back the updated target data to the service server comprises:
and sending a data updating response message to the service server by calling an RPC interface between the service server and the service server, wherein the data updating response message comprises the updated target data.
9. A data updating method is applied to a service server, and the method comprises the following steps:
acquiring data updating information and sequencing information;
sending a data updating request to a storage server, wherein the data updating request comprises the data updating information and the sorting information, and the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
the data updating information comprises data identification, field identification and updating information, wherein the data identification is used for determining target data to be updated, the field identification is used for determining a target field to be updated in the target data, and the updating information is used for determining an updating mode of the target field; the storage server is used for reading the target data corresponding to the data identification and extracting the target field corresponding to the field identification from the target data; updating the target field according to the updating information to obtain an updated target field; combining other fields except the target field in the target data with the updated target field to obtain updated target data;
the storage server is also used for performing deserialization on the target field to obtain a first field; updating the first field according to the updating information to obtain an updated second field; serializing the second field to obtain the updated target field;
and receiving the updated target data fed back by the storage server.
10. The method of claim 9, wherein sending a data update request to a storage server comprises:
and calling a remote procedure call protocol (RPC) interface between the remote procedure call server and the storage server, and sending the data updating request to the storage server.
11. The method according to claim 9 or 10, characterized in that the method further comprises:
and receiving a data updating response message sent by the storage server through an RPC interface between the storage server and the storage server, wherein the data updating response message comprises the updated target data.
12. A method for updating data, the method comprising:
the method comprises the steps that a service server sends a data updating request to a storage server, wherein the data updating request comprises data updating information and sequencing information;
when the storage server receives the data updating request, adding the data updating information in the data updating request to an information queue according to the sorting information; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue; updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
the data updating information includes a data identifier, a field identifier and updating information, the data identifier is used for determining target data to be updated, the field identifier is used for determining a target field to be updated in the target data, the updating information is used for determining an updating mode of the target field, and the corresponding target data is updated based on the extracted data updating information, including:
the storage server reads the target data corresponding to the data identification, and extracts the target field corresponding to the field identification from the target data; updating the target field according to the updating information to obtain an updated target field; combining other fields except the target field in the target data with the updated target field to obtain updated target data;
the updating the target field according to the update information to obtain an updated target field includes:
the storage server carries out deserialization on the target field to obtain a first field; updating the first field according to the updating information to obtain an updated second field; serializing the second field to obtain the updated target field;
and the service server receives the updated target data.
13. A data update apparatus, applied to a storage server, the apparatus comprising:
the system comprises a receiving module, a sending module and a receiving module, wherein the receiving module is used for receiving a data updating request sent by a service server, and the data updating request comprises data updating information and sequencing information;
the adding module is used for adding the data updating information in the data updating request to an information queue according to the sorting information;
the extracting module is used for extracting the data updating information from the information queue when the data updating information is positioned at a specified position in the information queue;
the updating module is used for updating the corresponding target data based on the extracted data updating information;
the feedback module is used for feeding back the updated target data to the service server;
the data updating information includes a data identifier, a field identifier and updating information, the data identifier is used for determining target data to be updated, the field identifier is used for determining a target field to be updated in the target data, the updating information is used for determining an updating mode of the target field, and the updating module includes:
the reading unit is used for reading the target data corresponding to the data identification;
an extracting unit, configured to extract the target field corresponding to the field identifier from the target data;
the updating unit is used for updating the target field according to the updating information to obtain an updated target field;
a combining unit, configured to combine the updated target field and other fields in the target data except for the target field to obtain updated target data;
the update module includes:
the deserializing unit is used for deserializing the target field to obtain a first field;
the updating unit is used for updating the first field according to the updating information to obtain an updated second field;
and the serialization unit is used for serializing the second field to obtain the updated target field.
14. The apparatus of claim 13, wherein the ordering information comprises a timestamp indicating a time of receipt of the data update information, the information in the information queue is configured to be processed according to a first-in-first-out processing mechanism, and the extracting module is further configured to extract the data update information from the information queue when the data update information is the data update information with the earliest timestamp in the information queue, and the data update information is located at the first position in the information queue.
15. The apparatus of claim 13, wherein the ordering information includes a priority, the information in the information queue is configured to be processed according to the priority from high to low, and the extracting module is further configured to extract the data update information from the information queue when the data update information is the data update information with the highest priority in the information queue, and the data update information is located first in the information queue.
16. The apparatus of claim 13, wherein the adding module comprises:
the calling unit is used for calling the mutual exclusion lock of the information queue and adding the data updating information into the information queue, and the mutual exclusion lock can be called only by one party;
and the releasing unit is used for releasing the mutual exclusion lock after the data updating information is added to the information queue.
17. The apparatus of claim 13, wherein the extraction module comprises:
the calling unit is used for calling a mutual exclusion lock of the information queue when the data updating information is positioned at a specified position in the information queue, and extracting the data updating information from the information queue, wherein the mutual exclusion lock can be called only by one party;
and the releasing unit is used for releasing the mutual exclusion lock after the data updating information is extracted from the information queue.
18. The apparatus of claim 13, wherein the updating unit is further configured to update the target field according to an update type when the update information includes the update type, so as to obtain the updated target field; or,
and when the updated information comprises the updated target field, replacing the target field with the updated target field.
19. The apparatus of any of claims 13-18, wherein the receiving module is further configured to receive the data update request through a remote procedure call protocol (RPC) interface with the service server.
20. The apparatus of any of claims 13-18, wherein the feedback module is further configured to send a data update response message to the service server by invoking an RPC interface with the service server, and wherein the data update response message includes the updated target data.
21. A data updating apparatus, applied in a service server, the apparatus comprising:
the acquisition module is used for acquiring data updating information and sequencing information;
the sending module is used for sending a data updating request to a storage server, wherein the data updating request comprises the data updating information and the sorting information, the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information, and the data in the information queue is configured to be processed according to a first-in first-out processing mechanism; extracting the data updating information from the information queue, updating corresponding target data based on the extracted data updating information, and feeding the updated target data back to the service server;
the data updating information comprises data identification, field identification and updating information, wherein the data identification is used for determining target data to be updated, the field identification is used for determining a target field to be updated in the target data, and the updating information is used for determining an updating mode of the target field; the storage server is used for reading the target data corresponding to the data identification and extracting the target field corresponding to the field identification from the target data; updating the target field according to the updating information to obtain an updated target field; combining other fields except the target field in the target data with the updated target field to obtain updated target data;
the storage server is also used for performing deserialization on the target field to obtain a first field; updating the first field according to the updating information to obtain an updated second field; serializing the second field to obtain the updated target field;
and the receiving module is used for receiving the updated target data fed back by the storage server.
22. The apparatus of claim 21, wherein the sending module is further configured to call a remote procedure call protocol (RPC) interface with the storage server to send the data update request to the storage server.
23. The apparatus according to claim 21 or 22, wherein the receiving module is further configured to receive a data update response message sent by the storage server through an RPC interface with the storage server, where the data update response message includes the updated target data.
24. A data update system, the system comprising:
the service server is used for sending a data updating request to the storage server, wherein the data updating request comprises data updating information and sequencing information;
the storage server is used for adding the data updating information in the data updating request to an information queue according to the sorting information when receiving the data updating request; when the data updating information is located at a designated position in the information queue, extracting the data updating information from the information queue; updating corresponding target data based on the extracted data updating information; feeding back the updated target data to the service server;
the data updating information comprises a data identifier, a field identifier and updating information, wherein the data identifier is used for determining target data to be updated, the field identifier is used for determining a target field to be updated in the target data, and the updating information is used for determining an updating mode of the target field;
the storage server is further configured to read the target data corresponding to the data identifier, and extract the target field corresponding to the field identifier from the target data; updating the target field according to the updating information to obtain an updated target field; combining other fields except the target field in the target data with the updated target field to obtain updated target data;
the storage server is further used for performing deserialization on the target field to obtain a first field; updating the first field according to the updating information to obtain an updated second field; serializing the second field to obtain the updated target field;
and the service server is also used for receiving the updated target data.
25. A computer-readable storage medium, comprising at least one instruction which is loaded and executed by a processor to perform operations performed by the data update method of any of claims 1 to 8; or, loaded and executed to implement the operations performed by the data update method of any of the preceding claims 9 to 11; or loaded and executed to implement the operations performed by the data update method of claim 12 above.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610933755.6A CN108023908B (en) | 2016-10-31 | 2016-10-31 | Data updating method, device and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610933755.6A CN108023908B (en) | 2016-10-31 | 2016-10-31 | Data updating method, device and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN108023908A CN108023908A (en) | 2018-05-11 |
| CN108023908B true CN108023908B (en) | 2020-04-24 |
Family
ID=62069625
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201610933755.6A Active CN108023908B (en) | 2016-10-31 | 2016-10-31 | Data updating method, device and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108023908B (en) |
Families Citing this family (16)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108829732B (en) * | 2018-05-16 | 2021-10-19 | 创新先进技术有限公司 | Data processing method and device |
| CN109167819B (en) * | 2018-08-13 | 2021-11-26 | 苏州科达科技股份有限公司 | Data synchronization system, method, device and storage medium |
| CN110928887A (en) * | 2018-09-19 | 2020-03-27 | 北京国双科技有限公司 | Data processing method and device |
| CN109542635A (en) * | 2018-10-17 | 2019-03-29 | 深圳壹账通智能科技有限公司 | Configuration information update method, apparatus, computer equipment and storage medium |
| CN109542636B (en) * | 2018-10-18 | 2020-12-25 | 新浪网技术(中国)有限公司 | Data updating method and device |
| CN109788053B (en) * | 2019-01-04 | 2022-04-29 | 深圳壹账通智能科技有限公司 | Data synchronization method and system |
| CN109933590B (en) * | 2019-03-19 | 2021-04-20 | 上海达梦数据库有限公司 | Data updating method, device, server and storage medium |
| CN110083612B (en) * | 2019-03-21 | 2021-09-17 | 北京三快在线科技有限公司 | Data updating method and device, electronic equipment and readable storage medium |
| CN112839067B (en) * | 2019-11-22 | 2022-07-22 | 腾讯科技（深圳）有限公司 | Data synchronization method and device |
| CN112835724A (en) * | 2019-11-25 | 2021-05-25 | 北京京东尚科信息技术有限公司 | A method and device for resolving message version conflict |
| CN111414259A (en) * | 2020-02-10 | 2020-07-14 | 北京声智科技有限公司 | Resource updating method, system, device, server and storage medium |
| CN111445157A (en) * | 2020-03-31 | 2020-07-24 | 深圳前海微众银行股份有限公司 | Service data management method, device, equipment and storage medium |
| CN111859200B (en) * | 2020-06-18 | 2024-05-14 | 口碑(上海)信息技术有限公司 | Method, device and equipment for updating mark of target object |
| CN113992754B (en) * | 2021-10-25 | 2023-12-22 | 北京恒安嘉新安全技术有限公司 | Policy updating method, device, equipment and medium of deep packet inspection equipment |
| CN113918586A (en) * | 2021-10-25 | 2022-01-11 | 金蝶软件（中国）有限公司 | Data updating method, device, equipment and storage medium |
| CN115623087B (en) * | 2022-11-21 | 2023-02-28 | 飞天诚信科技股份有限公司 | Method and system for analyzing PB format circulation data |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CA2292040C (en) * | 1999-03-25 | 2004-03-30 | International Business Machines Corporation | Interface system and method for asynchronously updating a shared resource |
| CN102012899A (en) * | 2009-09-07 | 2011-04-13 | 中国移动通信集团公司 | Method, system and equipment for updating data |
| CN103036717A (en) * | 2012-12-12 | 2013-04-10 | 北京邮电大学 | Consistency maintenance system and methods for distributed-type data |
| CN104243405A (en) * | 2013-06-08 | 2014-12-24 | 华为技术有限公司 | Request processing method, device and system |
| CN104331494A (en) * | 2014-11-17 | 2015-02-04 | 北京国双科技有限公司 | Method and system for updating data |
| US8965861B1 (en) * | 2012-06-28 | 2015-02-24 | Amazon Technologies, Inc. | Concurrency control in database transactions |
| CN104461707A (en) * | 2014-11-28 | 2015-03-25 | 华为技术有限公司 | Locking request processing method and device |
| CN104917813A (en) * | 2015-04-17 | 2015-09-16 | 小米科技有限责任公司 | Resource request method and device |
-
2016
- 2016-10-31 CN CN201610933755.6A patent/CN108023908B/en active Active
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CA2292040C (en) * | 1999-03-25 | 2004-03-30 | International Business Machines Corporation | Interface system and method for asynchronously updating a shared resource |
| CN102012899A (en) * | 2009-09-07 | 2011-04-13 | 中国移动通信集团公司 | Method, system and equipment for updating data |
| US8965861B1 (en) * | 2012-06-28 | 2015-02-24 | Amazon Technologies, Inc. | Concurrency control in database transactions |
| CN103036717A (en) * | 2012-12-12 | 2013-04-10 | 北京邮电大学 | Consistency maintenance system and methods for distributed-type data |
| CN104243405A (en) * | 2013-06-08 | 2014-12-24 | 华为技术有限公司 | Request processing method, device and system |
| CN104331494A (en) * | 2014-11-17 | 2015-02-04 | 北京国双科技有限公司 | Method and system for updating data |
| CN104461707A (en) * | 2014-11-28 | 2015-03-25 | 华为技术有限公司 | Locking request processing method and device |
| CN104917813A (en) * | 2015-04-17 | 2015-09-16 | 小米科技有限责任公司 | Resource request method and device |
Also Published As
| Publication number | Publication date |
|---|---|
| CN108023908A (en) | 2018-05-11 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108023908B (en) | Data updating method, device and system | |
| CN108388479B (en) | Delayed message pushing method and device, computer equipment and storage medium | |
| CN109491801B (en) | Micro-service access scheduling method, micro-service access scheduling device, medium and electronic equipment | |
| CN109032796B (en) | Data processing method and device | |
| CN112445626B (en) | Data processing method and device based on message middleware | |
| CN113485822A (en) | Memory management method, system, client, server and storage medium | |
| CN110413822B (en) | Offline image structured analysis method, device and system and storage medium | |
| WO2021104178A1 (en) | Dynamic message pushing method and system and vehicle diagnosis server | |
| CN113127564B (en) | Parameter synchronization method and device | |
| WO2021212965A1 (en) | Resource scheduling method and related device | |
| US20150304264A1 (en) | Context aware serialization | |
| CN113722056A (en) | Task scheduling method and device, electronic equipment and computer readable medium | |
| CN112015816A (en) | Data synchronization method, device, medium and electronic equipment | |
| CN111478781B (en) | Message broadcasting method and device | |
| CN113761001A (en) | A cross-system data synchronization method and device | |
| CN114928636B (en) | Interface call request processing method, device, equipment, storage medium and product | |
| CN112306695A (en) | Data processing method and device, electronic equipment and computer storage medium | |
| CN112671816B (en) | File downloading method, device, equipment and medium | |
| CN111880910A (en) | Data processing method and device, server and storage medium | |
| CN110109865A (en) | A kind of date storage method, device, equipment and readable storage medium storing program for executing | |
| CN113761052A (en) | Database synchronization method and device | |
| CN113783913A (en) | A message push management method and device | |
| CN117333170A (en) | Service processing method, device, electronic equipment and storage medium | |
| CN107634916B (en) | Data communication method and device | |
| CN115454666A (en) | Data synchronization method and device among message queue clusters |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |