2023 年的 Node.js 生態(tài)系統(tǒng)
隨著技術(shù)的不斷演進(jìn)和創(chuàng)新，Node.js 在 2023 年達(dá)到了一個(gè)新的高度。Node.js 擁有一個(gè)龐大的生態(tài)系統(tǒng)，可以幫助開發(fā)人員更快地實(shí)現(xiàn)復(fù)雜的應(yīng)用。本文就來(lái)看看 Node.js 最新的生
相信很多的小伙伴在面試的時(shí)候，涉及到MQ的面試題，消息丟失是必問面試題之一。那么對(duì)于消息丟失你又是如何理解的呢？
下面我們一起來(lái)看一下。
本文以 Kafka 舉例說明。
消息丟失的定義是：在消息傳遞的過程中，在某個(gè)環(huán)節(jié)意外丟失，也就是消息沒有成功的發(fā)送或者沒有被正確的接收。
生產(chǎn)者未能成功發(fā)送消息。
消費(fèi)者未能正確接收消息。
消費(fèi)者未能正確處理消息。
對(duì)于第三條可以理解為特殊的消息丟失，因?yàn)橄M(fèi)者的邏輯處理錯(cuò)誤，程序bug等其他原因，造成消息在處理過程中消息丟失或者被忽略（異常之后錯(cuò)誤的應(yīng)答等），也就是說消息沒有正確的被消費(fèi)掉，我們也可以認(rèn)為是一種消息丟失。
(1) 配置正確的主體、分區(qū)、以及TTL。
(2) 使用ACK應(yīng)答，等待消息被MQ寫入成功之后在確認(rèn)為發(fā)送成功。
(3) 消息發(fā)送重試。
(4) 配置合理的壓縮策略。
(5) 設(shè)置合理的消息緩沖區(qū)大小。
(6) 使用合適的序列化器，防止序列號(hào)錯(cuò)誤造成消息丟失。
其他的配置可以參考官網(wǎng) Kafka 生產(chǎn)者配置：https://kafka.apache.org/documentation/#producerconfigs
(1) 編寫健壯的代碼，說的容易，寫起來(lái)還是得多測(cè)試。對(duì)于可能產(chǎn)生的異常原因進(jìn)行分析處理。當(dāng)發(fā)生異常時(shí)，可以做如下處理：
(2) 使用手動(dòng)提交偏移量。（需保證所有的異常情況代碼中都有對(duì)應(yīng)的異常處理機(jī)制，也就是第一點(diǎn)，健壯的代碼）
(3) 使用自動(dòng)提交偏移量。（需要保證消費(fèi)邏輯正確）
(4) 使用監(jiān)控，監(jiān)控消費(fèi)者的消費(fèi)情況，發(fā)現(xiàn)異常立即上報(bào)。
(5) 正確的消費(fèi)者組管理，類似消費(fèi)者重平衡或者重啟等造成的消息偏移量丟失。
(6) 備份，發(fā)生異常或者消息丟失時(shí)，可以跟蹤到消費(fèi)者的消費(fèi)情況，直接使用備份恢復(fù)。
上面我們分析了什么是消息丟失，產(chǎn)生的原因有哪些以及如何解決。通過看完這篇文章相信你對(duì)Kafka中的消息丟失也有了一定的了解，在工作中使用的時(shí)候也就不會(huì)沒有底氣了。
相信有眼尖的小伙伴發(fā)現(xiàn)了，在消費(fèi)者的處理邏輯中，多次消費(fèi)會(huì)造成消息的多次重復(fù)消費(fèi)。消息的重試也有可能造成消息的堆積。那么這些問題就是下節(jié)課我們要說的。
本文鏈接：http://www.www897cc.com/showinfo-26-92457-0.html面試官：對(duì)于 MQ 中的消息丟失你是如何理解的？
聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)