<dependencies>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>5.6.0</version>
        </dependency>
</dependencies>

package com.itheima.producer;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class Producer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //2.设置参数
        factory.setHost("114.115.170.214");
        factory.setPort(5672);
        factory.setVirtualHost("/itcast");
        factory.setUsername("admin");
        factory.setPassword("admin");
        //3.创建连接 Connection
        Connection connection = factory.newConnection();
        //4.创建Channel
        Channel channel = connection.createChannel();
        //5.创建队列Queue
        channel.queueDeclare("denglimei",true,false,false,null);
        //要发送的消息
        String body ="hello rabbitmq~~~";
        //6.发送消息
        channel.basicPublish("","denglimei",null,body.getBytes());
         //7.释放资源
        channel.close();
        connection.close();
    }
}

package com.itheima.consumer;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class Consumer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //2.设置参数
        factory.setHost("114.115.170.214");
        factory.setPort(5672);
        factory.setVirtualHost("/itcast");
        factory.setUsername("admin");
        factory.setPassword("admin");
        //3.创建连接 Connection
        Connection connection = factory.newConnection();
        //4.创建Channel
        Channel channel = connection.createChannel();
        //5.创建队列Queue
        channel.queueDeclare("hello_world",true,false,false,null);
        //匿名内部类
        Consumer consumer = new DefaultConsumer(channel){
            /*
             * 回调方法，当收到消息后，会自动执行该方法
             * 1.consumerTag：标识
             * 2.envelope：获取一些信息，交换机，路由key
             * 3.properties：配置信息
             * 4.body：数据
             * */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                                       byte[] body) throws IOException {
                long start = System.currentTimeMillis();
                for (int i = 0; i < 10000; i++) {
                    System.out.println("第"+i+"条");
                }
                long end = System.currentTimeMillis();
                System.out.println(start-end);
            }
        };
        //接收消息
        channel.basicConsume("hello_world",true,consumer);
        //注意：消费者作为监听者，不要去关闭资源，否则如何监听资源？
    }
}