轮询分发消息演示：启动两个工作线程，一个消息发送线程，我们来看看两个工作线程是如何工作的。 <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 分别分得两个消息，并且是按照有序的一个接收一次消息。