METHOD, DEVICE, AND SYSTEM FOR INFORMATION PROCESSING BASED ON DISTRIBUTED BUSES

• US 20140233584A1
• Filed: 04/28/2014
• Published: 08/21/2014
• Est. Priority Date: 11/29/2012
• Status: Active Grant

• Current Assignee: Tencent Technology Company Limited (Tencent Holdings Limited)
• Original Assignee: Tencent Technology Company Limited (Tencent Holdings Limited)
• Inventors: LIN, Aimin, ZHANG, Qian
• Granted Patent: US 9,537,786 B2
• Time in Patent Office: Days
• US Class Current: 370/420
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services
• CPC Class Codes: H04L 47/522 Dynamic queue service slot or variable bandwidth allocation

Abstract

The present application discloses methods, devices, and systems for information processing based on distributed buses. A server may receive processing request packets from one or more client terminals and enter the processing request packets into a single input information queue. After determining a number of idle information processing threads, the server may use the idle information processing threads to process the selected processing request packets to obtain response data packets. Each information processing thread is configured to use a respective output information queue to store response data packets generated by the information processing thread. The server may then transmit the response data packets within a respective output information queue to a corresponding client terminal. The current method, as well as the devices and systems associated with the method, may be used to facilitate information processing, improve efficiency, and prevent excessive burden and data loss.

Claims

1. A method for information processing based on distributed buses, the method comprising:

at a server having one or more processors and memory storing programs executed by the one or more processors,

receiving processing request packets from one or more client terminals and entering the processing request packets into a single input information queue;

determining a number of idle information processing threads;

selecting, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads;

using the idle information processing threads to process the selected processing request packets to obtain response data packets, wherein each information processing thread is configured to use a respective output information queue to store response data packets generated by the information processing thread; and

transmitting the response data packets within a respective output information queue to a corresponding client terminal.

2. The method of claim 1, wherein the step of receiving processing request packets from one or more client terminals comprises:

connecting to the one or more client terminals and marking the client terminals as connected;

establishing communication sessions with the connected client terminals and marking the client terminals as in communication; and

receiving processing request packets from the one or more client terminals in communication.

3. The method of claim 2, wherein the step of establishing communication sessions comprises:

determining if any communication channels are idle;

if any communication channels are idle, establishing the active communication sessions using the idle communication channels; and

if no communication channel is idle, allowing the connected client terminals to queue for an idle communication channel and marking the client terminals as waiting in queue.

4. The method of claim 3, further comprising:

when a client terminal in communication is disconnected abnormally, switching the communication channel with the abnormally disconnected client terminal to a protected status.

5. The method of claim 4, further comprising:

determining if any connected client terminal is associated with a communication channel having a protected status; and

if a connected client terminal is associated with a communication channel having a protected status, establishing the communication session with the client terminal using the communication channel.

6. The method of claim 2, further comprising:

after receiving a communication request from a client terminal having a new connection, determining whether the client terminal is in an established communication session; and

if the client terminal is in an established communication session, terminating the association between the established communication session and an old connection and associating the new communication session with the new connection.

7. The method of claim 1, wherein:

the processing request packets are based on binary data protocols.

8. The method of claim 7, wherein:

the packet headers of the processing request packets have a format of;

9. The method of claim 1, further comprising:

determining if the server is capable of performing a processing request included in the processing request packet; and

transferring the processing request packet if the server is not capable of performing the processing request.

10. The method of claim 1, wherein before the step of transmitting the response data packets to the one or more client terminals, the method further comprises:

extracting the response data packets from the output information queues.

11. A computer system based on distributed buses, the computer system comprising:

one or more processors;

memory; and

one or more program modules stored in the memory and configured for execution by the one or more processors, the one or more program modules including;

a receiving module configured to receive processing request packets from one or more client terminals and enter the processing request packets into a single input information queue;

a processing module configured to;

determine a number of idle information processing threads,

select, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads, and

use the idle information processing threads to process the selected processing request packets to obtain response data packets, wherein each information processing thread is configured to use a respective output information queue to store response data packets generated by the information processing thread; and

a transferring module configured to transmit the response data packets within a respective output information queue to a corresponding client terminal.

12. The computer system of claim 11, wherein the receiving module comprises:

a connection unit configured to connect the computer system to the one or more client terminals and marking the client terminals as connected; and

a communication session unit configured to establish communication sessions with the connected client terminals and marking the client terminals as in communication, wherein the computer system receives processing request packets from the one or more client terminals in communication.

13. The computer system of claim 12, wherein the communication sessions unit is further configured to:

determine if any communication channels are idle;

if any communication channels are idle, establish the active communication sessions using the idle communication channels; and

if no communication channel is idle, allow the connected client terminals to queue for an idle communication channel and marking the client terminals as waiting in queue.

14. The computer system of claim 12, wherein the communication session unit is further configured to:

determine whether the client terminal is in an established communication session after receiving a communication request from a client terminal having a new connection, and

if the client terminal is in an established communication session, terminate the association between the established communication session and an old connection and associate the new communication session with the new connection.

15. The computer system of claim 11, wherein:

the processing request packets are based on binary data protocols.

16. The computer system of claim 11, wherein the receiving module is further configured to:

determine if the server is capable of performing a processing request included in the processing request packet; and

transfer the processing request packet if the server is not capable of performing the processing request.

17. The computer system of claim 11, wherein the transferring module is further configured to:

extract the response data packets from the output information queues before transmitting the response data packets to the one or more client terminals.

18. The computer system of claim 11, further comprising:

a storage module configured to store the input information queue and the output information queue.

19. The computer system of claim 11, further comprising:

a setup module configured to set up a maximum connection number and a maximum communication session number, wherein;

the maximum connection number reflects the maximum number of simultaneous connections between the computer system and the client terminals, and

the maximum communication session number reflects the maximum number of simultaneous communication sessions between the computer system and the client terminals.

20. A non-transitory computer readable storage medium having stored therein instructions, which, when executed by a computer system, cause the computer system to:

receive processing request packets from one or more client terminals and enter the processing request packets into a single input information queue;

determine a number of idle information processing threads;

select, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads; and

use the idle information processing threads to process the selected processing request packets to obtain response data packets, wherein each information processing thread is configured to use a respective output information queue to store response data packets generated by the information processing thread;

transmit the response data packets within a respective output information queue to a corresponding client terminal.