消息中间件RabbitMQ系列，工作模型，一个发送者，多个消费者从队列里面拿数据（七）

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

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

发送者

代码语言：javascript复制

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个消费者

代码语言：javascript复制

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

    }

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

队列 模型 入门

0 人点赞