Now receive messages from the message queue and then write them to the file. Write one every hour, which is a batch write. But there is a problem. Every time a new file is written, there is some data at the beginning that should belong to the previous hour, and the message body has time. How to ensure that all messages are strictly written to your own files. What I think of now is to divide the buffers written in batches by hour, Map<hour,buffer>, one buffer corresponds to one hour, and the file name is generated based on the hour field corresponding to the buffer, so as to ensure that the data in each buffer belongs to itself. document. Is there any other better way?