rabbitmq java demo详解
标签：rabbitmq
补充：做下面的例子前，需要先安装 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!‘
rabbitmq java demo详解
标签：rabbitmq
原文地址：http://blog.csdn.net/wangyonglin1123/article/details/24643277
评论