接著上節(jié)來(lái)說(shuō)，Broker端如何進(jìn)行分配消息的？同時(shí)當(dāng)新增或者刪除消費(fèi)者時(shí)，如果進(jìn)行重平衡，被其他消費(fèi)者分配后如何處理？ 1、Consumer啟動(dòng) 負(fù)載均衡消息隊(duì)列，...
發(fā)簡(jiǎn)信
IP屬地：臺(tái)灣
-
RocketMQ隊(duì)列分配和重平衡 -
RocketMQ系列3-消息發(fā)送流程
概念 1、消息發(fā)送方式 Rocketmq提供三種方式可以發(fā)送普通消息：同步、異步、和單向發(fā)送。 同步：發(fā)送方發(fā)送消息后，收到服務(wù)端響應(yīng)后才發(fā)送下一條消息 異步：發(fā)送一條消息后...
-
RocketMQ系列4-長(zhǎng)輪詢模式實(shí)現(xiàn)推送消息
1、Consumer消費(fèi)消息兩種模式比較 RocketMQ提供兩種方式進(jìn)行消費(fèi)消息pull vs push，這也是很多涉及到Client和Server之間的交互模型 1....
-
RocketMQ系列2：主從同步
前提netty常用方法 通過(guò)學(xué)習(xí)RocketMQ源碼發(fā)現(xiàn)其中涉及到很多netty編程，下面先簡(jiǎn)單梳理一下Netty 常用類和方法，本次重點(diǎn)說(shuō)一下ByteBuffer和Soc...
-
RocketMQ系列：概述Apache RocketMQ是阿里開源的一款高性能、高吞吐量的分布式消息中間件。 一、系統(tǒng)部署架構(gòu) 下圖為RocketMQ系統(tǒng)部署架構(gòu)： 整體的架構(gòu)設(shè)計(jì)主要分為四大部分，...
-
無(wú)網(wǎng)絡(luò)搭建docker環(huán)境
由于公司在做一些私有云平臺(tái)構(gòu)建，所以會(huì)出現(xiàn)在沒有網(wǎng)絡(luò)的情況下搭建環(huán)境，經(jīng)過(guò)測(cè)試整個(gè)流程可以進(jìn)行搭建docker環(huán)境的。 無(wú)網(wǎng)絡(luò)服務(wù)器安裝docker 先在本機(jī)下載dock...
-
Mysql原理（二）索引篇常見的數(shù)據(jù)結(jié)構(gòu) 1、有序數(shù)組:有序的元素序列，同時(shí)每一個(gè)數(shù)組元素都有下標(biāo)，所以在查詢的時(shí)候通過(guò)下標(biāo)可以直接獲取，但是插入一條數(shù)據(jù)需要將后面的記錄往后移動(dòng)成本就會(huì)高，該數(shù)據(jù)結(jié)構(gòu)...