相關(guān)文章

• 

  【簡單認識zookeeper+kafka分布式消息隊列集群的部署】

  Zookeeper是一個開源的分布式的，為分布式框架提供協(xié)調(diào)服務的Apache項目。 Zookeeper從設計模式角度來理解：是一個基于觀察者模式設計的分布式服務管理框架，它負責存儲和管理大家都關(guān)心的數(shù)據(jù)，然后接受觀察者的注冊，一旦這些數(shù)據(jù)的狀態(tài)發(fā)生變化，Zookeeper就將負責通知已

  2024年02月13日

  瀏覽(24)
• 

  【深入淺出RocketMQ原理及實戰(zhàn)】「消息隊列架構(gòu)分析」幫你梳理RocketMQ或Kafka的選擇理由以及二者PK

  前提背景 大家都知道，市面上有許多開源的MQ，例如，RocketMQ、Kafka、RabbitMQ等等，現(xiàn)在Pulsar也開始發(fā)光，今天我們談談筆者最常用的RocketMQ和Kafka，想必大家早就知道二者之間的特點以及區(qū)別，但是在實際場景中，二者的選取有可能會范迷惑，那么今天筆者就帶領大家分析一下

  2024年02月19日

  瀏覽(26)
• 

  項目實戰(zhàn) — 消息隊列（2）{創(chuàng)建核心類}

  目錄 ?一、創(chuàng)建項目 二、創(chuàng)建核心類 ?? 1、?編寫交換機類，Exchange ?? 2、編寫存儲消息的隊列，MSGQueue ?? 3、編寫綁定類，binding ?? 4、編寫消息，Message ? 代碼解釋主要在注釋上面，注意一下注釋 核心類主要是在服務器模塊中的。? 主要是以下幾個類 *?交換機 exchange *

  2024年02月15日

  瀏覽(20)
• 

  【Kafka】消息隊列Kafka基礎

  ??消息隊列，經(jīng)?？s寫為MQ。從字面上來理解，消息隊列是一種用來存儲消息的隊列。例如Java中的隊列： ??上述代碼，創(chuàng)建了一個隊列，先往隊列中添加了一個消息，然后又從隊列中取出了一個消息。這說明了隊列是可以用來存取消息的。我們可以簡單理解消息隊列就是

  2024年02月16日

  瀏覽(20)
• 

  【Kafka】消息隊列Kafka進階

  生產(chǎn)者分區(qū)寫入策略 生產(chǎn)者寫入消息到 topic，Kafka 將依據(jù)不同的策略將數(shù)據(jù)分配到不同的分區(qū)中。 輪詢分區(qū)策略 隨機分區(qū)策略 按key分區(qū)分配策略 自定義分區(qū)策略 輪詢策略 ??默認的策略，也是使用最多的策略，可以最大限度保證所有消息平均分配到一個分區(qū)。如果在生產(chǎn)

  2024年02月15日

  瀏覽(18)
• 

  架構(gòu)核心技術(shù)之分布式消息隊列

  Java全能學習+面試指南：https://javaxiaobear.cn 今天我們來學習分布式消息隊列，分布式消息隊列的知識結(jié)構(gòu)如下圖。 主要介紹以下內(nèi)容： 同步架構(gòu)和異步架構(gòu)的區(qū)別。異步架構(gòu)的主要組成部分：消息生產(chǎn)者、消息消費者、分布式消息隊列。異步架構(gòu)的兩種主要模型：點對點模型

  2024年02月07日

  瀏覽(24)
• 

  【Kafka專題】Kafka收發(fā)消息核心參數(shù)詳解

  在Kafka中，對于客戶端和服務端的定義如下： 客戶端Client： 包括消息生產(chǎn)者 和 消息消費者 服務端：即Broker，Broker：一個Kafka服務器就是一個Broker 首先，先引入客戶端maven依賴 1.1 消息發(fā)送者源碼示例 然后可以使用Kafka提供的客戶端——Producer類，快速發(fā)送消息。 看上面的源

  2024年02月03日

  瀏覽(16)

• Kafka消息隊列中關(guān)于消息的實現(xiàn)原理

  2023年07月01日

  瀏覽(27)
• 

  Kafka消息隊列實現(xiàn)消息的發(fā)送和接收

  消息在Kafka消息隊列中發(fā)送和接收過程如下圖所示： 消息生產(chǎn)者Producer產(chǎn)生消息數(shù)據(jù)，發(fā)送到Kafka消息隊列中，一臺Kafka節(jié)點只有一個Broker，消息會存儲在Kafka的Topic（主題中），不同類型的消息數(shù)據(jù)會存儲在不同的Topic中，可以利用Topic實現(xiàn)消息的分類，消息消費者Consumer會訂閱

  2024年02月11日

  瀏覽(21)
• 

  消息隊列——kafka基礎

  首先自然是要列出Kafka官網(wǎng)地址啦：https://kafka.apache.org/ 概述 定義 發(fā)布/訂閱模式 ? 原文鏈接：https://blog.csdn.net/tjvictor/article/details/5223309 ? 定義了一種 一對多 的依賴關(guān)系，讓 多個訂閱者對象同時監(jiān)聽某一個主題對象 。這個主題對象在自身狀態(tài)變化時，會通知所有訂閱者對

  2024年02月04日

  瀏覽(24)