1. 在這裡不提如何整合rabbit mq到Spring。

2. 實現功能的配置都在消費者端：

3. 下面是步驟和說明

（1）在消費者端的mq配置檔案上新增,配置  關鍵程式碼為 acknowledeg = "manual"
，意為表示該消費者的ack方式為手動（此時的queue已經和生產者的exchange通過某個routeKey綁定了）

<rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual">
    <rabbit:listener queues="queue_xxx" ref="MqConsumer"/>
    <rabbit:listener queues="queue_xxx" ref="MqConsumer2"/>
</rabbit:listener-container>
 

（2）新建一個類 MqConsumer ，並實現介面  ChannelAwareMessageListener ，實現onMessage方法，不需要指定方法。

因為下方圖所示，springAMQP中已經實現了一個功能，如果該監聽器已經實現了下面2個介面，則直接呼叫onMessage方法

（3）關鍵點在實現了ChannelAwareMessageListener的onMessage方法後，會有2個引數。

一個是message（訊息實體），一個是channel就是當前的通道

很多地方都沒有說清楚怎麼去手動ack，其實手動ack就是在當前channel裡面呼叫basicAsk的方法，並傳入當前訊息的tagId

第二個引數我其實也沒理解用途，暫時還沒有模擬出場景，所以先不討論。

同樣的，如果要unack或者拒絕訊息（reject）的時候，也是呼叫channel裡面的basicXXX方法就可以了（當然要制定tagId）。

注意如果拋異常或unack（並且requeue為true），訊息會一直重新入佇列，一不小心就會xxxxx一大堆訊息不斷重複~。

//訊息的標識，false只確認當前一個訊息收到，true確認所有consumer獲得的訊息

channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);

//ack返回false，並重新回到佇列，api裡面解釋得很清楚

channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);

//拒絕訊息

channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);