RabbitMQ 快速入门

编写消费者代码

具体步骤：

1. 建立连接
2. 创建信道
3. 声明队列
4. 消费消息
5. 释放资源

public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {
    //1.建立连接
    ConnectionFactory connectionFactory = new ConnectionFactory();
    connectionFactory.setHost("localhost");
    connectionFactory.setPort(5672);
    connectionFactory.setUsername("admin");
    connectionFactory.setPassword("admin");
    connectionFactory.setVirtualHost("study");
    Connection connection = connectionFactory.newConnection();
    //2.创建 Channel
    Channel channel = connection.createChannel();
    //3.声明队列（可以省略）
    channel.queueDeclare("hello",true,false,false,null);
    //4.消费消息
    DefaultConsumer consumer = new DefaultConsumer(channel){
        //从队列中收到消息，就会执行的方法
        @Override
        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
            System.out.println("接收到消息：" + new String(body));
        }
    };
    /**
     * String basicConsume(String queue, boolean autoAck, Consumer callback) throws IOException;
     * 参数说明：
     * queue：队列名称
     * autoAck：是否自动确认
     * callback：接收到消息后，执行的逻辑
     */
    channel.basicConsume("hello",true,consumer);
    //等待程序完成
    Thread.sleep(5000);
    //5.释放资源
    channel.close();
    connection.close();
}