輪詢分發消息演示：啟動兩個工作線程，一個消息發送線程，我們來看看兩個工作線程是如何工作的。 <br/> 步驟如下： **1. 工具類** ```java public class RabbitMQUtils { /** * 連接RabbitMQ服務器 */ public static Channel getChannel() throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("192.168.0.107"); factory.setUsername("admin"); factory.setPassword("admin"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); return channel; } } ``` **2. 啟動兩個工作線程** ```java public class Worker01 { private static final String QUEUE_NAME = "hello"; public static void main(String[] args) throws Exception { Channel channel = RabbitMQUtils.getChannel(); DeliverCallback deliverCallback = (consumerTag, delivery) -> { String receivedMessage = new String(delivery.getBody()); System.out.println("接收到消息:" + receivedMessage); }; CancelCallback cancelCallback = (consumerTag) -> { System.out.println(consumerTag + "消費者取消消費接口回調邏輯"); }; System.out.println("C1 消費者啟動等待消費......"); channel.basicConsume(QUEUE_NAME, true, deliverCallback, cancelCallback); } } ``` 按照下面步驟使用同一個Worker01來模擬啟動兩個工作線程。    **3. 啟動一個消息發送線程** ```java public class Task01 { private static final String QUEUE_NAME = "hello"; public static void main(String[] args) throws Exception { try (Channel channel = RabbitMQUtils.getChannel();) { channel.queueDeclare(QUEUE_NAME, false, false, false, null); //從控制臺當中接受信息 Scanner scanner = new Scanner(System.in); while (scanner.hasNext()) { String message = scanner.next(); channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println("發送消息完成:" + message); } } } } ``` **4. 測試** （1）生產者生產4條消息。  （2）兩個消費者消費到的消息。   通過程序執行發現生產者總共發送 4 個消息，消費者 1 和消費者 2 分別分得兩個消息，并且是按照有序的一個接收一次消息。