RocketMQ的定時任務設計精髓！

今天來分享 RocketMQ 的定時任務。通過這些定時任務，能讓我們更加理解 RocketMQ 的消息處理機制和設計理念。

從 RocketMQ 4.9.4 的源代碼上看，RocketMQ 的定時任務有很多，今天主要講解一些核心的定時任務。

1 架構回顧

首先再來回顧一下 RocketMQ 的架構圖：

Name Server 集群部署，但是節點之間并不會同步數據，因為每個節點都會保存完整的數據。因此單個節點掛掉，并不會對集群產生影響。

Broker 可以采用主從集群部署，實現多副本存儲和高可用。每個 Broker 節點都要跟所有的 Name Server 節點建立長連接，定義注冊 Topic 路由信息和發送心跳。

Producer 和 Consumer 跟 Name Server 的任意一個節點建立長連接，定期從 Name Server 拉取 Topic 路由信息。

2 Producer 和 Consumer

2.1 獲取 NameServer 地址

Producer 和 Consumer 要跟 Name Server 建立連接，就必須首先獲取 Name Server 地址。Producer 和 Consumer 采用定時任務每兩分鐘獲取 Name Server 地址并更新本地緩存。代碼如下：

//MQClientInstance類
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???MQClientInstance.this.mQClientAPIImpl.fetchNameServerAddr();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?fetchNameServerAddr?exception",?e);
??}
?}
},?1000?*?10,?1000?*?60?*?2,?TimeUnit.MILLISECONDS);

2.2 更新路由信息

Producer 和 Consumer 會定時從 Name Server 獲取定時訂閱信息，更新本地緩存，默認間隔是 30s（可以配置）。代碼如下

//MQClientInstance類
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???MQClientInstance.this.updateTopicRouteInfoFromNameServer();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?updateTopicRouteInfoFromNameServer?exception",?e);
??}
?}
},?10,?this.clientConfig.getPollNameServerInterval(),?TimeUnit.MILLISECONDS);

2.3 向 Broker 發送心跳

Producer 和 Consumer 會從本地緩存的 Broker 列表中定時清除離線的 Broker，并且向 Broker 發送心跳，默認間隔是 30s（可以配置）。代碼如下：

//MQClientInstance類
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???MQClientInstance.this.cleanOfflineBroker();
???MQClientInstance.this.sendHeartbeatToAllBrokerWithLock();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?sendHeartbeatToAllBroker?exception",?e);
??}
?}
},?1000,?this.clientConfig.getHeartbeatBrokerInterval(),?TimeUnit.MILLISECONDS);

2.4 持久化 Offset

消費者需要定時持久化 MessageQueue 的偏移量，默認每 5s 更新一次（可以配置）。

注意：集群模式需要向 Broker 發送持久化消息，因為集群模式偏移量保存在 Broker 端，而廣播模式只需要把偏移量保存在消費者本地文件。 代碼如下：

//MQClientInstance類
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???MQClientInstance.this.persistAllConsumerOffset();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?persistAllConsumerOffset?exception",?e);
??}
?}
},?1000?*?10,?this.clientConfig.getPersistConsumerOffsetInterval(),?TimeUnit.MILLISECONDS);

2.5 調整核心線程數

對于消費者采用推模式的情況，消費者會根據未消費的消息數量，定期更新核心線程數，默認每 1m 一次。

注意：在 4.9.4 這個版本，更新核心線程數的代碼并沒有實現，只是預留了接口。 代碼如下：

//MQClientInstance類
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???MQClientInstance.this.adjustThreadPool();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?adjustThreadPool?exception",?e);
??}
?}
},?1,?1,?TimeUnit.MINUTES);

2.6 失效過期請求

Producer 和 Consumer 會定時掃描緩存在本地的請求，如果請求開始時間加超時時間（再加 1s）小于當前時間，則這個請求過期。通過定時任務（3s 一次）讓過期請求失效，并且觸發回調函數。

//NettyRemotingClient.java
this.timer.scheduleAtFixedRate(new?TimerTask()?{
?@Override
?public?void?run()?{
??try?{
???NettyRemotingClient.this.scanResponseTable();
??}?catch?(Throwable?e)?{
???log.error("scanResponseTable?exception",?e);
??}
?}
},?1000?*?3,?1000);

2.7 生產者

2.7.1 性能記錄

生產者發送消息后，會對成功失敗的狀態、花費時間進行記錄，以此來計算吞吐量 TPS，響應時間 RT，代碼如下：

//Producer.java
executorService.scheduleAtFixedRate(new?TimerTask()?{
?@Override
?public?void?run()?{
??snapshotList.addLast(statsBenchmark.createSnapshot());
??if?(snapshotList.size()?>?10)?{
???snapshotList.removeFirst();
??}
?}
},?1000,?1000,?TimeUnit.MILLISECONDS);

executorService.scheduleAtFixedRate(new?TimerTask()?{
?private?void?printStats()?{
??if?(snapshotList.size()?>=?10)?{
???doPrintStats(snapshotList,??statsBenchmark,?false);
??}
?}

?@Override
?public?void?run()?{
??try?{
???this.printStats();
??}?catch?(Exception?e)?{
???e.printStackTrace();
??}
?}
},?10000,?10000,?TimeUnit.MILLISECONDS);

2.8 消費者

2.8.1 MessageQueue 加鎖

對于順序消息，要保證同一個 MessageQueue 只能被同一個 Consumer 消費。消費者初始化的時候，會啟動一個定時任務，定時（默認 20s，可以配置）地向 Broker 發送鎖定消息，Broker 收到請求后，就會把 MessageQueue、group 和 clientId 進行綁定，這樣其他客戶端就不能從這個 MessageQueue 拉取消息。

代碼如下：

//ConsumeMessageOrderlyService.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???ConsumeMessageOrderlyService.this.lockMQPeriodically();
??}?catch?(Throwable?e)?{
???log.error("scheduleAtFixedRate?lockMQPeriodically?exception",?e);
??}
?}
},?1000?*?1,?ProcessQueue.REBALANCE_LOCK_INTERVAL,?TimeUnit.MILLISECONDS);

注意：Broker 的加鎖是有時效的（默認 60s，可以配置），過期后，有可能被其他 Consumer 進行消費。

2.8.2 性能快照

Consumer 每秒會記錄一次性能快照，比如消息從創建到消費花費的時間，消息從保存到消費花費的時間，接收到消息的總數量，失敗總數量。代碼如下：

//Consumer.java
executorService.scheduleAtFixedRate(new?TimerTask()?{
?@Override
?public?void?run()?{
??snapshotList.addLast(statsBenchmarkConsumer.createSnapshot());
??if?(snapshotList.size()?>?10)?{
???snapshotList.removeFirst();
??}
?}
},?1000,?1000,?TimeUnit.MILLISECONDS);

上面記錄了性能快照后，Consumer 會每隔 10s 進行性能參數計算和打印。代碼如下：

//Consumer.java
executorService.scheduleAtFixedRate(new?TimerTask()?{
private?void?printStats()?{
?if?(snapshotList.size()?>=?10)?{
??Long[]?begin?=?snapshotList.getFirst();
??Long[]?end?=?snapshotList.getLast();

??final?long?consumeTps?=
???(long)?(((end[1]?-?begin[1])?/?(double)?(end[0]?-?begin[0]))?*?1000L);
??final?double?averageB2CRT?=?(end[2]?-?begin[2])?/?(double)?(end[1]?-?begin[1]);
??final?double?averageS2CRT?=?(end[3]?-?begin[3])?/?(double)?(end[1]?-?begin[1]);
??final?long?failCount?=?end[4]?-?begin[4];
??final?long?b2cMax?=?statsBenchmarkConsumer.getBorn2ConsumerMaxRT().get();
??final?long?s2cMax?=?statsBenchmarkConsumer.getStore2ConsumerMaxRT().get();

??statsBenchmarkConsumer.getBorn2ConsumerMaxRT().set(0);
??statsBenchmarkConsumer.getStore2ConsumerMaxRT().set(0);

??System.out.printf("Current?Time:?%s?TPS:?%d?FAIL:?%d?AVG(B2C)?RT(ms):?%7.3f?AVG(S2C)?RT(ms):?%7.3f?MAX(B2C)?RT(ms):?%d?MAX(S2C)?RT(ms):?%d%n",
????System.currentTimeMillis(),?consumeTps,?failCount,?averageB2CRT,?averageS2CRT,?b2cMax,?s2cMax
??);
?}
}

通過性能參數的日志輸出，可以很方便的對 RocketMQ 的消費者進行監控。

2.8.3 清除過期消息

消費者會定期檢查本地拉取的消息列表，如果列表中的消息已經過期（默認 15 分鐘過期，可以配置），則把過期消息再次發送給 Broker，然后從本地消息列表刪除。代碼如下：

//ConsumeMessageConcurrentlyService.java
this.cleanExpireMsgExecutors.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???cleanExpireMsg();
??}?catch?(Throwable?e)?{
???log.error("scheduleAtFixedRate?cleanExpireMsg?exception",?e);
??}
?}

},?this.defaultMQPushConsumer.getConsumeTimeout(),?this.defaultMQPushConsumer.getConsumeTimeout(),?TimeUnit.MINUTES);

2.8.4 清除過期消息

消費者會每隔 30s 向 NameServer 拉取 MessageQueue 信息，然后跟本地保存的進行比較，如果不一致，則更新本地緩存信息。代碼如下：

//DefaultLitePullConsumerImpl.java
scheduledExecutorService.scheduleAtFixedRate(
new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???fetchTopicMessageQueuesAndCompare();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?fetchMessageQueuesAndCompare?exception",?e);
??}
?}
},?1000?*?10,?this.getDefaultLitePullConsumer().getTopicMetadataCheckIntervalMillis(),?TimeUnit.MILLISECONDS);

3 Broker

3.1 狀態采樣

Broker 端會對狀態進行采用，比如一個 Topic、MessageQueue、Group 總共發送了多少條消息，Topic 總共發送的消息大小。Broker 會對這些狀態按照秒、分鐘、小時為單位進行采樣并且定時打印，這里一共有 6 個定時任務。比如下面是按照秒進行采樣的定時任務：

//StatsItemSet.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???samplingInSeconds();
??}?catch?(Throwable?ignored)?{
??}
?}
},?0,?10,?TimeUnit.SECONDS);

3.2 記錄消息延時

Broker 讀取消息時會記錄消息從保存磁盤到被讀取的時間差并定時打印。定時任務代碼如下：

//MomentStatsItemSet.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???printAtMinutes();
??}?catch?(Throwable?ignored)?{
??}
?}
},?Math.abs(UtilAll.computeNextMinutesTimeMillis()?-?System.currentTimeMillis()),?1000?*?60?*?5,?TimeUnit.MILLISECONDS);

3.3 持久化數據

Broker 會定時持久化消費偏移量、Topic 配置、定閱組配置等，默認 10s 一次（可以配置）。代碼如下：

//ScheduleMessageService.java
this.deliverExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???if?(started.get())?{
????ScheduleMessageService.this.persist();
???}
??}?catch?(Throwable?e)?{
???log.error("scheduleAtFixedRate?flush?exception",?e);
??}
?}
},?10000,?this.defaultMessageStore.getMessageStoreConfig().getFlushDelayOffsetInterval(),?TimeUnit.MILLISECONDS);

3.4 失效過期請求

Broker 會定時掃描緩存在本地的請求，如果請求開始時間加超時時間（再加 1s）小于當前時間，則這個請求過期。通過定時任務（3s 一次）讓過期請求失效，并且觸發回調函數。

//NettyRemotingServer.java
this.timer.scheduleAtFixedRate(new?TimerTask()?{

?@Override
?public?void?run()?{
??try?{
???NettyRemotingServer.this.scanResponseTable();
??}?catch?(Throwable?e)?{
???log.error("scanResponseTable?exception",?e);
??}
?}
},?1000?*?3,?1000);

3.5 過濾服務

消費者可能會向 Broker 注冊 filterClass 用來過濾消息。Broker 收到消費者注冊的 filterClass 后會用定時任務來創建 FilterServer。代碼如下：

//FilterServerManager.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???FilterServerManager.this.createFilterServer();
??}?catch?(Exception?e)?{
???log.error("",?e);
??}
?}
},?1000?*?5,?1000?*?30,?TimeUnit.MILLISECONDS);

這樣消費者拉取消息時首先從 FilterServer 拉取消息，FilterServer 從 Broker 拉取消息后進行過濾，只把消費者感興趣的消息返回給消費者。一個 Broker 可以有多個 FilterServer。如下圖：

3.6 記錄消息總量

Broker 每天會記錄前一天收發消息的總數量，定時任務如下（period 是 1 天）：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.getBrokerStats().record();
??}?catch?(Throwable?e)?{
???log.error("schedule?record?error.",?e);
??}
?}
},?initialDelay,?period,?TimeUnit.MILLISECONDS);

3.7 持久化 Offset

Broker 默認每隔 5s（可以配置）會持久化一次消息的 Offset，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.consumerOffsetManager.persist();
??}?catch?(Throwable?e)?{
???log.error("schedule?persist?consumerOffset?error.",?e);
??}
?}
},?1000?*?10,?this.brokerConfig.getFlushConsumerOffsetInterval(),?TimeUnit.MILLISECONDS);

3.8 持久化過濾參數

上面提到過，消費者可能會向 Broker 注冊 filterClass，Broker 解析消費者注冊的 filterClass 后，會把解析后的 FilterData 持久化到文件，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.consumerFilterManager.persist();
??}?catch?(Throwable?e)?{
???log.error("schedule?persist?consumer?filter?error.",?e);
??}
?}
},?1000?*?10,?1000?*?10,?TimeUnit.MILLISECONDS);

3.9 Broker 自我保護

當消費者讀取消息緩慢時，Broker 為了保護自己，會把這個消費者設置為不允許讀取的狀態，這樣這個消費組就不能再拉取消息了，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.protectBroker();
??}?catch?(Throwable?e)?{
???log.error("protectBroker?error.",?e);
??}
?}
},?3,?3,?TimeUnit.MINUTES);

3.10 Broker 打印水位

Broker 會每隔 1s 打印一次水位，包括發送消息的延遲、接收消息的延遲、事務消息的延遲、查詢消息的延遲，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.printWaterMark();
??}?catch?(Throwable?e)?{
???log.error("printWaterMark?error.",?e);
??}
?}
},?10,?1,?TimeUnit.SECONDS);

3.11 Broker 打印 Offset 差

Broker 會定時打印最新的消息 Offset 和已經分發給 MessageQueue 和 Index 索引的 Offset 差距，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???log.info("dispatch?behind?commit?log?{}?bytes",?BrokerController.this.getMessageStore().dispatchBehindBytes());
??}?catch?(Throwable?e)?{
???log.error("schedule?dispatchBehindBytes?error.",?e);
??}
?}
},?1000?*?10,?1000?*?60,?TimeUnit.MILLISECONDS);

3.12 獲取 NameServer 地址

Broker 會定期獲取 NameServer 的地址，并更新本地緩存，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???BrokerController.this.brokerOuterAPI.fetchNameServerAddr();
??}?catch?(Throwable?e)?{
???log.error("ScheduledTask?fetchNameServerAddr?exception",?e);
??}
?}
},?1000?*?10,?1000?*?60?*?2,?TimeUnit.MILLISECONDS);

3.13 打印主從偏移量差距

Broker 會定時打印 master 節點和 slave 節點消息 Offset 的差距，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.printMasterAndSlaveDiff();
??}?catch?(Throwable?e)?{
???log.error("schedule?printMasterAndSlaveDiff?error.",?e);
??}
?}
},?1000?*?10,?1000?*?60,?TimeUnit.MILLISECONDS);

3.14 向 NameServer 注冊

Broker 會定時向（默認 30s，可配置，最高不超過 60s）所有 NameServer 發送注冊消息，代碼如下：

//BrokerController.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{

?@Override
?public?void?run()?{
??try?{
???BrokerController.this.registerBrokerAll(true,?false,?brokerConfig.isForceRegister());
??}?catch?(Throwable?e)?{
???log.error("registerBrokerAll?Exception",?e);
??}
?}
},?1000?*?10,?Math.max(10000,?Math.min(brokerConfig.getRegisterNameServerPeriod(),?60000)),?TimeUnit.MILLISECONDS);

3.15 同步 Slave

Broker 的 Master 節點會每間隔 10s 向 Slave 節點同步數據，包括 Topic 配置、消費偏移量、延遲偏移量、消費組配置，代碼如下：

//BrokerController.java
slaveSyncFuture?=?this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???BrokerController.this.slaveSynchronize.syncAll();
??}
??catch?(Throwable?e)?{
???log.error("ScheduledTask?SlaveSynchronize?syncAll?error.",?e);
??}
?}
},?1000?*?3,?1000?*?10,?TimeUnit.MILLISECONDS);

3.16 刪除過期文件

Broker 會周期性（默認 10s，可以配置）地執行刪除任務，刪除過期的 CommitLog 文件和 ConsumeQueue 文件，代碼如下：

//DefaultMessageStore.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??DefaultMessageStore.this.cleanFilesPeriodically();
?}
},?1000?*?60,?this.messageStoreConfig.getCleanResourceInterval(),?TimeUnit.MILLISECONDS);

3.17 文件大小檢查

Broker 會每隔 10 分鐘檢查 CommitLog 文件和 ConsumeQueue 文件，用當前文件的最?。ㄆ鹗迹?Offset 減去上一個文件最?。ㄆ鹗迹?Offset，如果不等于一個文件的大小，就說明文件存在問題。代碼如下：

//DefaultMessageStore.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??DefaultMessageStore.this.checkSelf();
?}
},?1,?10,?TimeUnit.MINUTES);

3.18 保存堆棧映射

Broker 會每隔 1s 記錄所有存活線程的堆棧映射信息，前提是 debugLockEnable 開關配置是打開的。代碼如下：

//DefaultMessageStore.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??if?(DefaultMessageStore.this.getMessageStoreConfig().isDebugLockEnable())?{
???try?{
????if?(DefaultMessageStore.this.commitLog.getBeginTimeInLock()?!=?0)?{
?????long?lockTime?=?System.currentTimeMillis()?-?DefaultMessageStore.this.commitLog.getBeginTimeInLock();
?????if?(lockTime?>?1000?&&?lockTime?

	3.19 檢查物理磁盤

	Broker 會每隔 10s 檢查保存 CommitLog 的磁盤空間是否達到閾值，如果達到，會打印 error 級別的日志。代碼如下：
//DefaultMessageStore.java
this.diskCheckScheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?public?void?run()?{
??DefaultMessageStore.this.cleanCommitLogService.isSpaceFull();
?}
},?1000L,?10000L,?TimeUnit.MILLISECONDS);


	3.20 持久化延時消息偏移量

	RocketMQ 的延時消費分為 18 個級別，定義如下：
//ScheduleMessageService.java
private?String?messageDelayLevel?=?"1s?5s?10s?30s?1m?2m?3m?4m?5m?6m?7m?8m?9m?10m?20m?30m?1h?2h";


	RocketMQ 會為每個延時級別定義要給 ConsumeQueue，每隔 ConsumeQueue 都會有一個 Offset，通過 offsetTable(ConcurrentMap) 來記錄不同延時級別對應的 Offset。

	RocketMQ 會周期性地（默認 10s，可以配置）把 offsetTable 中保存的 Offset 持久化到文件。代碼如下：
//DefaultMessageStore.java
this.deliverExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???if?(started.get())?{
????ScheduleMessageService.this.persist();
???}
??}?catch?(Throwable?e)?{
???log.error("scheduleAtFixedRate?flush?exception",?e);
??}
?}
},?10000,?this.defaultMessageStore.getMessageStoreConfig().getFlushDelayOffsetInterval(),?TimeUnit.MILLISECONDS);


	3.21 關閉異常連接

	Broker 會定時掃描所有的長連接，主要包括生產者、消費者和 FilterServer，如果連接不活躍，則關閉該連接，并從本地連接列表中移除。代碼如下：
//ClientHousekeepingService.java
this.scheduledExecutorService.scheduleAtFixedRate(new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???ClientHousekeepingService.this.scanExceptionChannel();
??}?catch?(Throwable?e)?{
???log.error("Error?occurred?when?scan?not?active?client?channels.",?e);
??}
?}
},?1000?*?10,?1000?*?10,?TimeUnit.MILLISECONDS);


	3.22 清理過期消息

	如果 Broker 配置了允許快速失?。╞rokerFastFailureEnable），則會每隔 10ms 定時清理過期請求，包括要發送的消息、接收的消息、心跳消息、要結束的事務消息。代碼如下：
scheduledExecutorService.scheduleAtFixedRate(
new?Runnable()?{
?@Override
?public?void?run()?{
??try?{
???fetchTopicMessageQueuesAndCompare();
??}?catch?(Exception?e)?{
???log.error("ScheduledTask?fetchMessageQueuesAndCompare?exception",?e);
??}
?}
},?1000?*?10,?this.getDefaultLitePullConsumer().getTopicMetadataCheckIntervalMillis(),?TimeUnit.MILLISECONDS);


	注意：清理消息前會判斷是否系統繁忙，如果系統繁忙，會給發送隊列中的消息直接返回系統繁忙，暫時不做過期消息清理。

	4 NameServer

	4.1 檢查過期 Broker

	在 3.14 節中講過，Broker 會跟 NameServer 建立長連接，定時向 NameServer 發送注冊消息。NameServer 會在本地維護一個 Broker 列表，定時任務會輪詢本地保存的 Broker 列表，檢查注冊消息是否過期（超過 120s），如果注冊消息過期，則關閉長連接，從本地緩存刪除這個 Broker。代碼如下：
//NamesrvController.java
this.scheduledExecutorService.scheduleAtFixedRate(NamesrvController.this.routeInfoManager::scanNotActiveBroker,?5,?10,?TimeUnit.SECONDS);


	4.2 打印配置

	NameServer 啟動時，會加載 KV 格式的配置文件到 configTable 這個變量，NameServer 客戶端也可以發送一個 KV 配置請求給 NameServer，NameServer 收到請求后也會保存到 configTable。

	NameServer 會定時打印 configTable 中的配置，代碼如下：
//NamesrvController.java
this.scheduledExecutorService.scheduleAtFixedRate(NamesrvController.this.kvConfigManager::printAllPeriodically,?1,?10,?TimeUnit.MINUTES);


	5 總結

	RocketMQ 的定時任務很多，這些定時任務的加入讓 RocketMQ 的設計更加完備，包括業務處理、監控日志、心跳、清理任務、關閉連接、持久化數據等。通過對定時任務的理解，能夠更深入地理解 RocketMQ 的設計理念。

	編輯：黃飛

	?

閱讀全文

定時(25177) 定時(25177)
Server(23812) Server(23812)
函數(61194) 函數(61194)
源代碼(65967) 源代碼(65967)

MCU長耗時任務的優化策略

在 MCU 裸機開發中，采用分時片的方式進行多任務處理是一種常見的技術。

2023-11-21 09:39:17

269

定時執行的程序相關問題討論

變量去當成判斷條件，然后實現不同的定時。按照上面方法實現程序效率肯定高，不過一旦程序功能豐富起來，代碼量增大，可維護性就降低了，后來我又看到另一種定時方法，定時器會同時提供一套定時任務注冊機制，比如

2016-01-22 23:53:00

Actor Framework中的定時結構（LabVIEW中的定時結構詳解----終）

一下類設計定時類Timer Manager數據：Timer Info array保存定時啟動后的定時任務名稱和控制消息數組方法：Add Time Task（）增加定時任務Stop a Timer

2018-06-26 01:18:43

CC2541在定時任務中發送數據，自動斷開連接？

從機是CC2541，主機是CC2540 USB，版本為1.4.0，從機與主機建立連接后，啟動一個5ms的定時任務，定時任務中發一個16字節的數據包給主機，半個小時不到，從機就自動斷開了連接，連接間隔最小與最大都為8，哪位大神知道這是為什么？

2016-04-18 16:22:26

HarmonyOS后臺任務管理開發指南上線！

時的操作步驟。 ①了解相關機制及規格，實現更高效開發。 ○ 申請時機：應用需要在前臺或退至后臺 5 秒內申請短時任務。 ○ 數量限制：一個應用同一時刻最多支持申請 3 個。 ○ 配額機制：一個應用有一定時

2023-11-29 09:58:38

Linux刪除指定時間前的文件的操作指導介紹

Linux 定時任務 刪除指定時間前的文件

2019-06-06 09:30:18

Linux應用--日志定時清理

;*.log.*"：目標文件的類型，帶有log的所有文件-exec：固定寫法rm -rf：強制刪除包括目錄在內的文件{} \;：固定寫法，一對大括號+空格+\+; 2、設置定時任務 每次都去手動執行任務

2019-07-09 08:12:07

Linux系統定時任務Crond

會定期（默認每分鐘檢查一次）檢查系統中是否有要執行的任務工作，如果有，便會根據其預先設定的定時任務規則自動執行該定時任務工作，這個crond定時任務服務就相當于我們平時早起使用的鬧鐘一樣。

2019-07-05 06:22:05

Stm32CubeMx基本定時器的概念

基本定時器概念在stm32f103中，共有八個定時器:TIM1~TIM8。其中TIM6和TIM7是基本定時器基本定時器相較于其他定時器只有基本的定時功能和驅動數模轉換器(Digital to Analog Converter, DAC)的功能，不具備外部通道簡單來說，就是實現一些簡單的定時任務的時候使用基本定時器

2021-08-18 08:18:19

busybox用crontab/crond在嵌入式系統中添加定時任務的方法

busybox 用crontab、crond在嵌入式系統中添加定時任務:參考文檔：在嵌入式系統中，定時任務通過crond和cronttab兩個系統命令來聯合執行。其中crond是定時任務的守護進程

2021-12-14 06:40:28

為當前用戶創建cron服務1.鍵入 crontab-e 編輯crontab服務文件例如文件內容如下：*/2 * * * * /bin/sh /home/admin/jiaoben/buy/deleteFile.sh 保存文件并并退出*/2 * * * * /bin/sh /home/admin/jiaoben/buy/deleteFile.sh */2 * * * * 通過這段字段可以設定什么時候執行腳本/bin/sh /home/admin/jiaoben/buy/deleteFile.sh 這一字段可以設定你要執行的腳本，這里要注意一下bin/sh 是指運行腳本的命令后面一段時指腳本存放的路徑

2019-07-08 06:20:37

linux的循環定時任務

linux循環定時任務

2020-05-20 14:59:46

ucos iii定時任務有什么用？

ucos iii 的定時任務有什么用，通過定時任務定時與普通的調用系統定時函數定時有什么區別？

2023-10-07 06:16:00

【API】多pk分組&用戶場景&通用定時任務api已經發布

多PK分組、用戶場景和通用定時任務接口已經發布。以上OPEN API 用戶/廠商可免費使用。多PK分組：可讓用戶/廠商對不用產品的設備進行歸類管理。接口兼容原有的單PK分組，不同點在于創建多 pk

2017-08-31 13:08:41

為什么軟件定時任務設置的延時周期時間不起作用？

(void){OS_ERRerr; /* 創建心跳任務 */OSTmrCreate((OS_TMR* )&tmr1, //定時器 1 (1)(CPU_CHAR* )"tmr1"

2019-06-30 22:52:35

使用RT_USING_TIMER_SOFT軟件定時器運行一段時間后任務出現異常怎么解決

版本：4.0.2主控：STM32L431現象：使用 RT_USING_TIMER_SOFT 軟件定時器，目前發現在運行一段時間之后，定時任務不運行了，仿真查看定時器任務發現任務出現異常如下為正常

2022-04-13 09:46:15

使用TC21x的GPT實現1m計時器執行定時任務，怎么配置GTM和GPT？

專家們好，我想使用TC21x的GPT實現1m計時器執行定時任務，不知道怎么配置GTM和GPT？

2024-02-06 06:47:00

使用stm32的滴答定時器構建多組軟件定時器

不高。但是實現方法及其簡單，甚至都不用配置什么外設，對于一般的定時任務來說夠用了。如果是對定時精度較高的任務來說，我們最好用硬件定時器來實現了。但是MCU的硬件定時器資源有限，而且定時器開多了可...

2021-08-11 09:14:23

關于stm32系統定時任務的問題

在用stm32做一個飛控程序時。需要用到上面這種系統循環定時任務，有一個問題：在System_Task_Loop函數里面，有1ms 、2ms、5ms的循環任務，但是他的這些定時是怎么得到的？是隨便

2017-10-10 23:43:13

在Linux系統下部署RocketMQ單機實例

前言這篇文章以4.3.0版本為標準進行講述在linux下部署RocketMQ單機實例,在此之前需要已配置JAVA環境。下載程序包直接使用一般就下載已經編譯好的二進制文件就好了,下載好以后&

2022-11-11 16:29:33

基于crontab命令的Linux服務器定時任務執行步驟

Linux服務器定時任務

2019-03-04 16:36:49

如何利用STM32的RTC實現定時中斷呢

能夠輸出固定頻率的脈沖信號。這樣做保證了低功耗情況下，單片機依舊能夠定時完成一些特定任務。功能描述用內部RTC實現秒級精度任務執行。例如：每1S進行一次LED燈的閃爍。每10S完成一次串口輸出等。下圖為使用內部RTC產生秒中斷，串口打印一次數據。用內部RTC實現定時任務執行。例如：每隔30分鐘

2022-01-13 07:34:29

實時多任務系統如何實現？

的情形是，系統不僅要對一些事件做出實時響應，并且還要承擔很多其他的非實時任務，并且這些非實時任務的運行時間要遠遠超出了實時響應時間的要求。傳統的這種程序結構顯然不能滿足系統的實時性要求。通常的解決方案是，引入實時操作系統，由操作系統進行任務的調度，優先執行實時任務，達到滿足系統實時性的要求。

2019-08-01 06:11:23

嵌入式linux是如何去實現定時任務的

嵌入式linux用倒計時是方式代替定時任務測試過程中,嵌入式linux ,是因為使用的系統默認使用ash進行編譯shell腳本，導致無法正常編譯。service crond status無法啟動定時任務

2021-11-05 06:04:42

手機APP對CH573F校之后，導致TMOS_Start_task()注冊的延時任務失效并立即執行如何解決？

通過手機APP對CH573F校之后，會導致TMOS_Start_task()注冊的延時任務失效并立即執行，該如何去解？

2022-08-23 06:19:16

機智云【API】多pk分組&用戶場景&通用定時任務api已經發布

2017-08-31 11:24:06

電磁兼容設計的精髓

2012-08-09 15:03:46

詳解linux定時任務

定時執行程序，實現腳本中的功能，在linux是通過etc/init.d/crond這個服務來實現計劃任務

2019-07-25 06:12:57

請教“同步開始定時結構”函數的使用方法

請教大家：“同步組名稱”、“定時結構名稱”這個參數如何設置？比如：有兩個定時任務：“定時任務A”、“定時任務B”，同步組如何設置？

2019-05-03 14:39:22

請問ucos III消息隊列列程中沒有處理掉的數據是什么意思？

你好，請問ucos III 消息隊列列程里面，關于定時任務關閉后，msgdis_task這個任務里面顯示的值還在一直累加，但是msg_num值不是在定時任務回調函數里面++的嗎？怎么定時任務關閉后

2019-10-31 03:26:12

請問ucos一個任務執行完了任務本身會怎樣？任務調度后其狀態會改變成怎樣？

初學。一直沒搞懂這個問題。就比如說任務1、2、3，優先級分別對應高，中，低。首先任務1在執行，執行完了引發任務調度，執行任務2，此時任務1的狀態是怎樣。那任務1的優先級應該是不改變，那任務2執行完了豈不是又執行任務1，那任務3怎么辦?

2020-05-14 21:54:20

鴻蒙原生應用/元服務開發-短時任務

概述應用退至后臺一小段時間后，應用進程會被掛起，無法執行對應的任務。如果應用在后臺仍需要執行耗時不長的任務，如狀態保存等，可以通過本文申請短時任務，擴展應用在后臺的運行時間。約束與限制 ·申請

2023-12-28 16:13:34

鴻蒙原生應用/元服務開發-長時任務

概述功能介紹應用退至后臺后，對于在后臺需要長時間運行用戶可感知的任務，例如播放音樂、導航等。為防止應用進程被掛起，導致對應功能異常，可以申請長時任務，使應用在后臺長時間運行。申請長時任務后，系統

2024-01-09 10:52:50

實時任務處理程序設計中“易變的”變量

實時任務處理程序設計中“易變的”變量

2009-05-15 13:52:43

OPC 實時任務系統動態調度算法的研究與設計The Stud

本文基于已有的OPC Server 實時任務模型，設計了處理混合任務集的動態調度算法（基于截止期優先）和實現方式。該算法實現了對混合任集可調度性的判斷，可以完成有硬實時性要

2009-05-31 15:36:16

控制系統中實時任務分析

本文分析了控制系統任務的特點，給出了控制系統中各種實時任務模型。分析了控制系統性能與任務參數之間的關系，給出了參數的設置方法。最后，研究了控制系統中實時任務

2009-08-06 08:35:50

μClinux下實時任務的一種實現方法

文中以ARM7 TDMI 處理器為例，闡述了μClinux 進程調度的原理。根據該原理，提出了一種在μClinux 平臺下實現實時任務的設計方法，這種方法較簡單，易于實現。這種設計一般可

2009-08-29 09:19:57

允許多處理機故障的實時任務容錯調度算法

隨著故障處理機個數增加，基于主/從版本技術的實時容錯調度算法對處理機利用率迅速下降。論文提出了一種能夠調度周期和非周期混合實時任務的容錯調度算法，該算法允許多個

2010-02-09 11:49:49

#硬聲創作季 13-Quartz動態定時任務（暫停定時任務）

JAVA編程語言

Mr_haohao發布于 2022-09-03 07:27:41

#硬聲創作季 15-Quartz動態定時任務（刪除定時任務）

JAVA編程語言

Mr_haohao發布于 2022-09-03 07:28:17

#硬聲創作季 14-Quartz動態定時任務（恢復定時任務）

JAVA編程語言

Mr_haohao發布于 2022-09-03 07:28:54

#硬聲創作季 16-Quartz動態定時任務（立即執行定時任務）

JAVA編程語言

Mr_haohao發布于 2022-09-03 07:29:30

C和C代碼精髓

C和C代碼精髓，有需要的朋友可以下來看看。

2016-05-20 14:28:44

基于單片機狀態的多任務系統

。傳統采用的事件觸發方式不但會導致事件的丟失，同時沒有考慮不同任務的靈活處理。對實時任務與非實時任務，對不頻繁調用的長任務與頻繁調用短任務,需要對內部資源不是很充足的８位機設計一個合適的任務調度器。本設計試圖將

2016-07-13 17:31:46

C語言的精髓——指針詳解

2017-11-30 14:43:33

實時任務雙容錯調度算法

云環境中的處理機故障已成為云計算不可忽視的問題，容錯成為設計和發展云計算系統的關鍵需求。針對一些容錯調度算法在任務調度過程中調度效率低下以及任務類型單一的問題，提出一種處理機和任務主副版本分組的容錯

2018-01-14 11:26:04

移動終端最優節能任務調度

討論在移動終端設備下硬實時任務調度的原理、機制、策略。在硬實時任務對時效性的要求與現時任務對能耗管理的要求這2個約束條件下對任務進行調度，實現最優節能與任務盡可能及時完成2個主要目標。研究在這

2018-02-07 16:30:12

展望Apache RocketMQ5.0 | 談RocketMQ的過去、現在和未來

摘要：?核心理念：計算和存儲分離。近日，在Aliware Open Source?深圳站 - Apache Dubbo & Apache RocketMQ 開發者沙龍上，Apache

2018-08-14 16:37:54

117

PHP簡單實現不依賴于Unix系統Cron的定時任務程序資料說明

本文檔的主要內容詳細介紹的是PHP簡單實現不依賴于Unix系統Cron的定時任務程序資料說明。

2019-03-01 16:52:00

定時任務的發展史是怎么樣的

定時任務是互聯網行業里最常用的服務之一，本文給大家介紹定時任務在我司的發展歷程。 linux系統中一般使用crontab命令來實現，在Java世界里，使用最廣泛的就是quartz

2019-07-18 17:38:00

如何實現Linux定時任務

cron的軟件包cronie rpm -ql cronie

2020-02-20 15:09:52

2551

linux定時任務如何判斷文件差異？

設計每10min執行任務檢查/app/recode文件大小，該文件不會超過4MB，超過此大小則壓縮處理，僅保留最近的日志內容。立馬著手檢查linux定時任務cron運行情況。 2. 初步排查

2021-03-17 10:05:36

1212

開發中如何實現生成訂單超時未支付自動取消

一個問題，這個延時任務和定時任務的區別究竟在哪里呢？一共有如下幾點區別 定時任務有明確的觸發時間，延時任務沒有 定時任務有執行周期，而延時任務在某事件觸發后一段時間內執行，沒有執行周期 定時任務一般執行的是批處理操作是多個任

2021-09-06 10:52:12

2464

SpringBoot如何實現動態增刪啟停定時任務

在spring boot項目中，可以通過 @EnableScheduling 注解和@Scheduled注解實現定時任務，也可以通過SchedulingConfigurer接口來實現定時任務。但是

2021-09-24 09:49:59

2551

Python定時任務的實現方式

在日常工作中，我們常常會用到需要周期性執行的任務，一種方式是采用 Linux 系統自帶的 crond 結合命令行實現。另外一種方式是直接使用Python。接下來整理的是常見的Python定時任務

2021-10-08 15:20:56

3191

嵌入式linux 用倒計時的方式代替定時任務

嵌入式linux 用倒計時是方式代替定時任務測試過程中,嵌入式linux ,是因為使用的系統默認使用ash進行編譯shell腳本，導致無法正常編譯。service crond status 無法

2021-11-02 15:06:15

Apache RocketMQ MQTT協議架構模型

rocketmq-mqtt.zip

2022-04-20 10:45:35

柚備創建數據備份定時任務

gitee-youbei.zip

2022-04-28 10:04:57

開源軟件-RocketMQ Externals Apache RocketMQ的擴展項目

./oschina_soft/rocketmq-externals.zip

2022-06-23 15:03:44

如何在SpringBoot項目中實現動態定時任務

之前寫過文章記錄怎么在SpringBoot項目中簡單使用定時任務，不過由于要借助cron表達式且都提前定義好放在配置文件里，不能在項目運行中動態修改任務執行時間，實在不太靈活。

2022-09-30 11:16:55

1432

說說Spring定時任務如何大規模企業級運用

定時任務是業務應用開發中非常普遍存在的場景（如：每分鐘掃描超時支付的訂單，每小時清理一次數據庫歷史數據，每天統計前一天的數據并生成報表等等），解決方案很多，Spring 框架提供了一種通過注解來配置定時任務的解決方案，接入非常的簡單，僅需如下兩步。

2022-11-04 09:36:18

487

解析Golang定時任務庫gron設計和原理

正巧，最近看到了 gron 這個開源項目，它是用 Golang 實現一個并發安全的定時任務庫。實現非常簡單精巧，代碼量也不多。今天我們就來一起結合源碼看一下，怎樣基于 Golang 的能力做出來一個【定時任務庫】。

2022-12-15 13:57:35

905

定時任務cron的教學

格式 {秒數} {分鐘} {小時} {日期} {月份} {星期} {年份(可為空)} 用法 "30 * * * * ? " 每半分鐘觸發任務 "30 10 * * * ? " 每小時的10分30

2023-01-13 15:18:14

1044

求一種SpringBoot定時任務動態管理通用解決方案

SpringBoot的定時任務的加強工具，實現對SpringBoot原生的定時任務進行動態管理,完全兼容原生@Scheduled注解,無需對原本的定時任務進行修改

2023-02-03 09:49:20

511

探秘消息在RocketMQ中短暫而又精彩的一生

當生產者啟動的時候，會從NameServer中拉取到路由表，緩存到本地，同時會開啟一個定時任務，默認是每隔30s從NameServer中重新拉取路由信息，更新本地緩存。

2023-03-31 10:28:06

394

SpringBoot如何實現定時任務（下）

SpringBoot創建定時任務的方式很簡單，主要有兩種方式：一、基于注解的方式（@Scheduled）二、數據庫動態配置。實際開發中，第一種需要在代碼中寫死表達式，如果修改起來，又得重啟會顯得很麻煩；所以我們往往會采取第二種方式，可以直接從數據庫中讀取定時任務的指定執行時間，無需重啟。

2023-04-07 14:51:21

1012

SpringBoot如何實現定時任務（上）

2023-04-07 14:51:44

994

Spring Boot中整合兩種定時任務的方法

在 Spring + SpringMVC 環境中，一般來說，要實現定時任務，我們有兩中方案，一種是使用 Spring 自帶的定時任務處理器 @Scheduled 注解，另一種就是使用第三方

2023-04-07 14:55:25

1211

SpringBoot-動態定時任務調度

先說業務場景，根據用戶輸入的cron表達式進行定時調度，舉個例子：如圖

2023-04-07 14:56:37

567

Quartz中編碼中用到的幾個對象

在使用Quartz的時候，我們需要用到Quartz的幾個對象：Job（任務）,JobDetail（任務定義：使用JobDetail來定義定時任務的實例），Trigger（觸發器：任務在什么時候會執行）。

2023-04-12 10:50:09

235

在Spring Boot中如何使用定時任務

本文介紹在 Spring Boot 中如何使用定時任務，使用非常簡單，就不做過多說明了。

2023-04-12 10:56:48

756

從各個維度再次介紹Spring Boot定時任務調度

Java自帶的java.util.Timer類，這個類允許你調度一個java.util.TimerTask任務。使用這種方式可以讓你的程序按照某一個頻度執行，但不能在指定時間運行。一般用的較少。

2023-04-12 11:01:04

449

如何動態添加修改刪除定時任務？

如何動態添加修改刪除定時任務？那么我們一起看看具體怎么實現，先看下本節大綱：（1）思路說明；（2）代碼解析；（3）修改定時任務執行周期特別說明；

2023-04-12 11:06:01

846

定時器作用及實現定時器數據結構選取介紹1

定時器在各種場景都需要用到，比如游戲的Buff實現，Redis中的過期任務，Linux中的定時任務等等。顧名思義，定時器的主要用途是執行定時任務。

2023-04-21 15:20:31

817

定時器作用及實現定時器數據結構選取介紹2

定時器在各種場景都需要用到，比如游戲的Buff實現，Redis中的過期任務，Linux中的定時任務等等。顧名思義，定時器的主要用途是執行定時任務。

2023-04-21 15:20:53

854

Linux如何使用cron進行定時任務的操作

按計劃執行命令對于計算機來說非常重要，因為假如我親自去執行一些任務的話，可能會因為多方面因素不能按時執行，所以定時任務就顯得非常重要了！ cron就是一個能夠執行定時任務的命令，其實該命令本身不難，下面小編帶您詳細了解！

2023-05-12 16:27:04

1702

python定時任務實踐

由于程序需求，監測配置變化需要設置定時任務，每分鐘執行一次，對任務持久化要求不高，不需要時可以關閉定時任務

2023-05-20 17:53:03

751

如何使用Spring scheduling task簡化定時任務功能的實現？

很多時候，我們有這么一個需求，需要在每天的某個固定時間或者每隔一段時間讓應用去執行某一個任務。

2023-05-22 16:48:52

692

H3C交換機配置定時任務

H3C交換機配置定時任務

2023-06-21 09:21:41

869

聊聊RocketMQ的主從復制

RocketMQ 主從復制是 RocketMQ 高可用機制之一，數據可以從主節點復制到一個或多個從節點。

2023-07-04 09:42:20

329

RocketMQ和RabbitMQ的區別

RocketMQ和RabbitMQ的區別：架構設計：RocketMQ是基于主題（Topic）的發布/訂閱模式，而RabbitMQ則是基于隊列（Queue）的消息代理系統。語言支持

2023-07-24 13:39:00

9692

RocketMQ在業務消息場景的優勢有哪些呢？

RocketMQ 5.0 是消息事件流一體的實時數據處理平臺，是業務消息領域的事實標準，很多互聯網公司在業務消息場景會使用 RocketMQ。

2023-08-07 11:36:10

456

Healthchecks：監控服務器Cron定時任務的神器

在運維服務器的時候經常會用到一些Crontab任務。當你的Crontab中的任務數超過10個的時候，你會發現這些任務管理起來非常困難。尤其是當這些Cron任務執行失敗的時候，比如 Python

2023-10-21 14:22:47

348

Clone節點如何避免主從故障？

通過解析binlog發現，同一時刻主從節點都在執行同一條語句，因此詢問業務是否在主從節點都執行了定時任務，業務回復定時任務只在主節點執行。

2023-10-26 09:27:13

healthchecks：監控服務器Cron定時任務的神器

2023-10-31 11:34:39

282

基于Django的Celery異步任務和定時任務的實戰教程

Django與Celery是基于Python進行Web后端開發的核心搭配，在運營開發（即面向企業內部）的場景中非常常見。下面是基于Django的Celery異步任務和定時任務的實戰教程，大家覺得

2023-11-02 10:45:18

253

定時器設計實現

由于目前C++標準中沒有現成的定時器,本設計使用C++11相關語法并進行封裝。本定時器包含一個TimerManager類用于創建定時器和進行定時任務管理，TimerManager會創建兩個線程

2023-11-08 16:50:55

239

定時器如何實現定時任務

1.1、單次定時任務實現 boost 的asio庫里有幾個定時器，老的有 deadline_timer , 還有三個可配合 C++11 的 chrono

2023-11-09 17:20:31

304

分布式定時調度：xxl-job最佳實踐方法

定時任務是按照指定時間周期運行任務。使用場景為在某個固定時間點執行，或者周期性的去執行某個任務，比如：每天晚上24點做數據匯總，定時發送短信等。

2023-11-30 11:06:27

315

任務調度系統設計的核心邏輯

Redis的讀寫性能極好，分布式鎖也比Quartz數據庫行級鎖更輕量級。當然Redis鎖也可以替換成Zookeeper鎖，也是同樣的機制。在小型項目中，使用：定時任務框架（Quartz/Spring Schedule）和分布式鎖（redis/zookeeper）有不錯的效果。

2024-01-02 15:09:14

239

RocketMQ協議是什么？RocketMQ協議特點

RocketMQ是由阿里巴巴開發的開源分布式消息和流處理平臺。它提供可靠、可擴展和高性能的消息傳輸和實時處理解決方案。 RocketMQ使用一種名為RocketMQ協議的通信協議。該協議旨在促進

2024-01-03 16:11:17

305

已全部加載完成

搜索歷史

RocketMQ的定時任務設計精髓！

評論

RocketMQ的定時任務設計精髓！