專案基礎結構參考：

原始碼：

工作過程

生產者每隔1秒傳送一條資訊到test_work_queue佇列中

工作佇列有兩種工作方式：

輪詢分發round-robin：

程式碼裡進行了測試，將consumer01執行緒暫停4秒再執行，在round-robin情況下，仍會輪詢分發。

結果：

生產者

消費者1：

由於sleep 4s，所以執行起來要比消費者2慢很多

消費者2：

雖然消費者2執行的快，但是由於設定為round-robin，不會多進行訊息處理

公平分發fairdispatch：

告訴RabbitMQ不要同時將多個訊息分派給一個工作者，換句話說，在某個工作者處理完一條訊息並確認它之前，RabbitMQ不會給該工作者分派新的訊息，而是將新的訊息分派給下一個不是很繁忙的工作者 這就是fair dispatch

//如果不設定，預設是round-robin

factory.setPrefetchCount(1);

並且註釋掉（為什麼要註釋掉呢？）

factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);

結果：

消費者1：

消費者2：

可以看到目前是fairdispatch方式

訊息應答和訊息持久化

注意以下兩點：

1. 自動應答

為true說明佇列把訊息給消費者之後就將訊息從其記憶體中刪除。如果殺掉正在執行任務的消費者，就會丟失訊息。

為false，關閉自動應答，說明佇列把訊息給消費者之後要等待消費者的確認處理完成訊息。如果未收到消費者的確認處理完成訊息，就會分發給其他消費者，保證訊息不丟失。

factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);

2. 訊息持久化

如果rabbitmq掛了，那麼儲存在記憶體中的訊息就會丟失了，這裡涉及到durable的問題。將佇列設定為durable實現訊息持久化

    @Bean

    public Queue queue(){

        return new Queue(QUEUE_NAME,true);

    }

參考：