為您找到相關結果17,529個
RocketMQ源碼分析之Broker過期消息清理機制_java_腳本之家
ConsumeQueue和IndexFile清理源碼分析 ConsumeQueue和IndexFile清理方法CleanConsumeQueueService#run調用了CleanConsumeQueueService#deleteExpiredFiles方法清理ConsumeQueue和IndexFile。CleanConsumeQueueService#deleteExpiredFiles核心代碼如下,包括兩個主要邏輯 遍歷consumeQueueTable中的ConsumeQueue,調用ConsumeQueue#deleteExpiredFile...
www.dbjr.com.cn/article/2837...htm 2025-6-9
盤點MQ中的異常測試_java_腳本之家
而consumequeue,就是用來記錄數(shù)據的位置,以便 Consumer 快速通過 consumequeue 找到 commitlog 中的數(shù)據。 四、MQ 異常測試 MQ消息體 MQ消息體中某些必填參數(shù)為 NULL,或者全部必填都為NULL,字段類型、長度是否不符合約定等。 消息重復發(fā)送 消息重復發(fā)送,只消費一條,一般根據消息內容中唯一標識來去重。
www.dbjr.com.cn/article/2496...htm 2025-5-26
linux安裝RocketMQ實例步驟_Linux_腳本之家
mkdir /usr/local/rocketmq/store/consumequeue mkdir /usr/local/rocketmq/store/index 2.8 把borker-a.properties 和borker-b.properties 上傳到/usr/local/recketmq/conf/2m-noslave 2.9 master01配置borker-a.properties brokerName=broker-a 對應文件名稱 ...
www.dbjr.com.cn/article/1806...htm 2025-6-7
Python使用asyncio.Queue進行任務調度的實現(xiàn)_python_腳本之家
在main函數(shù)中,我們首先創(chuàng)建了一個asyncio.Queue對象。然后,使用asyncio.create_task()函數(shù)創(chuàng)建了兩個任務——一個是生產者任務produce,另一個是消費者任務consume。最后,通過asyncio.gather()函數(shù)等待所有任務完成。 asyncio.Queue的常用方法 asyncio.Queue提供了一系列方法來操作隊列。以下是一些常用方法的介紹: ...
www.dbjr.com.cn/python/315034m...htm 2025-6-2
RocketMQ之Consumer整體介紹啟動源碼分析_java_腳本之家
privatelongsuspendCurrentQueueTimeMillis =1000; // 消息阻塞消費線程的最大超時時間,默認15分鐘 privatelongconsumeTimeout =15; // 關閉使用者時等待消息的最長時間,0表示沒有等待。 privatelongawaitTerminationMillisWhenShutdown =0; } Consumer消費模式 ...
www.dbjr.com.cn/article/2837...htm 2025-6-8