RabbitMQ学习系列 二 “Hello World”

public class Send {
    private final static String QUEUE_NAME="hello";

    public static void main(String[] args) throws IOException, TimeoutException {
        /*创建连接工厂*/
        ConnectionFactory connectionFactory = new ConnectionFactory();
        connectionFactory.setHost("localhost");
        Connection connection = connectionFactory.newConnection();
        /*创建频道*/
        Channel channel = connection.createChannel();
        /*声明一个队列*/
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        String message = "HJW,Hello World!";
        /*发布消息*/
        channel.basicPublish("",QUEUE_NAME,null,message.getBytes());

        channel.close();
        connection.close();
    }
}

public class Recv {
    private final static String QUEUE_NAME ="hello";

    public static void main(String[] args) throws IOException, TimeoutException {
        /*创建连接工厂*/
        ConnectionFactory connectionFactory = new ConnectionFactory();
        /*设置Rabbitmq主机地址，用户名密码与端口。用户名密码与端口可不设置可以使用默认*/
        connectionFactory.setHost("localhost");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setPort(5672);
        Connection connection = connectionFactory.newConnection();
        /*通过连接创建频道*/
        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 message = new String(body,"UTF-8");
                System.out.println(" Message is received: " + message );
            }
        };
        /*订阅消息并消费*/
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}