之前讲解的直连模型，这个只是一个入门，也就是之前的那个只有一个消费者。现在想要一个队列被更多的消费者进行消费，那么现在就有了第二个模型，这个就是工作队列模型

一个队列可以被多个消费者进行消费

发送者

public class provider { @Test public void SendMessage() throws IOException, TimeoutException { Connection connection = RabbitMqUtils.getConnection(); // 创建通道 Channel channel = connection.createChannel(); // 让通道和消息队列进行绑定 channel.queueDeclare("work",true,false,false,null); for (int i = 0; i < 10; i++) { channel.basicPublish("","work", null,(i+"hello work").getBytes()); } RabbitMqUtils.closeConnectionAndChannel(channel,connection); } }

利用循环的代码，在work队列里面创建了10个消息

消费者

创建了2个消费者

public class Customer { public static void main(String[] args) throws IOException, TimeoutException { channel.queueDeclare("work",false,false,false,null); channel.basicConsume("work",true,new DefaultConsumer(channel){ @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { System.out.println("消费者2==="+new String(body)); } }); }

先启动两个消费端，之后启动发送者，看控制台输出的是什么