日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

面試官:對于 MQ 中的消息丟失你是如何理解的?

來源: 責編: 時間:2024-06-06 17:39:06 216觀看
導讀相信很多的小伙伴在面試的時候,涉及到MQ的面試題,消息丟失是必問面試題之一。那么對于消息丟失你又是如何理解的呢?下面我們一起來看一下。本文以 Kafka 舉例說明。一、什么是消息丟失?消息丟失的定義是:在消息傳遞的過程

相信很多的小伙伴在面試的時候,涉及到MQ的面試題,消息丟失是必問面試題之一。那么對于消息丟失你又是如何理解的呢?lX128資訊網——每日最新資訊28at.com

下面我們一起來看一下。lX128資訊網——每日最新資訊28at.com

本文以 Kafka 舉例說明。lX128資訊網——每日最新資訊28at.com

lX128資訊網——每日最新資訊28at.com

lX128資訊網——每日最新資訊28at.com

一、什么是消息丟失?

消息丟失的定義是:在消息傳遞的過程中,在某個環節意外丟失,也就是消息沒有成功的發送或者沒有被正確的接收。lX128資訊網——每日最新資訊28at.com

生產者未能成功發送消息。lX128資訊網——每日最新資訊28at.com

lX128資訊網——每日最新資訊28at.com

消費者未能正確接收消息。lX128資訊網——每日最新資訊28at.com

lX128資訊網——每日最新資訊28at.com

消費者未能正確處理消息。lX128資訊網——每日最新資訊28at.com

lX128資訊網——每日最新資訊28at.com

對于第三條可以理解為特殊的消息丟失,因為消費者的邏輯處理錯誤,程序bug等其他原因,造成消息在處理過程中消息丟失或者被忽略(異常之后錯誤的應答等),也就是說消息沒有正確的被消費掉,我們也可以認為是一種消息丟失。lX128資訊網——每日最新資訊28at.com

二、消息丟失的原因有哪些

1.消息生產階段

  • 生產者配置錯誤:生產者在發送消息時,配置錯誤的主體、分區或者消息的過期時間,造成消息無法正確發送到MQ中。
  • 網絡故障:生產者與MQ集群之間網絡故障。

2.消息存儲階段

  • 磁盤故障:以Kafka舉例,如果磁盤出現故障,Kafka中的消息無法洛盤,可能導致消息的丟失。
  • 日志壓縮策略:使用了壓縮比較高的壓縮策略從而可能在壓縮的過程中丟失消息。

3.消息消費階段

  • 消費者處理失?。涸谔幚硐M邏輯時,由于程序bug等原因,造成系統異常,錯誤應答從而丟失消息。
  • 消費者提交偏移量錯誤:當消費者消費完消息之后,提交錯誤的偏移量造成消息的重復消費或者消息丟失。

三、消息丟失的解決方案有哪些

1.消息生產階段

(1) 配置正確的主體、分區、以及TTL。lX128資訊網——每日最新資訊28at.com

(2) 使用ACK應答,等待消息被MQ寫入成功之后在確認為發送成功。lX128資訊網——每日最新資訊28at.com

  • ack=1:默認值,leader副本成功寫入消息即發送成功。
  • ack=0:發送消息后不等待服務端確認。
  • ack=-1或者ack=all:生產者需要等待ISR中的所有副本都成功寫入消息才為消息發送成功。

(3) 消息發送重試。lX128資訊網——每日最新資訊28at.com

  • retries:配置生產者發送消息重試次數。

(4) 配置合理的壓縮策略。lX128資訊網——每日最新資訊28at.com

  • compression.type 支持none、gzip、snappy、lz4、zstd。

(5) 設置合理的消息緩沖區大小。lX128資訊網——每日最新資訊28at.com

  • buffer.memory:默認33554432。生產者用于緩存一批發送到服務器消息的總內存字節數。

(6) 使用合適的序列化器,防止序列號錯誤造成消息丟失。lX128資訊網——每日最新資訊28at.com

其他的配置可以參考官網 Kafka 生產者配置:https://kafka.apache.org/documentation/#producerconfigslX128資訊網——每日最新資訊28at.com

2.消息存儲階段

  • 配置適當的副本數量和ISR。在發生故障的時候消息仍然可以從其他的副本中進行恢復。
  • 使用監控,實時檢測消息的復制、磁盤的使用率。
  • 定期備份。

3.消息消費階段

(1) 編寫健壯的代碼,說的容易,寫起來還是得多測試。對于可能產生的異常原因進行分析處理。當發生異常時,可以做如下處理:lX128資訊網——每日最新資訊28at.com

  • 記錄錯誤,有異常處理機制,保證能夠正確的處理異常情況。
  • 消息重試消息。(需要注意消費冪等以及死循環造成消息堆積)

(2) 使用手動提交偏移量。(需保證所有的異常情況代碼中都有對應的異常處理機制,也就是第一點,健壯的代碼)lX128資訊網——每日最新資訊28at.com

(3) 使用自動提交偏移量。(需要保證消費邏輯正確)lX128資訊網——每日最新資訊28at.com

(4) 使用監控,監控消費者的消費情況,發現異常立即上報。lX128資訊網——每日最新資訊28at.com

(5) 正確的消費者組管理,類似消費者重平衡或者重啟等造成的消息偏移量丟失。lX128資訊網——每日最新資訊28at.com

(6) 備份,發生異常或者消息丟失時,可以跟蹤到消費者的消費情況,直接使用備份恢復。lX128資訊網——每日最新資訊28at.com

總結

上面我們分析了什么是消息丟失,產生的原因有哪些以及如何解決。通過看完這篇文章相信你對Kafka中的消息丟失也有了一定的了解,在工作中使用的時候也就不會沒有底氣了。lX128資訊網——每日最新資訊28at.com

相信有眼尖的小伙伴發現了,在消費者的處理邏輯中,多次消費會造成消息的多次重復消費。消息的重試也有可能造成消息的堆積。那么這些問題就是下節課我們要說的。lX128資訊網——每日最新資訊28at.com

本文鏈接:http://m.www897cc.com/showinfo-26-92457-0.html面試官:對于 MQ 中的消息丟失你是如何理解的?

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 面試官:對于MQ中的消息堆積你是怎么理解的?

下一篇: 記一次 .NET某工控視覺自動化系統卡死分析

標簽:
  • 熱門焦點
Top 日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不
久久精品国产免费看久久精品| 亚洲第一在线综合网站| 欧美人与性动交cc0o| 欧美视频一区在线观看| 国产精品视频xxx| 狠狠色综合色区| 亚洲高清精品中出| 亚洲视频观看| 久久久久久穴| 欧美日本韩国| 国产精品一区二区久久国产| 一区二区三区在线视频免费观看| 亚洲三级国产| 欧美一二三视频| 欧美成人激情视频| 国产精品免费在线| 亚洲国产欧美另类丝袜| 亚洲一区二区三区乱码aⅴ| 久久九九精品99国产精品| 欧美精品入口| 国产偷国产偷精品高清尤物| 最新亚洲电影| 性伦欧美刺激片在线观看| 欧美成人在线免费观看| 国产精品日韩精品欧美精品| 亚洲高清激情| 午夜久久一区| 欧美日韩高清不卡| 狠狠色丁香久久综合频道 | 先锋影院在线亚洲| 欧美极品一区二区三区| 国产亚洲精品美女| 欧美日本高清视频| 国产日韩精品电影| 亚洲精品社区| 久久精品国产亚洲a| 欧美午夜www高清视频| 亚洲成人在线视频播放| 午夜日韩电影| 欧美日韩亚洲在线| 亚洲国产日韩在线一区模特| 欧美一区91| 欧美视频1区| 91久久亚洲| 久久久久成人网| 国产精品欧美日韩一区| 99re亚洲国产精品| 美女主播视频一区| 国产一区二区黄| 亚洲欧美成人网| 欧美日韩午夜| 亚洲美女诱惑| 久久综合999| 国产亚洲一本大道中文在线| 亚洲制服少妇| 欧美视频日韩视频在线观看| 亚洲三级网站| 久久先锋影音| 韩国三级电影一区二区| 午夜精品免费在线| 欧美性猛交视频| 91久久国产自产拍夜夜嗨| 久久日韩粉嫩一区二区三区 | 日韩香蕉视频| 欧美黄色aa电影| 亚洲国产精品一区在线观看不卡| 久久久久久有精品国产| 国产一区自拍视频| 欧美一区二区女人| 国产亚洲精品aa午夜观看| 性欧美video另类hd性玩具| 国产精品久久久久久久久免费樱桃| 99国产精品99久久久久久粉嫩| 欧美国产精品v| 亚洲欧洲一区二区天堂久久 | 美女日韩欧美| 亚洲国产成人91精品| 老司机免费视频一区二区三区| 激情综合网激情| 久久久久欧美精品| 一区在线播放视频| 久久综合国产精品台湾中文娱乐网| 伊人久久男人天堂| 两个人的视频www国产精品| 亚洲大片一区二区三区| 欧美二区在线看| 亚洲美女av在线播放| 欧美视频一区二区三区在线观看| 亚洲午夜精品视频| 国产精品日韩欧美一区二区| 亚洲欧美国产一区二区三区| 国产伦精品一区二区三区视频孕妇| 欧美一级二级三级蜜桃| 国语自产精品视频在线看抢先版结局 | 欧美黄色大片网站| 91久久久久久国产精品| 欧美精品成人| 一区二区激情视频| 欧美日韩一区在线视频| 亚洲一区www| 国产日产欧产精品推荐色| 久久精品国产91精品亚洲| 激情视频亚洲| 欧美激情偷拍| 亚洲一级黄色片| 国产亚洲欧美日韩日本| 久久深夜福利免费观看| 亚洲精品乱码| 国产精品久久综合| 久久成人免费| 亚洲国产精品传媒在线观看 | 亚洲一区在线观看免费观看电影高清| 国产精品一区二区欧美| 久久精品亚洲乱码伦伦中文| 亚洲高清自拍| 欧美手机在线视频| 久久国产精品久久精品国产| 最近中文字幕日韩精品| 国产精品久久久久高潮| 久久精品日韩一区二区三区| 亚洲黑丝在线| 国产精品爽黄69| 免费一级欧美片在线观看| 一区二区三区av| 国产一区高清视频| 欧美日本中文字幕| 欧美一区二区视频网站| 亚洲国产精品热久久| 国产精品高精视频免费| 久久青草久久| 正在播放日韩| 一色屋精品亚洲香蕉网站| 欧美三级黄美女| 久久久久久尹人网香蕉| 一本高清dvd不卡在线观看| 国内精品视频在线播放| 欧美日韩亚洲一区二区三区| 久久久久久久久久码影片| 一本一本a久久| 黄色工厂这里只有精品| 欧美日韩亚洲一区三区| 看欧美日韩国产| 亚洲免费视频成人| 亚洲黄色一区二区三区| 国产欧美精品一区二区色综合 | 国产精品午夜在线观看| 免费久久99精品国产自在现线| 亚洲伊人色欲综合网| 亚洲第一精品影视| 国产欧美日韩精品丝袜高跟鞋 | 久久久人成影片一区二区三区观看| 99re热这里只有精品免费视频| 狠狠88综合久久久久综合网| 欧美色另类天堂2015| 美腿丝袜亚洲色图| 欧美一级专区免费大片| 日韩一区二区电影网| 永久免费精品影视网站| 国产精品视频yy9299一区| 欧美精品九九99久久| 久久久久久久久岛国免费| 亚洲午夜羞羞片| 亚洲精品中文字幕有码专区| 狠狠狠色丁香婷婷综合激情| 国产精品草草| 欧美精品久久久久久| 久久久久久一区二区| 新狼窝色av性久久久久久| 一区二区欧美日韩| 亚洲国产成人在线| 狠狠色综合日日| 国产女主播在线一区二区| 欧美视频国产精品| 欧美精品一区二区三区一线天视频 | 欧美激情免费在线| 久久久噜噜噜久噜久久| 亚洲欧美中文另类| 一区二区三区久久网| 亚洲国产欧美日韩| 伊人色综合久久天天| 国产综合香蕉五月婷在线| 国产精品夜夜夜| 欧美日韩综合在线| 欧美精品在线观看播放| 欧美不卡激情三级在线观看| 久久久久久久一区二区| 欧美在线视频a| 欧美亚洲在线| 亚洲欧美视频在线观看| 亚洲永久免费视频| 亚洲一区二区三区影院| 一区二区三区日韩欧美| 日韩一级视频免费观看在线| 91久久久久久久久久久久久| 亚洲高清视频在线| 亚洲大胆人体在线| 亚洲国产精品第一区二区三区| 在线播放中文一区| 在线精品亚洲| 1024亚洲| 亚洲国产一区二区视频| 亚洲国产精品热久久| 亚洲国产日本| 亚洲日本欧美|