The invention discloses a message reliable
processing guarantee method of a real-time flow calculating
frame based on
Storm. The method comprises the steps: 1, in a preprocessing phase, initialization work is carried out on an environment; 2, data which have already been sent and are in a calculating state are tracked in a cluster calculation process; 3, when an emission task monitors a
signal that the
message processing is successful, tracking information of all sub-tuples which belong to the task in a cache region are emptied; 4, when the emission task monitors a
signal that the
message processing is unsuccessful, the position of the task producing the
processing failure and data to be recovered are located; 5, a message
recovery program is constructed according to the tracking information and
xml files, the data to be recovered are read from the cache region, and the message
recovery program is executed; 6, the cache region is emptied, and a memory space is released. According to the method, when a message is recovered, large-scale repetitive computation existing in a complex topology business is avoided, the calculated amount of message
recovery is effectively reduced, the performance of
processing data under the whole business scene is promoted, and the
low delay requirement of real-
time processing can be ensured.