MESSAGE PROCESSING SYSTEM AND MESSAGE PROCESSING METHOD

• US 20130013702A1
• Filed: 07/08/2011
• Published: 01/10/2013
• Est. Priority Date: 07/08/2011
• Status: Active Grant

• Current Assignee: GREE Inc.
• Original Assignee: GREE Inc.
• Inventors: Ebisawa, Satoshi, Doi, Masayuki
• Granted Patent: US 10,277,452 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: G06F 11/0703 Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
• CPC Class Codes: G06F 11/0709 in a distributed system consisting of a plurality of standalone computer nodes, e.g. clusters, client-server systems
• CPC Class Codes: G06F 11/0784 Routing of error reports, e.g. with a specific transmission path or data flow
• CPC Class Codes: G06F 15/16 Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs coordinating program control therefor G06F9/52; in regulating and control system G05B
• CPC Class Codes: H04L 41/0604 using filtering, e.g. reduction of information by using priority, element types, position or time
• CPC Class Codes: H04L 41/0609 based on severity or priority
• CPC Class Codes: H04L 43/0817 by checking functioning
• CPC Class Codes: H04L 67/55 Push-based network services
• CPC Class Codes: H04L 69/40 for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection management of faults, events, alarms or notifications in data switching networks H04L41/06

Abstract

A message processing system with improved maintainability, while ensuring availability, is provided. A filtering section 131 determines a degree of importance of an error message transmitted from a monitoring target server 110 and performs a process of filtering. A queue 121 receives the error message after the process of filtering by the filtering section 131 and transmits the error message to all summarizing sections 132. The summarizing section 132 then performs a process of summarizing for summarizing error messages of the same type as to the error messages after the process of filtering by the filtering section 131. A topic 122 receives the error message after the process of summarizing from one summarizing section 132. The topic 122 then selects one mail transmitting section from mail transmitting sections 133 informing by e-mail transmission about the error message after the process of summarizing by the summarizing section 132, and transmits the error message to the selected mail transmitting section 133.

Claims

1. A message processing system for receiving a message from a publisher server and performing a process depending on the received message, comprising:

a message delivering apparatus connected to the publisher server; and

two or more message processing apparatuses connected to the message delivering apparatus,

wherein the message processing apparatus comprises;

a message processing unit for processing a message transmitted from the publisher server and received via the message delivering apparatus;

a representative determining unit for determining whether or not the message processing unit provided in its own apparatus is a representative by comparing predetermined information set in its own apparatus with predetermined information set in the other message processing apparatus or the other message processing apparatuses; and

an informing unit for sending a notice depending on the message processed by the message processing unit when the representative determining unit determines the message processing unit as a representative,

and the message delivering apparatus comprises;

a first broadcast unit for transmitting a message received from the publisher server to all the message processing apparatuses; and

a second broadcast unit for transmitting information of the message processing unit, received from the representative determining unit, to the other message processing apparatus or all the other message processing apparatuses except the message processing apparatus having transmitted the information.

2. The message processing system according to claim 1, wherein the message processing unit comprises a summarizing process unit for performing a process of summarizing where messages of the same type are summarized among messages received via the message delivering apparatus.

3. The message processing system according to claim 1, wherein the message processing unit comprises a filtering process unit for filtering a message received via the message delivering apparatus.

4. The message processing system according to claim 3, wherein the filtering process unit performs a process of filtering depending on a degree of importance of the message received via the message delivering apparatus.

5. The message processing system according to claim 3, wherein the message processing unit further comprises a summarizing process unit for summarizing messages of the same type among messages received via the message delivering apparatus based on a result of filtering processed by the filtering process unit.

6. The message processing system according to claim 5, wherein the message delivering apparatus further comprises a selecting/transmitting unit for selecting one of the message processing apparatuses and transmitting a message received from the publisher server to the filtering process unit provided in the selected message processing apparatus, and

the filtering processing unit provided in the selected message processing apparatus performs the process of filtering to the message received via the selecting/transmitting unit and transmits the message after the process of filtering to the first broadcast unit.

7. The message processing system according to claim 1, wherein the publisher apparatus is a target server for monitoring a failure and the message is an error message including a content of a failure having occurred in the server.

8. The message processing system according to claim 1, wherein the predetermined information is an IP address of the message processing apparatus, and

the representative determining unit compares an IP address set in the other message processing apparatus or the other message processing apparatuses with an IP address set in its own apparatus and determines the message processing unit provided in its own message processing apparatus as a representative when a predetermined value included in the IP address set in its own apparatus corresponds to a predetermined condition.

9. The message processing system according to claim 1, wherein the informing unit informs a person in charge of failure about a message processed by the message processing unit by using e-mail.

10. A message processing method for receiving a message from a publisher server and performing a process depending on the received message,

a message delivering apparatus connected to the publisher server and comprising a first broadcast unit and a second broadcast unit,

two or more message processing apparatuses connected to the message delivering apparatus and comprising a message processing unit, a representative determining unit and an informing unit,

the method comprising the steps of:

the first broadcast unit transmitting a message received from the publisher server to all the message processing apparatuses;

the message processing unit processing the message received from the first broadcast unit;

the second broadcast unit transmitting information of the message processing unit, received from the representative determining unit, to the other message processing apparatus or all the other message processing apparatuses except the message processing apparatus having transmitted the information;

the representative determining unit deter inning whether or not the message processing unit provided in its own apparatus is a representative by comparing predetermined information set in its own apparatus with predetermined information set in the other message processing apparatus or the other message processing apparatuses; and

the informing unit sending a notice depending on a message processed by the message processing unit when the representative determining unit determines the message processing unit as a representative.