activeMQ會在什麼情況下重新發送訊息？

activeMQ中的訊息重發，指的是訊息可以被broker重新分派給消費者，不一定的之前的消費者。重發訊息之後，消費者可以重新消費。訊息重發的情況有以下幾種。

1.事務會話中，當還未進行session.commit()時，進行session.rollback()，那麼所有還沒commit的訊息都會進行重發。
2.使用客戶端手動確認的方式時，還未進行確認並且執行Session.recover()，那麼所有還沒acknowledge的訊息都會進行重發。
3.所有未ack的訊息，當進行session.closed()關閉事務，那麼所有還沒ack的訊息broker端都會進行重發，而且是馬上重發

重發指的是訊息經過broker重新進行轉發給消費者，經過測試，1和2的情況訊息重發會發送給原來的消費者，3和4可以轉發訊息給別的消費者。累計次數超過設定的maximumRedeliveries時訊息都會都會進入死信佇列。

有毒訊息
當一個訊息被接收的次數超過maximumRedeliveries(預設為6次)次數時，會給broker傳送一個poison _ack，這種ack型別告訴broker這個訊息“有毒”，嘗試多次依然失敗，這時broker會將這個訊息傳送到DLQ，以便後續處理。activeMQ預設的死信佇列是ActiveMQ.DLQ，如果沒有特別指定，死信訊息都會被髮送到這個佇列。

預設情況下持久訊息過期都會被送到DLQ，非持久訊息過期預設不會送到DLQ。

可以通過配置檔案為指定佇列建立死信佇列。

重試策略配置

下面是模擬重試的消費者程式碼

public class JMSClientAckConsumer {
    public static void main(String[] args) throws JMSException {
        //根據broker URL建立連線工廠

        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.0.15:61616"
 
);
        //建立連線
        ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();
        connection.start();
        //建立會話
        Session session = connection.createSession(true, Session.CLIENT_ACKNOWLEDGE);
        //重發策略
        RedeliveryPolicy queuePolicy = new RedeliveryPolicy();
        queuePolicy.setInitialRedeliveryDelay(0);
        queuePolicy.setRedeliveryDelay(1000);
        queuePolicy.setUseExponentialBackOff(false);
        queuePolicy.setMaximumRedeliveries(2);

        //建立佇列（有則不建立）
        Destination destination = session.createQueue("garine-queue");

        RedeliveryPolicyMap map = connection.getRedeliveryPolicyMap();
        map.put((ActiveMQDestination) destination, queuePolicy);


        session.createConsumer(destination).setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println(textMessage.getText());
                    session.rollback();
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

    }
}

重試策略配置除了以上的方式，還可以按照url的配置方式，可配置屬性很多，這裡列舉兩個
1.url

tcp://192.168.0.15:61616?jms.redeliveryPolicy.initialRedeliveryDelay=0&jms.redeliveryPolicy.redeliveryDelay=1000

重發策略配置可以在官方文件找到重發策略配置
2.在activeMq broker中配置

上面模擬的是在事務會話中呼叫rollback進行重試，經過模擬，發現訊息每次重試都是直接在原來的消費者進行重試，即使在重試次數內該消費者掛了，訊息依然不會馬上分發給別的消費者重試。

死信佇列配置
如果想自定義死信傳送策略，可以在activeMQ.xml裡面進行配置。

<destinationPolicy> 

           <policyMap> 

             <policyEntries> 

               <policyEntry topic=">" > 

                 <pendingMessageLimitStrategy> 

                   <constantPendingMessageLimitStrategy limit="1000"/> 

                 </pendingMessageLimitStrategy> 

               </policyEntry>  

                // “>”表示對所有佇列生效，如果需要設定指定佇列，則直接寫隊 列名稱 

            <policyEntry queue=">"> 
                  <deadLetterStrategy> 
                 //queuePrefix:設定死信佇列字首 
                    <individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true" processExpired="false"/> 
                     //是否丟棄過期訊息
                     <!--<sharedDeadLetterStrategy processExpired="false" />-->
                   </deadLetterStrategy> 

               </policyEntry> 

             </policyEntries> 

           </policyMap> 

       </destinationPolicy> 

什麼時候重新消費死信佇列裡面的訊息？
死信佇列也是佇列，訊息當然可以被重新消費。