rabbitmq java demo详解

时间：2014-04-29 13:38:21 收藏：0 阅读：531

补充：做下面的例子前，需要先安装 rabbitmq-server-3.3.0.exe 服务器。资源我已经上传

安装以后启动服务器就可以了

下面文章出自：http://blog.csdn.net/mydreamongo/article/details/8272025

请保护正版：

abbitMQ是一个在AMQP基础上完整的，可服用的企业消息系统。他遵循Mozilla Public License 开源协议。

关于amqp可参考http://www.oschina.net/p/rabbitmq/

rabbitmq是一个消费的代理；通过生产者客户端生产一个信息，转送给消费者客户端;在这个传输过程中，根据你的需要可以经过路由、缓冲、持久化来得到这个消息。

先通过一个例子开始：通过rabbitmq输出"Hello World!"

其中P代表生产者、C表示消费者、中间红色部分代表消息队列

生产者客户端的发送消息程序如下：

Java代码  

package com.abin.test;  

import java.io.IOException;  

import com.rabbitmq.client.Channel;  

import com.rabbitmq.client.Connection;  

import com.rabbitmq.client.ConnectionFactory;  

public class Send {  

    private final static String QUEUE_NAME = "hello";  

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

        ConnectionFactory factory = new ConnectionFactory();  

        factory.setHost("localhost");  

        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();  

    }  

}

运行结果如下：

Java代码  

[x] Sent ‘Hello World!‘  

消费者客户端接收消息程序如下：

Java代码  

package com.abin.test;  

import com.rabbitmq.client.Channel;  

import com.rabbitmq.client.Connection;  

import com.rabbitmq.client.ConnectionFactory;  

import com.rabbitmq.client.QueueingConsumer;  

public class Reqv {  

    private final static String QUEUE_NAME = "hello";  

    public static void main(String[] argv) throws Exception {  

        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 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 + "‘");  

        }  

    }  

}

运行程序得到的结果如下：

Java代码  

[*] Waiting for messages. To exit press CTRL+C  

[x] Received ‘Hello World!‘  