安装RabbitMQ

1
$ brew install rabbitmq

默认rabbit的命令会被安装到/usr/local/sbin下，这个路径默认不在PATH中，你需要手动添加一下。

启动rabbitmq的方法有两种，一种是使用brew命令：

1
$ brew services start rabbitmq

或者手动启动

1
$ rabbitmq-server

默认rabbitmq会建立一个guest用户，密码也是guest，这个用户只能从localhost访问。这个对于我们用于测试学习是够了，如果要建立可以被远程访问的rabbitmq，可以参考access control。

可以访问rabbitmq自带的管理后台查看其运行状态：

Java使用RabbitMQ

添加依赖

1
2
3
4
5
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>3.6.5</version>
</dependency>

编写发送方

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
public class Send {
    public static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws IOException, TimeoutException {

        //建立服务器连接,获取通道
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        //声明一个发送队列
        //声明一个队列是幂等的，仅仅在要声明的队列不存在时才创建
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        String msg = "Hello World!";
        channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());
        System.out.println("Sent msg: "+msg);

        //关闭通道和连接
        channel.close();
        connection.close();
    }
}

编写接收方

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
public class Recv {
    public static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {
        //建立服务器连接,获取通道
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        //声明一个队列
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        System.out.println("Waiting for message...");

        //定义一个消费者
        QueueingConsumer consumer = new QueueingConsumer(channel);
        channel.basicConsume(QUEUE_NAME,true,consumer);

        //从队列中获取消息并消费
        while (true){
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            String msg = new String(delivery.getBody());
            System.out.println("Received msg: "+msg);
        }
    }
}

继续学习

RabbitMQ官网的教程写得非常好，图文并茂，推荐阅读：RabbitMQ - Getting started with RabbitMQ

RabbitMQ技巧

在命令行中查看队列消息

1
$ rabbitmqadmin get queue=hello requeue=false

参考：RabbitMQ - Management Command Line Tool

使用rabbitmq_tracing插件记录消息收发日志

1
$ rabbitmq-plugins enable rabbitmq_tracing

然后RabbitMQ Management管理后台中就可以看日志了：

（图片引用自，http://www.cnblogs.com/gossip/p/4517345.html）

参考资料