問題描述

現在從消息隊列接收消息，然后寫入文件。每小時寫一個，是批量寫入。但是出現個問題，每次寫的新文件開頭都有一些應該屬于上個小時得數據，消息體有time。如何保證所有消息都嚴格寫入自己小時得文件。現在想到的是將批量寫入的buffer按小時區分，Map<hour,buffer>，一個buffer對應一個小時，以buffer 對應的小時字段生成文件名，這樣就保證每個buffer 里的數據都屬于自己的文件。還有其他更好的方法嗎？

問題解答

文件在小時整點生成，每個消息都帶上各自的時間戳，匹配寫

感覺你這個問題可能有以下幾個原因造成的：

producer重復發送了消息

mq重復發送了消息給consumer

前一小時consumer沒有告知mq已經消費消息，導致后一個小時mq又發送了消息

參考資料：

duplicated-messages-on-activemq

avoiding-duplicated-messages-on-jms-activemq

duplicate-detection