上一篇部落格的作為rabbitMQ的入門程式，也是簡單佇列模式，一個生產者，一個消費者，今天這篇部落格介紹work模式，一個生產者，多個消費者，下面的例子模擬兩個消費者的情況。

圖示：
        

  一個生產者、兩個消費者；一個訊息只能被一個消費者獲取。

  在work模式中可以分為兩種模式，一種是兩個消費者平均消費佇列中的訊息，即使他們的消費能力是不一樣的，這種似乎不太符合實際的情況。另一種是能者多勞模式，處理訊息能力強的消費者會獲取更多的 訊息，這種模式更符合實際需求。

  生產者：向佇列傳送50條訊息，下面程式碼中，生產者每生產一條訊息後都會休眠一段時間，並且越往後休眠的時間越長。

public class Send {

    private final static String QUEUE_NAME = "test_queue_work";

    public static void main(String[] argv) throws Exception {
        // 獲取到連線以及mq通道
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();

        // 宣告佇列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        for (int i = 0; i < 50; i++) {
            // 訊息內容
            String message = "" + i;
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");

            Thread.sleep(i * 10);
        }

        channel.close();
        connection.close();
    }
}
 

public class Recv {

    private final static String QUEUE_NAME = "test_queue_work";

    public static void main(String[] argv) throws Exception {

        // 獲取到連線以及mq通道
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();

        // 宣告佇列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 同一時刻伺服器只會發一條訊息給消費者
        //channel.basicQos(1);

        // 定義佇列的消費者
        QueueingConsumer consumer = new QueueingConsumer(channel);
        // 監聽佇列，手動返回完成
        channel.basicConsume(QUEUE_NAME, false, consumer);

        // 獲取訊息
        while (true) {
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            String message = new String(delivery.getBody());
            System.out.println(" [x] Received '" + message + "'");
            //休眠
            Thread.sleep(10);
            // 返回確認狀態
            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
        }
    }
}
 

消費者2：休眠時間為1000ms

public class Recv2 {

    private final static String QUEUE_NAME = "test_queue_work";

    public static void main(String[] argv) throws Exception {

        // 獲取到連線以及mq通道
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();

        // 宣告佇列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 同一時刻伺服器只會發一條訊息給消費者
        //channel.basicQos(1);

        // 定義佇列的消費者
        QueueingConsumer consumer = new QueueingConsumer(channel);
        // 監聽佇列，手動返回完成狀態
        channel.basicConsume(QUEUE_NAME, false, consumer);

        // 獲取訊息
        while (true) {
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            String message = new String(delivery.getBody());
            System.out.println(" [x] Received '" + message + "'");
            // 休眠1秒
            Thread.sleep(1000);

            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
        }
    }
}

  我們把每個消費者中的程式碼：channel.basicQos(1);這句程式碼解開註釋會發現消費者2獲取到8條資料，而消費者1獲取到42條訊息。這樣的結果才符合work模式的能者多勞模式。這句程式碼表示伺服器同一時刻只會傳送一條訊息給消費者，但並不指定是哪個消費者，處理能力高的人會接收到更多的訊息。

小結：

  簡單佇列和work 模式的不同：
  簡單佇列只要訊息從佇列中獲取，無論消費者獲取到訊息後是否成功消費，比如遇到狀況：斷電，都認為是訊息已經成功消費；

  work模式消費者從佇列中獲取訊息後，伺服器會將該訊息標記為不可用狀態，等待消費者反饋，如果消費這一直沒有反饋，則該訊息一直處於不可用狀態。

  具體使用哪種模式具體問題具體分析。

  channel.basicConsume(QUEUE_NAME, false, consumer);false表示監聽佇列，手動返回完成狀態，true表示自動返回。