相關(guān)文章

• Java中如何使用消息隊列實現(xiàn)異步（ActiveMQ，RabbitMQ，Kafka）

  在 Java 中，可以使用消息隊列實現(xiàn)異步處理。下面是一個簡單的示例代碼，用于說明如何使用 ActiveMQ 實現(xiàn)消息隊列異步處理： 添加 ActiveMQ 依賴 在 pom.xml 文件中添加以下依賴： 創(chuàng)建消息隊列 創(chuàng)建一個名為 “TestQueue” 的消息隊列，并配置 ActiveMQ 連接信息： 創(chuàng)建消息消費者

  2024年02月16日

  瀏覽(33)

• 分布式消息隊列：Kafka vs RabbitMQ vs ActiveMQ

  在現(xiàn)代分布式系統(tǒng)中，消息隊列是一種常見的異步通信模式，它可以幫助系統(tǒng)處理高并發(fā)、高可用性以及容錯等問題。在這篇文章中，我們將深入探討三種流行的分布式消息隊列：Apache Kafka、RabbitMQ和ActiveMQ。我們將討論它們的核心概念、算法原理、特點以及使用場景。 隨著

  2024年02月02日

  瀏覽(19)

• 消息隊列之六脈神劍：RabbitMQ、Kafka、ActiveMQ 、Redis、 ZeroMQ、Apache Pulsar對比和如何使用

  消息隊列（Message Queue）是一種異步通信機制，它將消息發(fā)送者和接收者解耦，從而提高了應(yīng)用程序的性能、可擴展性和可靠性。在分布式系統(tǒng)中，消息隊列經(jīng)常被用于處理高并發(fā)、異步處理、應(yīng)用解耦等場景。 本篇回答將分析比較常見的六種消息隊列：RabbitMQ、Kafka、Active

  2024年02月14日

  瀏覽(19)
• 

  消息隊列-RabbitMQ：workQueues—工作隊列、消息應(yīng)答機制、RabbitMQ 持久化、不公平分發(fā)（能者多勞）

  Work Queues— 工作隊列 (又稱任務(wù)隊列) 的主要思想是避免立即執(zhí)行資源密集型任務(wù)，而不得不等待它完成 。 我們把任務(wù)封裝為消息并將其發(fā)送到隊列，在后臺運行的工作進程將彈出任務(wù)并最終執(zhí)行作業(yè)。當(dāng)有多個工作線程時，這些工作線程將一起處理這些任務(wù) 。 輪訓(xùn)分發(fā)消

  2024年02月21日

  瀏覽(23)
• 

  RabbitMQ工作模式-工作隊列

  官網(wǎng)關(guān)于工作模式的解釋地址：https://www.rabbitmq.com/getstarted.html Work Queue（工作隊列） 生產(chǎn)者發(fā)消息，啟動多個消費者來消費消息，每個消費者僅消費部分消息，可達到負(fù)載均衡的效果。 創(chuàng)建生產(chǎn)者 創(chuàng)建消費者 首先運行消息費，為了測試工作隊列模式，消費都需要啟動多個，

  2024年02月10日

  瀏覽(20)
• 

  RabbitMQ:工作隊列模式

  ??個人主頁:不斷前進的皮卡丘 ??博客描述:夢想也許遙不可及，但重要的是追夢的過程，用博客記錄自己的成長，記錄自己一步一步向上攀登的印記 ??個人專欄:消息中間件 工作隊列（又名： 任務(wù)隊列 ）背后的主要思想是避免立即執(zhí)行資源密集型任務(wù)并等待其完成。相反

  2024年01月23日

  瀏覽(26)
• 

  RabbitMQ 工作隊列模式 Work Queue Demo

  工作隊列模式,一個消息只能有一個消費者消費 ?生產(chǎn)者發(fā)送20條消息 消費者有兩個 第一個消費 睡一秒取一個 第二個睡2秒取 ? 手動簽收的好處:比如說你自動簽收了,消息中間件上刪除了,結(jié)果執(zhí)行邏輯出錯了 手動簽收好處就是當(dāng)出現(xiàn)異常 ,有余地可以再次執(zhí)行

  2024年02月02日

  瀏覽(27)
• 

  RaabitMQ(三) - RabbitMQ隊列類型、死信消息與死信隊列、懶隊列、集群模式、MQ常見消息問題

  這是RabbitMQ最為經(jīng)典的隊列類型。在單機環(huán)境中，擁有比較高的消息可靠性。 經(jīng)典隊列可以選擇是否持久化(Durability)以及是否自動刪除(Auto delete)兩個屬性。 Durability有兩個選項，Durable和Transient。 Durable表示隊列會將消息保存到硬盤，這樣消息的安全性更高。但是同時，由于需

  2024年02月14日

  瀏覽(1047)
• 

  RabbitMQ(一) - 基本結(jié)構(gòu)、SpringBoot整合RabbitMQ、工作隊列、發(fā)布訂閱、直接、主題交換機模式

  Publisher ： 生產(chǎn)者 Queue: 存儲消息的容器隊列； Consumer:消費者 Connection：消費者與消息服務(wù)的TCP連接 Channel:信道，是TCP里面的虛擬連接。例如：電纜相當(dāng)于TCP，信道是一條獨立光纖束，一條TCP連接上創(chuàng)建多少條信道是沒有限制的。TCP一旦打開，就會出AMQP信道。無論是發(fā)布消息

  2024年02月14日

  瀏覽(23)
• 

  RabbitMQ：第一章：6 種工作模式以及消息確認(rèn)機制

  } System.out.println(“發(fā)送數(shù)據(jù)成功”); channel.close(); connection.close(); } } 消費者一： import com.liao.rabbitmq.utils.RabbitConstant; import com.liao.rabbitmq.utils.RabbitUtils; import com.rabbitmq.client.*; import java.io.IOException; /** 消費者1 */ public class ConsumerOne { public static void main(String[] args) throws Exception { Con

  2024年04月12日

  瀏覽(18)