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

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

发送者

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));
            }
        });

    }

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