package rabbitmq;

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

public class Send {

     private final static String QUEUE_NAME = "hello";

      public static void main(String[] args) throws java.io.IOException {

            /**

             * 创建连接连接到MabbitMQ

             */

            ConnectionFactory factory = new ConnectionFactory();

            // 设置MabbitMQ所在主机ip或者主机名

            factory.setHost("123.206.216.31");

            factory.setPort(5672);

            factory.setUsername("admin");

            factory.setPassword("admin");

            // 创建一个连接

            Connection connection = factory.newConnection();

            // 创建一个频道

            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(" [x] Sent '" + message + "'");

            // 关闭频道和连接

            channel.close();

            connection.close();

        }  

}

package rabbitmq;

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import java.io.IOException;

import com.rabbitmq.client.AMQP;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Consumer;

import com.rabbitmq.client.DefaultConsumer;

import com.rabbitmq.client.Envelope;

import com.rabbitmq.client.QueueingConsumer;

public class Recv {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws java.io.IOException, java.lang.InterruptedException  {

        // TODO Auto-generated method stub

         ConnectionFactory factory = new ConnectionFactory();

            factory.setHost("123.206.216.31");

            factory.setPort(5672);

            factory.setUsername("admin");

            factory.setPassword("admin");

            // 打开连接和创建频道，与发送端一样

            Connection connection = factory.newConnection();

            Channel channel = connection.createChannel();  

            // 声明队列，主要为了防止消息接收者先运行此程序，队列还不存在时创建队列。

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

            // 创建队列消费者  

            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

            // 指定消费队列

            // 指定消费队列

            QueueingConsumer consumer = new QueueingConsumer(channel);

            channel.basicConsume(QUEUE_NAME, true, consumer);

            while(true){

                QueueingConsumer.Delivery delivery = consumer.nextDelivery();

                String message = new String(delivery.getBody());

                System.out.println(" [x] Received '" + message + "'");

            }  

    }

}