Skip to main content

🧣 ActiveMQ 自動回收

環境​

訂閱者回收​

訂閱者回收 - 設定​

  • 檔案: /conf/activemq.xml
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}"  offlineDurableSubscriberTimeout="86400000" offlineDurableSubscriberTaskSchedule="30000">
<!-- 其他設定 -->
</broker>

訂閱者回收 - 屬性​

  1. offlineDurableSubscriberTimeout:

    • 此屬性設定了離線持久訂閱者的超時時間
    • 如果一個持久訂閱者在指定的超時時間內沒有任何活動，系統可能會將其視為離線狀態，並進行相應的處理
    • 超時時間設定為 86400000 毫秒，即 24 小時。

  2. offlineDurableSubscriberTaskSchedule:

    • 此屬性設定了執行離線持久訂閱者任務的排程間隔
    • 系統將以指定的間隔執行任務，以確保離線持久訂閱者的狀態得以更新
    • 排程間隔設定為 30000 毫秒，即 30 秒

Topic 回收​

Topic 回收 - 設定​

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}"  offlineDurableSubscriberTimeout="86400000" offlineDurableSubscriberTaskSchedule="30000">
 <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry topic=">">
                    <pendingMessageLimitStrategy>
                        <constantPendingMessageLimitStrategy limit="1000"/>
                    </pendingMessageLimitStrategy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>    
<!-- 其他設定 -->
</broker>

Topic 回收 - 屬性​

  1. topic:

    • 此屬性指定了 Topic 的名稱，這裡使用了 >，表示所有的 Topic
    • 回收策略將應用於所有的 Topic

  2. pendingMessageLimitStrategy:

    • 此屬性設定了待處理訊息數的限制策略，即當一個 Topic 上的待處理訊息數超過指定限制時，將採取相應的處理策略
    • 在這個例子中，使用了常數限制策略，設定的限制為每個 Topic 最多允許 1000 則待處理訊息

Queue 回收​

Queue 回收 - 設定​

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}"  offlineDurableSubscriberTimeout="86400000" offlineDurableSubscriberTaskSchedule="30000">
 <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry queue=">" gcInactiveDestinations="true" inactiveTimoutBeforeGC="30000"/>
            </policyEntries>
        </policyMap>
    </destinationPolicy>    
<!-- 其他設定 -->
</broker>

Queue 回收 - 屬性​

  1. gcInactiveDestinations:

    • 此屬性用於啟用或禁用對閒置目的地的垃圾回收（Garbage Collection）
    • 如果設定為 true，系統將對閒置的 Queue 進行垃圾回收

  2. inactiveTimoutBeforeGC:

    • 此屬性設定了在執行垃圾回收之前，目的地可以保持閒置的時間閾值
    • 設定為 30000 毫秒，即 30 秒
    • 如果一個 Queue 在 30 秒內沒有活動，系統將視其為閒置目的地，並在啟用垃圾回收的情況下將其回收