Communication system, queue management server, and communication method

Patent metadata

Field	Value
Publication number	US-2016234129-A1
Application number	US-201615012262-A
Country	US
Kind code	A1
Filing date	Feb 1, 2016
Priority date	Feb 5, 2015
Publication date	Aug 11, 2016
Grant date	—

Abstract

Provided is a communication system capable of sending and receiving signals. The communication system includes a plurality of data store servers each including a queue capable of storing signals and a queue management server capable of allocating signals to the plurality of data store servers. The queue management server holds distribution policy information that specifies policies to allocate signals to the plurality of data store servers. The queue management server is configured to determine to allocate a plurality of received signals to one queue in one of the plurality of data store servers based on the distribution policy information when the plurality of signals include in-order guarantee keys indicating that the plurality of signals are in need of in-order guarantee and the in-order guarantee keys of the plurality of signals are identical.

First claim

What is claimed is:

1 . A communication system capable of sending and receiving signals, the communication system comprising:
a plurality of data store servers each including a queue capable of storing signals; and a queue management server capable of allocating signals to the plurality of data store servers, wherein the queue management server holds distribution policy information that specifies policies to allocate signals to the plurality of data store servers, and wherein the queue management server is configured to determine to allocate a plurality of received signals to one queue in one of the plurality of data store servers based on the distribution policy information when the plurality of signals include in-order guarantee keys indicating that the plurality of signals are in need of in-order guarantee and the in-order guarantee keys of the plurality of signals are identical.

2 . The communication system according to claim 1 ,
wherein each of the plurality of data store servers holds queue management information that indicates number and storage order of signals stored in the queue, wherein a data store server is configured to:
update the queue management information when a signal is allocated to a queue in the data store server; and
output a signal stored to the queue at an earliest time to the queue management server with reference to the queue management information upon receipt of a request to acquire a signal from the queue from the queue management server.

3 . The communication system according to claim 2 ,
wherein the plurality of data store servers each include a pre-update queue to be used before the plurality of data store servers are updated in number and a post-update queue to be used after the data store servers are updated in number, and wherein the queue management server is configured to determine to change where to allocate signals to the post-update queues when the queue management server is notified of update in number of the plurality of data store servers after determining to allocate signals to the pre-update queues.

4 . The communication system according to claim 3 , wherein the queue management server is configured to:
determine whether the pre-update queues include any signal upon receipt of a request to acquire a signal after determining to change where to allocate signals to the post-update queues; and acquire a signal from one of the pre-update queues when the pre-update queues include at least one signal.

5 . The communication system according to claim 4 ,
wherein the queue management information in each data store server indicates number of signals stored in the pre-update queue and number of signals stored in the post-update queue, wherein the queue management server is configured to:
acquire the queue management information from the plurality of data store servers for multiple times; and
output data to display the number of signals stored in the pre-update queues and the number of signals stored in the post-update queues in chronological order based on the acquired queue management information.

6 . The communication system according to claim 5 , wherein the queue management server is configured to:
acquire the queue management information at predetermined intervals; and determine whether the pre-update queues include any signal based on the queue management information.

7 . The communication system according to claim 3 ,
wherein the communication system comprises a plurality of queue management servers, wherein the plurality of data store servers includes a representative data store server, wherein the representative data store server holds agreement information to indicate whether the plurality of queue management servers are in agreement with update of the system, wherein each of the plurality of queue management servers is configured to:
update the agreement information when the queue management server agrees with the update in number of the plurality of data store servers notified of; and
determine to change where to allocate signals to the post-update queues when the agreement information indicates that all the plurality of queue management servers are in agreement with the update of the system.

8 . The communication system according to claim 1 , further comprising a message server capable of including in-order guarantee keys in signals,
wherein the queue management server is configured to receive the signals including the order-guarantee keys from the message server.

9 . A queue management server capable of sending and receiving signals and allocating the received signals to a plurality of data store servers each including a queue capable of storing signals,
the queue management server comprising a memory, wherein the memory holds distribution policy information that specifies policies to allocate signals to the plurality of data store servers, and wherein the queue management server is configured to determine to allocate a plurality of signals to one queue in one of the plurality of data store servers based on the distribution policy information when the plurality of received signals include in-order guarantee keys indicating that the plurality of signals are in need of in-order guarantee and the in-order guarantee keys of the plurality of signals are identical.

10 . The queue management server according to claim 9 , wherein the queue management server is configured to determine to change where to allocate signals to post-update queues held in the plurality of data store servers when the queue management server is notified of update of the plurality of data store servers in number after determining to allocate signals to pre-update queues held in the plurality of data servers.

11 . The queue management server according to claim 10 , wherein the queue management server is configured to:
determine whether the pre-update queues include any signal when the queue management server receives a request to acquire a signal after determining to change where to allocate signals to the post-update queues; and acquire a signal from one of the pre-update queues when the pre-update queues include at least one signal.

12 . The queue management server according to claim 11 , wherein the queue management server is configured to:
acquire queue management information that is held in each of the plurality of data store servers and indicates number of signals stored in a pre-update queue and number of signals stored in a post-update queue from the plurality of data store servers for a plurality of times; and output data to display the number of signals stored in the pre-update queues and the number of signals stored in the post-update queues in chronological order based on the acquired queue management information.

13 . The queue management server according to claim 12 , wherein the queue management server is configured to:
acquire the queue management information at predetermined intervals; and determine whether the pre-update queues include any signal based on the queue management information.

14 . The queue management server according to claim 10 , wherein the queue management server is configured to:
update agreement information held by a representative data store server in the plurality of data store servers when the queue management server agrees with the update in number of the plurality of data store servers notified of; and determine to change where to allocate signals to the post-update queues when the agreement information indicates that all queue management servers inclusive of the queue management server are in agreemen

Assignees

• Hitachi Ltd

Inventors

• Konoura Hiroaki
• Kinoshita Masafumi
• Koike Takafumi
• Kamiya Toshiyuki

Classifications

• G06F9/546 Primary

  Message passing systems or structures, e.g. queues · CPC title

• H04L47/781 Primary

  Centralised allocation of resources · CPC title

• H04L41/12

  Discovery or management of network topologies · CPC title

• G06F2209/548

  Queue · CPC title