In recent years, with the development of the Internet and communication devices, the numbers of pieces of data and amounts of message data transmitted from personal smart devices are also increasing. In a system that processes these message data, it is necessary to construct a system by using distributed data storage in order to improve extensibility and serviceability of the system.
A distributed processing type message queue system that stores message data in distributed data storages and processes message data in a distributed manner includes a plurality of message queue servers, for example. Each message queue server includes a storage device that stores message data. The plurality of message queue servers share storage devices and provide a message queue for each storage device between a client and a service providing server.
As the plurality of message queue servers share storage devices with one another, large-capacity storage can be implemented. In addition, the storage capacity can be easily increased by adding a message queue server. Also, serviceability can be improved by duplicating message data between message queue servers.
There is a related technique disclosed in Patent Literature 1. The PTL 1 discloses a technique for controlling a processing order based on correlation between different messages within a same message queue.