Data processing method and system

• US 9,357,027 B2
• Filed: 10/28/2013
• Issued: 05/31/2016
• Est. Priority Date: 10/29/2012
• Status: Active Grant

• Current Assignee: Tencent Technology Company Limited (Tencent Holdings Limited)
• Original Assignee: Tencent Technology Company Limited (Tencent Holdings Limited)
• Inventors: Wang, Hui
• Primary Examiner(s): NANO, SARGON N
• Application Number:
  US14/439,580
• Publication Number:
  US 20150296036A1
• Time in Patent Office: 946 Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24552 Database cache management
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/306 User profiles
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

A data processing system relates to network communications technologies. A data buffering layer receives an operation request of a follower of a user having a long relation and of a client. The data buffer layer pushes the operation request to a service layer. The service layer receives the operation request pushed by the data buffering layer and caches the operation request according to a minimum storage unit. The minimum storage unit is determined by using the user having a long relation chain as a unit. The service layer determines a specified database that belongs to the user having a long relation chain and performs an operation on the specified database according to the operation request. The service layer determines the specified database according to a preset routing configuration when data cached in the minimum storage unit reaches a preset condition.

Claims

1. A data processing method, the method comprising:

receiving, by a data buffering layer, an operation request of a follower of a user, having a long relation chain, of a client, and pushing the operation request to a service layer;

receiving, by the service layer, the operation request pushed by the data buffering layer, and caching the operation request according to a minimum storage unit, the minimum storage unit being divided by using the user having a long relation chain as a unit; and

finding, by the service layer according to a preset routing configuration when data cached in the minimum storage unit reaches a preset condition, a specified database that belongs to the user having a long relation chain, and performing an operation on the specified database according to the operation request;

wherein the pushing the operation request to a service layer comprises;

calculating, by the data buffering layer, a minimum operating unit of the user having a long relation chain, and routing the operation request to the minimum operating unit of the service layer;

wherein the receiving, by the service layer, the operation request pushed by the data buffering layer, and caching the operation request according to a minimum storage unit comprises;

receiving, by a receiving process at the service layer, the operation request pushed by the data buffering layer, and caching a log of the operation request to the minimum operating unit; and

reading, by a storage process at the service layer, the minimum operating unit to obtain the operation request in the minimum operating unit, calculating the minimum storage unit of the operation request, and caching the operation request to the minimum storage unit.

2. The method according to claim 1, wherein after the receiving, by a receiving process at the service layer, the operation request pushed by the data buffering layer, and caching a log of the operation request to the minimum operating unit, the method further comprises:

adding, by the receiving process, one cumulatively to a synchronization sequence number of the minimum operating unit, wherein the synchronization sequence number is used for identifying a synchronization progress between the receiving process and the data buffering layer.

3. The method according to claim 2, wherein the reading, by a storage process at the service layer, the minimum operating unit to obtain the operation request in the minimum operating unit comprises:

reading, by the storage process, the synchronization sequence number of the minimum operating unit in the receiving process, determining whether the synchronization sequence number of the minimum operating unit is greater than a locally stored reading sequence number of the minimum operating unit, and reading the operation request in the minimum operating unit if the synchronization sequence number is greater than the locally stored reading sequence number, wherein the reading sequence number is used for identifying a synchronization progress between the storage process and the receiving process.

4. A terminal, the terminal comprising:

a touch screen display, one or more processors, a memory, and one or more programs, the one or more programs being stored in the memory and configured to be executed by the one or more processors, and the one or more programs containing an instruction used for performing the following operations;

receiving, by a data buffering layer, an operation request of a follower of a user, having a long relation chain, of a client, and pushing the operation request to a service layer;

receiving, by the service layer, the operation request pushed by the data buffering layer, and caching the operation request according to a minimum storage unit, the minimum storage unit being divided by using the user having a long relation chain as a unit; and

finding, by the service layer according to a preset routing configuration when data cached in the minimum storage unit reaches a preset condition, a specified database that belongs to the user having a long relation chain, and performing an operation on the specified database according to the operation request;

the terminal comprising an instruction used for performing the following operations;

calculating, by the data buffering layer, a minimum operating unit of the user having a long relation chain, and routing the operation request to the minimum operating unit of the service layer;

the terminal comprising an instruction used for performing the following operations;

receiving, by a receiving process at the service layer, the operation request pushed by the data buffering layer, and

caching a log of the operation request to the minimum operating unit; and

reading, by a storage process at the service layer, the minimum operating unit to obtain the operation request in the minimum operating unit, calculating the minimum storage unit of the operation request, and caching the operation request to the minimum storage unit.

5. The terminal according to claim 4, comprising an instruction used for performing the following operation:

adding, by the receiving process, one cumulatively to a synchronization sequence number of the minimum operating unit, wherein the synchronization sequence number is used for identifying a synchronization progress between the receiving process and the data buffering layer.

6. The terminal according to claim 5, comprising an instruction used for performing the following operations:

reading, by the storage process, the synchronization sequence number of the minimum operating unit in the receiving process, determining whether the synchronization sequence number of the minimum operating unit is greater than a locally stored reading sequence number of the minimum operating unit, and reading the operation request in the minimum operating unit if the synchronization sequence number is greater than the locally stored reading sequence number, wherein the reading sequence number is used for identifying a synchronization progress between the storage process and the receiving process.

7. A non-transitory computer readable storage medium, the computer readable storage medium storing one or more programs, the one or more programs being used for executing a data processing method by one or more processors, and the method comprising:

receiving, by a data buffering layer, an operation request of a follower of a user, having a long relation chain, of a client, and pushing the operation request to a service layer;

receiving, by the service layer, the operation request pushed by the data buffering layer, and caching the operation request according to a minimum storage unit, the minimum storage unit being divided by using the user having a long relation chain as a unit; and

finding, by the service layer according to a preset routing configuration when data cached in the minimum storage unit reaches a preset condition, a specified database that belongs to the user having a long relation chain, and performing an operation on the specified database according to the operation request;

wherein the pushing the operation request to a service layer comprises;

calculating, by the data buffering layer, a minimum operating unit of the user having a long relation chain, and routing the operation request to the minimum operating unit of the service layer;

wherein the receiving, by the service layer, the operation request pushed by the data buffering layer, and caching the operation request according to a minimum storage unit comprises;

receiving, by a receiving process at the service layer, the operation request pushed by the data buffering layer, and caching a log of the operation request to the minimum operating unit; and

reading, by a storage process at the service layer, the minimum operating unit to obtain the operation request in the minimum operating unit, calculating the minimum storage unit of the operation request, and caching the operation request to the minimum storage unit.

8. The non-transitory computer readable storage medium according to claim 7, wherein after the receiving, by a receiving process at the service layer, the operation request pushed by the data buffering layer, and caching a log of the operation request to the minimum operating unit, the method further comprises:

adding, by the receiving process, one cumulatively to a synchronization sequence number of the minimum operating unit, wherein the synchronization sequence number is used for identifying a synchronization progress between the receiving process and the data buffering layer.

9. The non-transitory computer readable storage medium according to claim 8, wherein the reading, by a storage process at the service layer, the minimum operating unit to obtain the operation request in the minimum operating unit comprises:

reading, by the storage process, the synchronization sequence number of the minimum operating unit in the receiving process, determining whether the synchronization sequence number of the minimum operating unit is greater than a locally stored reading sequence number of the minimum operating unit, and reading the operation request in the minimum operating unit if the synchronization sequence number is greater than the locally stored reading sequence number, wherein the reading sequence number is used for identifying a synchronization progress between the storage process and the receiving process.