Empfangen Sie nun Nachrichten aus der Nachrichtenwarteschlange und schreiben Sie sie dann in eine Datei. Schreiben Sie jede Stunde einen, was einem Batch-Schreibvorgang entspricht. Aber jedes Mal, wenn eine neue Datei geschrieben wird, gibt es am Anfang einige Daten, die zur vorherigen Stunde gehören sollten, und der Nachrichtentext hat Zeit. So stellen Sie sicher, dass alle Nachrichten ausschließlich in Ihre eigenen Dateien geschrieben werden. Was mir jetzt einfällt, ist, die in Stapel geschriebenen Puffer nach Stunden aufzuteilen, Map<hour,buffer>, ein Puffer entspricht einer Stunde und der Dateiname wird basierend auf dem Stundenfeld generiert, das dem Puffer entspricht Die Daten in jedem Puffer gehören zu sich selbst. Gibt es einen anderen besseren Weg?