<dependency>

      <groupId>com.rabbitmq</groupId>

      <artifactId>amqp-client</artifactId>

      <version>4.2.0</version>

    </dependency>

    <dependency>

      <groupId>org.slf4j</groupId>

      <artifactId>slf4j-simple</artifactId>

      <version>1.7.25</version>

    </dependency>

   //创建队列，发送消息

    public static void sendMessage() throws Exception {

        //获取连接

        Connection connection = MessageUitl.getConnection();

        //创建通道

        Channel channel = connection.createChannel();

        //声明创建队列

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        //消息内容

        String message = "Hello World!";

        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());

        System.out.println("发送消息：" + message);

        //关闭连接和通道

        channel.close();

        connection.close();

    }

    //消费者消费消息

    public static void receiver() throws Exception {

        //获取连接和通道

        Connection connection = MessageUitl.getConnection();

        Channel channel = connection.createChannel();

        //声明通道

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        Consumer consumer = new DefaultConsumer(channel) {

            @Override

            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String msg = new String(body, "UTF-8");

                System.out.println("接收到的消息：" + msg);

            }

        };

        channel.basicConsume(QUEUE_NAME, consumer);

    }