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

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

    }
}

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

    }