RabbitMQ-二、安装部署
2016-11-03 17:57
239 查看
二、安装部署
Windows下RabbitMQ的安装下载Erlang,地址:http://www.erlang.org/download/otp_win64_R15B.exe,双击安装即可(首先装)
下载RabbitMQ,地址:http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.4/rabbitmq-server-3.3.4.exe,双击安装即可
【Windows上安装Erlang和RabbitMQ安装路径最好默认】
Javarabbitmq_client.jar包引入
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.6.5</version>
</dependency>
RabbitMQ安装完成后,安装目录sbin会有:rabbitmq-server.bat
在cmd下:进入sbin目录,运行rabbitmq-server start
rabbitmq常用命令
rabbitmqctl status 查看状态rabbitmqctllist_queues查看所有队列信息
hello world
一个producer发送消息,一个接收者接收消息,并在控制台打印出来发送端:producer1.java 连接到RabbitMQ(此时服务需要启动),发送一条数据,然后退出。
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class producer1 { //队列名称 private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); //创建连接连接到MabbitMQ //设置MabbitMQ所在主机ip或者主机名 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(); } }
值得注意的是队列只会在它不存在的时候创建,多次声明并不会重复创建。信息的内容是字节数组,也就意味着你可以传递任何数据。
接收端:consumer1.java不断等待服务器推送消息,然后在控制台输出。
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.QueueingConsumer; public class consumer1 { //队列名称 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) { //nextDelivery是一个阻塞方法(内部实现其实是阻塞队列的take方法) QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message = new String(delivery.getBody()); System.out.println(" [x] Received '" + message + "'"); } } }
分别运行Send.java和Recv.java 顺序无所谓。前提RabbitMQ服务开启。
运行结果:
[x]Sent 'hello world!'
----------------------------------------
[*] Waiting for messages. To exitpress CTRL+C
[x] Received 'hello world!'
原文:http://blog.csdn.net/lmj623565791/article/details/37607165
相关文章推荐
- Red Hat安装部署Rabbitmq
- RHEL7安装部署RabbitMQ
- RabbitMQ之Windows下的安装部署
- Docker:安装部署RabbitMQ
- rabbitmq 3.6.15 yum安装部署
- MQ-RabbitMq部署安装配置
- Linux下安装部署RabbitMQ
- Windows下RabbitMQ安装,部署,配置
- RabbitMQ---1、安装与部署
- RabbitMQ安装部署文档
- rabbitMQ安装及部署
- ubuntu14.04 rabbitmq安装、线上部署及允许其他ip地址访问
- RabbitMQ的安装部署
- Windows下RabbitMQ安装,部署,配置
- 消息队列_RabbitMQ-0001.RabbitMQ消息代理/队列服务器快速安装部署?
- Docker实战:Docker安装部署RabbitMQ
- [部署篇1]VMWare搭建Openstack——控制节点的基础环境和RabbitMQ消息服务器安装
- RabbitMQ指南(3)-安装部署
- Docker 安装部署RabbitMQ
- RabbitMQ介绍及安装部署