文章詳情頁
java - 消息隊列處理臨界時間問題
瀏覽:178日期:2023-11-28 08:05:45
問題描述
現在從消息隊列接收消息,然后寫入文件。每小時寫一個,是批量寫入。但是出現個問題,每次寫的新文件開頭都有一些應該屬于上個小時得數據,消息體有time。如何保證所有消息都嚴格寫入自己小時得文件。現在想到的是將批量寫入的buffer按小時區分,Map<hour,buffer>,一個buffer對應一個小時,以buffer 對應的小時字段生成文件名,這樣就保證每個buffer 里的數據都屬于自己的文件。還有其他更好的方法嗎?
問題解答
回答1:文件在小時整點生成,每個消息都帶上各自的時間戳,匹配寫
回答2:感覺你這個問題可能有以下幾個原因造成的:
producer重復發送了消息
mq重復發送了消息給consumer
前一小時consumer沒有告知mq已經消費消息,導致后一個小時mq又發送了消息
參考資料:
duplicated-messages-on-activemq
avoiding-duplicated-messages-on-jms-activemq
duplicate-detection
標簽:
java
相關文章:
1. 關于docker下的nginx壓力測試2. 關docker hub上有些鏡像的tag被標記““This image has vulnerabilities””3. mac里的docker如何命令行開啟呢?4. docker - 各位電腦上有多少個容器啊?容器一多,自己都搞混了,咋辦呢?5. nignx - docker內nginx 80端口被占用6. docker容器呢SSH為什么連不通呢?7. angular.js使用$resource服務把數據存入mongodb的問題。8. 如何解決Centos下Docker服務啟動無響應,且輸入docker命令無響應?9. docker start -a dockername 老是卡住,什么情況?10. dockerfile - 我用docker build的時候出現下邊問題 麻煩幫我看一下
排行榜

網公網安備