MQ - 愛碼網

RocketMQ - 消費者啟動機制

RocketMQ客戶端中有兩個獨立的消費者實現類：org.apache.rocketmq.client.consumer.DefaultMQPullConsumer 和 org.apache.rocketmq.client.consumer.DefaultMQPushConsumer Default ... ?

RocketMQ - 消費者概述

消費流程消費者組：一個邏輯概念，在使用消費者時需要指定一個組名。一個消費者組可以訂閱多個Topic。消費者實例：一個消費者組程序部署了多個進程，每個進程都可以稱為一個消費者實例。訂閱關系：一個消費者組訂閱一個 Topic 的某一個 Tag，這種記錄被稱為訂閱關系。RocketMQ規定消費 ... ?

MQ收到無序的消息時如何進行業務處理

業務背景跟第三方系統做對接，雙方通過ActiveMQ進行通信，消息之間是有內在關聯的，也就是消息本來應該是有業務順序的，但由于一些原因，現在收到消息是亂序的，這種情況下做業務處理就有一點小問題了方案一：自己重排序收到消息后，自己在內存排序，然后按順序丟到隊列中，自己控制消息的發送和接收保證收到 ... ?

RocketMQ - 生產者消息發送流程

RocketMQ客戶端的消息發送通常分為以下3層業務層：通常指直接調用RocketMQ Client發送API的業務代碼。消息處理層：指RocketMQ Client獲取業務發送的消息對象后，一系列的參數檢查、消息發送準備、參數包裝等操作。通信層：指RocketMQ基于Netty封裝的一個R ?

RocketMQ - 生產者啟動流程

生產者啟動流程 DefaultMQProducer是RocketMQ中默認的生產者實現核心屬性： namesrvAddr: 繼承自 ClientConfig，表示 RocketMQ 集群的Namesrv 地址，如果是多個則用分號分開。比如：127.0.0.1：9876;127.0.0.2：987 ?

RocketMQ - 生產者原理

https://rocketmq.apache.org/ Apache RocketMQ是一款開源的、分布式的消息投遞與流數據平臺。出生自阿里巴巴，在阿里巴巴內部經歷了3個版本后，作為Apache 頂級開源項目之一直到現在。在GitHub上有10000+star、5000+fork、170+cont ... ?

SpringBoot整合多個Mq服務做法詳解

目錄 1、自定義一個MqTemplate 2、定義一個mq配置項相對應的類 3、將我們自定義的mq配置定義成MqTemplate類型的bean 4、使用對應的Template發送消息以rabbitmq為例 springboot項目想要整合rabbitmq非常簡單，只需要在maven中引入對 ?

MQ系列11：如何保證消息可靠性傳輸（除夕奉上）

MQ系列1：消息中間件執行原理MQ系列2：消息中間件的技術選型MQ系列3：RocketMQ 架構分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的發送模式MQ系列6：消息的消費MQ系列7：消息通信，追求極致性能 MQ系列8：數據存儲，消息隊列的高可用保障MQ系列9：高可 ?

使用java代碼調用rabbitmq接口進行新增編輯mq用戶、虛擬機vhost、動態創建交換機exchange、隊列queue以及設置權限，綁定vhost與exchange等操作

使用java代碼操作rabbitmq時，首先需要一個有創建用戶等權限的管理員賬號，需要在rabbitmq的后臺管理頁面手動創建這個賬號，系統推薦的這幾個tag可以讓賬號有rabbitmq后臺管理頁面的訪問權限　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　 ?

MQ系列10：如何保證消息冪等性消費

MQ系列1：消息中間件執行原理 MQ系列2：消息中間件的技術選型 MQ系列3：RocketMQ 架構分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的發送模式 MQ系列6：消息的消費 MQ系列7：消息通信，追求極致性能 MQ系列8：數據存儲，消息隊列的高可用保障 M ... ?

MQ系列9：高可用架構分析

MQ系列1：消息中間件執行原理 MQ系列2：消息中間件的技術選型 MQ系列3：RocketMQ 架構分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的發送模式 MQ系列6：消息的消費 MQ系列7：消息通信，追求極致性能 MQ系列8：數據存儲，消息隊列的高可用保障 1 ... ?