Metering data management system and computer readable recording medium

A metering data management system comprising:

• a first buffer server having a first buffer and a second buffer;
• a second buffer server having the second buffer and a third buffer;
• A third buffer server having the third buffer and the first buffer;
• a metering data transmission module configured to collect first, second, and third pieces of metering data, generate a first message containing the first piece of metering data and first topic information, transmit the first message to the first buffer, generate a second message containing the second piece of metering data and second topic information, transmit the second message to the second buffer, generate a third message containing the third piece of metering data and third topic information, and transmit the third message to the third buffer;
• a metering data processing module configured to determine a topic of a piece of metering data, which is to be processed, extract the first piece of metering data from one of the first and second buffer servers when the determined topic corresponds to the first topic information, extract the second piece of metering data from one of the second and third buffer servers when the determined topic corresponds to the second topic information, and extract the third piece of metering data from one of the third and the first buffer servers when the determined topic corresponds to the third topic information;
• and
• a broker server configured to determine a buffer server, from which the metering data processing module is going to extract the piece of metering data, among the first to third of buffer servers on the basis of state information of the first to third of buffer servers,
• wherein the meter data processing module includes:
• a plurality of processing servers, each of which receives plurality of different assigned topics, configured to extract and process the piece of metering data from a buffer to which a topic the same as the assigned topic is assigned;
• and
• a master processing server configured to determine a topic of the piece of metering data, which is to be processed in some of the plurality of processing servers, and assign the determined topic to some of the plurality of processing servers on the basis of state information of the plurality of processing servers.

A non-transitory computer-readable recording medium having instructions stored thereon for execution by a processor to perform:

• collecting a piece of metering data;
• identifying the piece of metering data and generating topic information corresponding to the piece of metering data;
• generating a message containing the piece of metering data and the topic information;
• transmitting the message to a buffer server, corresponding to the topic information, among a plurality of buffer servers, each of which has a plurality of buffers to which different topics are assigned;
• determining a topic of the piece of metering data which is to be processed;
• assigning the determined topic to some of a plurality of processing servers on the basis of stat information of the plurality of processing servers;
• and
• determining a buffer server, to transmit the piece of metering data to some of the plurality of processing servers, among the plurality of buffer servers on the basis of state information of the plurality of buffer servers, extracting and processing the piece of metering data from a buffer to which a topic the same as the assigned topic is assigned in the buffer server.