对海量数据进行实时计算,并保证数据不重不丢