鴻蒙OS 4.0公測機型公布：甚至連nova6都支持
華為全新的HarmonyOS 4.0操作系統將于今天下午正式登場，官方在發布會之前也已經正式給出了可升級的機型產品，這意味著這些機型會率先支持升級享用。這次的HarmonyOS 4.0支持
相信很多的小伙伴在面試的時候，涉及到MQ的面試題，消息丟失是必問面試題之一。那么對于消息丟失你又是如何理解的呢？
下面我們一起來看一下。
本文以 Kafka 舉例說明。
消息丟失的定義是：在消息傳遞的過程中，在某個環節意外丟失，也就是消息沒有成功的發送或者沒有被正確的接收。
生產者未能成功發送消息。
消費者未能正確接收消息。
消費者未能正確處理消息。
對于第三條可以理解為特殊的消息丟失，因為消費者的邏輯處理錯誤，程序bug等其他原因，造成消息在處理過程中消息丟失或者被忽略（異常之后錯誤的應答等），也就是說消息沒有正確的被消費掉，我們也可以認為是一種消息丟失。
(1) 配置正確的主體、分區、以及TTL。
(2) 使用ACK應答，等待消息被MQ寫入成功之后在確認為發送成功。
(3) 消息發送重試。
(4) 配置合理的壓縮策略。
(5) 設置合理的消息緩沖區大小。
(6) 使用合適的序列化器，防止序列號錯誤造成消息丟失。
其他的配置可以參考官網 Kafka 生產者配置：https://kafka.apache.org/documentation/#producerconfigs
(1) 編寫健壯的代碼，說的容易，寫起來還是得多測試。對于可能產生的異常原因進行分析處理。當發生異常時，可以做如下處理：
(2) 使用手動提交偏移量。（需保證所有的異常情況代碼中都有對應的異常處理機制，也就是第一點，健壯的代碼）
(3) 使用自動提交偏移量。（需要保證消費邏輯正確）
(4) 使用監控，監控消費者的消費情況，發現異常立即上報。
(5) 正確的消費者組管理，類似消費者重平衡或者重啟等造成的消息偏移量丟失。
(6) 備份，發生異常或者消息丟失時，可以跟蹤到消費者的消費情況，直接使用備份恢復。
上面我們分析了什么是消息丟失，產生的原因有哪些以及如何解決。通過看完這篇文章相信你對Kafka中的消息丟失也有了一定的了解，在工作中使用的時候也就不會沒有底氣了。
相信有眼尖的小伙伴發現了，在消費者的處理邏輯中，多次消費會造成消息的多次重復消費。消息的重試也有可能造成消息的堆積。那么這些問題就是下節課我們要說的。
本文鏈接：http://www.www897cc.com/showinfo-26-92457-0.html面試官：對于 MQ 中的消息丟失你是如何理解的？
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號