Method, device, and system for information processing based on distributed buses

Patent metadata

Field	Value
Publication number	US-9537786-B2
Application number	US-201414263960-A
Country	US
Kind code	B2
Filing date	Apr 28, 2014
Priority date	Nov 29, 2012
Publication date	Jan 3, 2017
Grant date	Jan 3, 2017

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.

First claim

What is claimed is:

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 a plurality of connection requests from a plurality of client terminals respectively;
establishing connection between the server and the plurality of client terminals respectively in response to the plurality of connection requests;
establishing respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server;
receiving one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server;
entering the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets;
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 respectively;
storing the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding 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 , further comprising:
marking the plurality of client terminals that have established connection with the server as connected; and
marking the one or more client terminals that have established communication sessions with the server as in communication.

3. The method of claim 1 , 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 one or more information items selected from a group consisting of a packet length, a checksum for verification, a unique identifier of a client, a command word representing a server requested by a client terminal, a sequence number of a request data packet, a header body, a connection state identifier, and a source IP address of a client terminal.

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 programs stored in the memory and configured for execution by the one or more processors, the one or more programs include instructions for:
receiving a plurality of connection requests from a plurality of client terminals respectively;
establishing connection between the server and the plurality of client terminals respectively in response to the plurality of requests for connection;
establishing respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server;
receiving one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server;
entering the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets;
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 respectively,
storing the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding information processing thread; and
transmitting the response data packets within a respective output information queue to a corresponding client terminal.

12. The computer system of claim 11 , wherein the one or more programs further include instructions for:
marking the plurality of client terminals that have established connection with the server as connected; and
marking the one or more client terminals that have established communication sessions with the server as in communication.

13. The computer system of claim 11 , wherein the one or more programs further include instructions for:
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 com

Assignees

• Tencent Tech Shenzhen Co Ltd

Inventors

• Lin Aimin
• Zhang Qian

Classifications

• G06F9/547 Primary

  Remote procedure calls [RPC]; Web services · CPC title

• H04L47/522 Primary

  Dynamic queue service slot or variable bandwidth allocation · CPC title

• G06F2209/548

  Queue · CPC title