RabbitMQ基础（一）——基本概念和HelloWorld

package com.belonk.rmq.helloworld;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * Created by sun on 2018/1/17.
 *
 * @author sunfuchang03@126.com
 * @version 1.0
 * @since 1.0
 */
public class Sender {
    /**
     * 队列名称
     */
    public static final String QUEUE_NAME = "helloworld";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 创建连接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        // 连接到本地server
        connectionFactory.setHost("localhost");
        // 创建连接
        Connection connection = connectionFactory.newConnection();
        // 创建通道，API通过通道完成相关任务
        Channel channel = connection.createChannel();
        // 创建队列，该队列非持久(服务器重启后依然存在)、非独占(非仅用于此链接)、非自动删除(服务器将不再使用的队列删除)
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String msg = "hello, rabbit mq. 你好，rabbit mq.";
        // 发布消息
        channel.basicPublish("", QUEUE_NAME, null, msg.getBytes("utf-8"));
        System.out.println("Sent "" + msg + "".");;
        channel.close();
        connection.close();
    }
}

package com.belonk.rmq.helloworld;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * Created by sun on 2018/1/17.
 *
 * @author sunfuchang03@126.com
 * @version 1.0
 * @since 1.0
 */
public class Receiver {
    public static void main(String[] args) throws IOException, TimeoutException {
        // 创建连接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        // 连接到本地server
        connectionFactory.setHost("localhost");
        // 创建连接
        Connection connection = connectionFactory.newConnection();
        // 创建通道，API通过通道完成相关任务
        Channel channel = connection.createChannel();
        // 创建队列
        channel.queueDeclare(Sender.QUEUE_NAME, false, false, false, null);
        System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
        // 创建消费者，阻塞接收消息
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("consumerTag : " + consumerTag);
                System.out.println("exchange : " + envelope.getExchange());
                System.out.println("routing key : " + envelope.getRoutingKey());
                String msg = new String(body, "utf-8");
                System.out.println("Received "" + msg + "".");
            }
        };
        channel.basicConsume(Sender.QUEUE_NAME, consumer);
//        channel.close();
//        connection.close();
    }
}