消息关闭
    暂无新消息!

消息队列处理临界时间问题

问题作者 : 龙社2017-05-01发布

现在从消息队列接收消息,然后写入文件。每小时写一个,是批量写入。但是出现个问题,每次写的新文件开头都有一些应该属于上个小时得数据,消息体有time。如何保证所有消息都严格写入自己小时得文件。现在想到的是将批量写入的buffer按小时区分,Map<hour,buffer>,一个buffer对应一个小时,以buffer 对应的小时字段生成文件名,这样就保证每个buffer 里的数据都属于自己的文件。还有其他更好的方法吗?


2个回答