RibbitMQ 大資料分布式下的訊息佇列思

2022-02-23 06:10:42 字數 410 閱讀 5673

對於ribbitmq  訊息佇列

使用:定義乙個佇列,作為訊息佇列

生產者,生產訊息新增入佇列

消費者,監聽到訊息佇列中有訊息後,取出訊息處理訊息

每台伺服器也可以配置多個消費者去處理訊息

此處向handler中,增加的消費者物件,類似於觀察者模式

那是不是可以改為, handler 中,持有消費者物件,改為持有消費者物件工廠或者池

在啟動消費者執行緒去執行任務時, 主線程或開啟監聽執行緒,來監聽訊息處理的速度, 根據訊息處理的速度,呼叫消費者工廠,生成更多的消費者去處理任務

同理,如果是伺服器集群,在當今微服務盛行的情況下, 微服務啟動非常快,

也可以配置乙個監聽伺服器,用來監聽每個訊息佇列處理的任務的速度,

然後根據訊息處理的速度,啟動更多的伺服器去處理任務

分布式資料

2017年04月25日 10 36 40 唐大麥 閱讀數 13767 標籤 分布式 mysql 資料庫事務 更多 個人分類 mysql 在開發中,為了降低單點壓力,通常會根據業務情況進行分表分庫,將表分布在不同的庫中 庫可能分布在不同的機器上 在這種場景下,事務的提交會變得相對複雜,因為多個節點 庫...

分布式 分布式鎖

本質是利用redis的setnx 方法的特性來加鎖,setnx 即key不存在則設定key,否則直接返回false,要求在分布式系統中使用同乙個redis服務,以下提供兩種解決方案 1 直接使用redistemplate 這其實並不能完全保證高併發下的安全問題,因為可能在鎖過期之後該執行緒尚未執行完...

分布式 分布式事務

是資料庫執行過程中的乙個邏輯單位,由乙個有限的資料庫操作序列構成。事務的acid四大特性 原子性 atomicity 事務作為乙個整體被執行。一致性 consistency 從乙個一致的狀態轉換到另乙個一致的狀態。隔離性 isolation 多個事務併發執行時,併發事務之間互相影響的程度。永續性 d...