為您找到相關(guān)結(jié)果125,170個
RocketMQ Broker實現(xiàn)高可用高并發(fā)的消息中轉(zhuǎn)服務(wù)_java_腳本之家
RocketMQ消息代理(Broker)是一種高可用、高并發(fā)的消息中轉(zhuǎn)服務(wù),能夠接收并存儲生產(chǎn)者發(fā)送的消息,并將消息發(fā)送給消費者。它具有多種消息存儲模式和消息傳遞模式,支持水平擴展和故障轉(zhuǎn)移等特性,可以為分布式應(yīng)用提供可靠的消息傳遞服務(wù)+ 目錄 RocketMq-broker broker主要作用就是存儲消息。所以重點就放在它對于消息
www.dbjr.com.cn/article/2821...htm 2025-6-11
RocketMQ源碼分析之Broker過期消息清理機制_java_腳本之家
消息清理機制源碼分析 消息定時清理的是由DefaultMessageStore類負(fù)責(zé)的,它在啟動時(start)會調(diào)用DefaultMessageStore#addScheduleTask添加和消息存儲相關(guān)的定時任務(wù),其中就包括消息刪除相關(guān)的定時任務(wù)DefaultMessageStore.this.cleanFilesPeriodically(),這個定時任務(wù)在Broker啟動后60s開始,每隔10秒執(zhí)行一次。 1 2 3 4 5 6 ...
www.dbjr.com.cn/article/2837...htm 2025-6-9
RocketMQ特性Broker存儲事務(wù)消息實現(xiàn)_java_腳本之家
Broker存儲事務(wù)消息的是org.apache.rocketmq.broker.processor.SendMessageProcessor,這和普通消息其實是一樣的。 但是有兩點針對事務(wù)消息的特殊處理: 第一處: 在org.apache.rocketmq.broker.processor.SendMessageProcessor#sendMessage中: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 //獲取擴展字段的值,若是該...
www.dbjr.com.cn/article/2596...htm 2025-5-28
JMS 之 Active MQ 的消息傳輸(詳解)_java_腳本之家
一、消息協(xié)商器(Message Broker) broke:消息的交換器,就是對消息進行管理的容器。ActiveMQ 可以創(chuàng)建多個 Broker,客戶端與ActiveMQ交互,實際上都是與ActiveMQ中的Broker交互,Broker配置在${MQ_HOME}\conf\activemq.xml。 二、連接器(Connectors)(一)、傳輸連接器 (transportConnectors) ...
www.dbjr.com.cn/article/1164...htm 2025-6-9
Java消息隊列中的Kafka如何保證冪等性_java_腳本之家
kafka默認(rèn)情況下,提供的是至少一次的可靠性保障。即broker保障已提交的消息的發(fā)送,但是遇上某些意外情況 如:網(wǎng)絡(luò)抖動,超時等問題,導(dǎo)致Producer沒有收到broker返回的數(shù)據(jù)ack,則Producer會繼續(xù)重試發(fā)送消息,從而導(dǎo)致消息重復(fù)發(fā)送。 如果我們禁止Producer的失敗重試發(fā)送功能,消息要么寫入成功,要么寫入失敗,但絕不會重復(fù)發(fā)送。
www.dbjr.com.cn/program/293061p...htm 2025-6-4