RabbitMQ高級篇-MQ的可靠性

目錄

MQ的可靠性

1.如何設置數據持久化

1.1.交換機持久化

1.2.隊列持久化

1.3.消息持久化

2.消息持久化

隊列持久化:

消息持久化:

3.非消息持久化

非持久化隊列:

非持久化消息:

4.消息的存儲機制

4.1持久化消息(Persistent Messages)

4.2非持久化消息(Transient Messages)

4.3關鍵區別

4.4總結


之前的文章我們介紹了RabbitMQ的發送者的可靠性,接下來我來向大家講解MQ的可靠性

發送者的可靠性文章

MQ的可靠性

消息到達MQ以后,如果MQ不能及時保存,也會導致消息丟失,所以MQ的可靠性也非常重要。

1.如何設置數據持久化

為了提升性能,默認情況下MQ的數據都是在內存存儲的臨時數據,重啟后就會消失。為了保證數據的可靠性,必須配置數據持久化,包括:

  • 交換機持久化

  • 隊列持久化

  • 消息持久化

我們以控制臺界面為例來說明。

持久化:數據存儲在磁盤,服務宕機了,數據也不會丟失。

非持久化:數據存儲在內存,服務宕機了,數據也就不在了

1.1.交換機持久化

在控制臺的Exchanges頁面,添加交換機時可以配置交換機的Durability參數:

設置為Durable就是持久化模式,Transient就是臨時模式。

1.2.隊列持久化

在控制臺的Queues頁面,添加隊列時,同樣可以配置隊列的Durability參數:

1.3.消息持久化

在控制臺發送消息的時候,可以添加很多參數,而消息的持久化是要配置一個properties

Non-persistent:消息非持久化 Persistent:消息持久化

2.消息持久化

消息持久化是為了確保即使 RabbitMQ 服務重啟或崩潰,消息也不會丟失。它主要包括以下幾個步驟:

  1. 隊列持久化

    • 當創建隊列時,如果指定了隊列的持久化屬性(durable=true),那么該隊列會被寫入磁盤。即使 RabbitMQ 服務重啟,該隊列仍然存在。

    • 但如果隊列中沒有消息或消息沒有被持久化,隊列重啟后將是空的。

  2. 消息持久化

    • 當發送消息時,如果指定了消息的持久化屬性(delivery_mode=2),那么消息會被寫入磁盤。即使 RabbitMQ 服務重啟,消息仍然存在,直到被消費者消費。

    • 消息的持久化和隊列的持久化需要同時設置,否則消息仍然可能丟失。例如,如果隊列沒有設置持久化,即使消息設置了持久化,隊列在重啟后也會消失,消息也就隨之丟失。

3.非消息持久化

非持久化消息主要用于某些場景下,如消息的可靠性要求不高,或者需要快速傳輸大量消息。它主要包括以下幾個步驟:

  1. 非持久化隊列

  • 當創建隊列時,如果沒有指定隊列的持久化屬性(durable=false),那么該隊列不會被寫入磁盤。如果 RabbitMQ 服務重啟,該隊列將消失。
  1. 非持久化消息

  • 當發送消息時,如果沒有指定消息的持久化屬性(delivery_mode=1),那么消息不會被寫入磁盤。如果 RabbitMQ 服務重啟,消息將丟失。

4.消息的存儲機制

4.1持久化消息(Persistent Messages)

  • In Memory:持久化消息會被緩存在內存中,以便快速處理。

  • Persistent:這些消息同時也會被寫入磁盤進行持久化存儲。即使RabbitMQ服務重啟,持久化消息也不會丟失,因為它們在磁盤上有副本。

4.2非持久化消息(Transient Messages)

  • In Memory:非持久化消息同樣會被緩存在內存中。

  • Paged Out:當內存資源緊張時,RabbitMQ會將部分非持久化消息從內存換出到磁盤。這些消息被換出到磁盤后,如果內存壓力減輕,可能會被換回內存。但與持久化消息不同的是,非持久化消息在磁盤上沒有持久化副本,因此在RabbitMQ服務重啟時,這些消息不會被恢復。

4.3關鍵區別

  • 持久化消息:內存中的數據是緩存,同時在磁盤上有持久化副本,以確保數據不會丟失。

  • 非持久化消息:內存中的數據是主要存儲位置,磁盤上的數據只是在內存壓力下的一種臨時存儲方式,并不用于持久化。

4.4總結

  • 持久化消息:內存和磁盤上都有數據,磁盤上的數據用于持久化。

  • 非持久化消息:內存和磁盤上都有數據,但磁盤上的數據只是臨時的,不用于持久化。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/diannao/83143.shtml
繁體地址,請注明出處:http://hk.pswp.cn/diannao/83143.shtml
英文地址,請注明出處:http://en.pswp.cn/diannao/83143.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

ctfshow權限維持

1,web670 我們先看一下這個php代碼 error_reporting(0);#關閉錯誤報告 highlight_file(__FILE__);#內容高亮顯示$a$_GET[action];#get傳參switch($a){case cmd:eval($_POST[cmd]);break;case check:file_get_contents("http://checker/api/check");#獲取…

力扣算法ing(71 / 100)

5.15 哈希表合集—349.兩個數組的交集 給定兩個數組 nums1 和 nums2 ,返回 它們的 交集 。輸出結果中的每個元素一定是 唯一 的。我們可以 不考慮輸出結果的順序 。 示例 1: 輸入:nums1 [1,2,2,1], nums2 [2,2] 輸出:[2]示例…

(面試)Handler消息處理機制原理

Handler是用于實現線程間通信和任務調度的一種機(Handler、 Looper、MessageQueue、 Message)。Handler 允許線程間發送Message或Runnable對象進行通信。在Android中UI修改只能通過UI Thread,子線程不能更新UI。如果子線程想更新UI&#xff0…

Dify 實戰教程 | 5分鐘打造文本生成應用( Stable Diffusion 提示詞生成器)

AI 繪畫離不開「提示詞(Prompt)」——如何構造清晰、生動、有表現力的提示詞,直接決定你生成圖像的質量。而 Stable Diffusion 的提示詞構造相比 Midjourney 更加自由,但也更考驗組織語言的能力。 今天這篇教程,教你零…

RPC框架源碼分析學習(二)

RPC框架源碼分析與原理解讀 前言 在分布式系統開發中,遠程過程調用(RPC)是一項基礎且關鍵的技術。通過對KVstorageBaseRaft-cpp項目RPC模塊的源碼分析,我深入理解了RPC框架的工作原理和實現細節。本文將從程序員視角分享我的學習心得。 框架概述 本項…

當下流行的智能體通信協議:MCP、A2A、ANP 分別是什么?

在當前人工智能(AI)智能體生態系統中,智能體之間的有效溝通至關重要。為了讓AI智能體能夠高效、安全地協同工作,業界提出了多種通信協議。其中,MCP、A2A 和 ANP 代表了三個關鍵層級的通信協議,各自應對不同…

為什么 cout<<“中文你好“ 能正常輸出中文

一, 簡答: 受python3字符串模型影響得出的下文C字符串模型結論 是錯的!C的字符串和python2的字符串模型類似,也就是普通的字符串是ASCII字符串和字節串兩種語義,類似重載或多態,有時候解釋為整數,有時候是字節串。Uni…

鴻蒙的卓易通,讓我踩了一次坑

前言 因為我本身對鴻蒙提不起興趣,哪怕有些文章給鴻蒙穿上了“黑絲”,再加上公司當前沒有適配鴻蒙的計劃,所以關于鴻蒙的消息我都關注的很少。 今早,看到了徐宜生老師的一篇文章:“鴻蒙卓易通,是飲鴆止渴…

Cursor vs VS Code vs Zed

代碼編輯器的世界已經迎來了創新的爆發。曾經由重量級IDE或基礎文本編輯器主導的領域,如今開發者們發現自己正在探索全新一波聚焦于AI集成、協作和性能的工具。 在本文中,我們將深入探討2025年三款流行的編輯器:Cursor、Visual Studio Code (VS Code)和Zed Code Editor。每…

使用 LiteFlow 實現靈活的業務邏輯解耦

1. 引言 1.1 業務邏輯復雜性帶來的挑戰 在現代軟件開發中,隨著業務需求不斷增長,代碼結構日趨復雜。硬編碼式的流程控制方式難以適應頻繁變更的需求,導致維護成本高、可讀性差、擴展性弱。 1.2 規則引擎在解耦中的作用 規則引擎(Rule Engine)通過將業務邏輯與程序代碼…

以項目的方式學QT開發(一)——超詳細講解(120000多字詳細講解,涵蓋qt大量知識)逐步更新!

以項目的方式學QT開發 以項目的方式學QT開發 P1 QT介紹 1.1 QT簡介 1.2 QT安裝 1.2.1 Windows QT安裝 1.2.2 QT Creator 使用基本介紹 P2 C基礎 2.1 命名空間 2.1.1 命名空間作用 2.1.2 自定義命名空間 2.2 從C語言快速入門 2.2.1 輸入輸出 2.2.2 基…

【前端】【css】【總復習】三萬字詳解CSS 知識體系

🌈 CSS 知識體系目錄大綱 一、基礎知識入門 1. CSS 簡介與作用 CSS(Cascading Style Sheets,層疊樣式表)是一種用于給 HTML 頁面添加樣式的語言,作用是讓網頁更美觀、結構更清晰、布局更靈活。 核心作用:…

R利用spaa包計算植物/微生物的生態位寬度和重疊指數

一、生態位寬度 生態位寬度指數包括shannon生態位指數和levins生態位指數。下面是采用levins方法計算生態位寬度。method也可以選擇“shannon”。 二、生態位重疊指數 生態位重疊指數,包括levins生態位重疊指數、schoener生態位重疊指數、petrai…

【論信息系統項目的合同管理】

論信息系統項目的合同管理 論文要求寫作要點正文前言一、合同的簽訂管理二、合同履行管理三、合同變更管理四、合同檔案管理五、合同違約索賠管理結語 論文要求 項目合同管理通過對項目合同的全生命周期進行管理,來回避和減輕可識別的項目風險。 請以“論信息系統項…

最新網盤資源搜索系統,電視直播,Alist聚合播放

源碼描述: 本項目是基于Vue與Nuxt.js技術構建的網盤搜索項目,持續開源并維護更新。該項目旨在使每個人都能擁有屬于自己的網盤搜索網站。我們強烈建議用戶自行部署該項目。 更新日志: 新增TV播放功能新增Alist源聚合播放功能新增批量刪除功…

【Ubuntu】安裝BitComet種子下載器

環境 Ubuntu 24.04.2 下載依賴庫 環境比較新,此軟件需要依賴很多舊的庫,逐個安裝下載: 1.libicu70 http://nz.archive.ubuntu.com/ubuntu/pool/main/i/icu/libicu70_70.1-2_amd64.deb2.libjavascriptcoregtk-4.0-18 http://security.ubu…

修復“ImportError: DLL load failed while importing lib: 找不到指定的程序”筆記

#工作記錄 一、問題描述 在運行CosyVoice_For_Windows項目時,出現以下報錯: Traceback (most recent call last): File "D:\ProgramData\anaconda3\envs\CosyVoice\Lib\pydoc.py", line 457, in safeimport module __import__(path) …

ubuntu18 設置靜態ip

百度 編輯/etc/netplan/01-netcfg.yaml 系統沒有就自己編寫 network: version: 2 renderer: networkd ethernets: eth0: dhcp4: no addresses: [192.168.20.8/24] # 設置你的IP地址和子網掩碼 gateway4: 192.168.20.1 # 網關地址 namese…

幀差法識別

定義: 視頻通過閃過x幀畫面來實現,幀差法就是利用兩幀之間的差異找出。也就是移動目標識別 幀差法識別步驟: 1、灰度處理:將多通道變成雙通道壓縮圖像數據。 cvtColor(before_frame,before_gray,CV_RGB2GRAY);cvtColor(after_f…

基于OAuth2+SpringSecurity+Jwt實現身份認證和權限管理后端服務

1、簡介 本文講述了如何實現簡易的后端鑒權服務。所謂“鑒權”,就是“身份鑒定”“權限判斷”。涉及的技術有:OAuth2、SpringSecurity、Jwt、過濾器、攔截器。OAuth2用于授權,使用Jwt簽發Access Token和Refresh Token,并管理token…