java版RabbitMQ的hello world实现
2017-11-27 11:14
399 查看
windows安装RabbitMq:
http://blog.csdn.net/leisure_life/article/details/78642799
官网教程:http://www.rabbitmq.com/tutorials/tutorial-one-java.html
请确保正确安装了上述环境并使之处于运行状态
一下教程是根据官网教程操作的步骤
建一个Java项目,根据官网提示下载相应jar包:
jar包地址:
amqp-client-4.0.2.jar
slf4j-api-1.7.21.jar
slf4j-simple-1.7.22.jar
http://blog.csdn.net/leisure_life/article/details/78642799
官网教程:http://www.rabbitmq.com/tutorials/tutorial-one-java.html
请确保正确安装了上述环境并使之处于运行状态
一下教程是根据官网教程操作的步骤
建一个Java项目,根据官网提示下载相应jar包:
jar包地址:
amqp-client-4.0.2.jar
slf4j-api-1.7.21.jar
slf4j-simple-1.7.22.jar
代码
send.java
package com.adtec.rabbitmq; 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[] 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); String message = "Hello World!"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); System.out.println(" [x] Sent '" + message + "'"); channel.close(); connection.close(); } }
Recv.java
package com.adtec.rabbitmq; import com.rabbitmq.client.*; import java.io.IOException; public class Recv { 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"); Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume(QUEUE_NAME, true, consumer); } }
运行send.java结果
[x] Sent 'Hello World!'
运行Recv.java结果
[*] Waiting for messages. To exit press CTRL+C [x] Received 'Hello World!'
相关文章推荐
- java实现rabbitmq消息的发送接受
- java jni实现hello world
- rabbitmq的java简单的实现
- RabbitMQ实例教程:Hello RabbitMQ World之Java实现
- 使用Java中的JNI技术将C/C++程序嵌入到Java代码中实现Hello World
- java 实现利用 RabbitMQ 发送和消费消息
- 用Java实现Hello World
- rabbitMQ实战(一)---------使用pika库实现hello world
- rabbitmq 路由 java实现
- RabbitMQ基本功能测试用例(Java实现)
- RabbitMQ入门教程 For Java【1】 - Hello World
- rabbitMQ第二篇:java简单的实现RabbitMQ
- rabbitMQ实战(一)---------使用pika库实现hello world
- RabbitMQ入门教程 For Java【1】 - Hello World
- java实现rabbitmq消息的发送接受
- rabbitmq 主题交换机java 实现
- java实现rabbitmq消息的发送接受
- java实现rabbitmq消息的发送接受
- java第一课:安装环境变量和用记事本实现Hello World
- RabbitMQ(python实现)学习之一:简单两点传输“Hello World”的实现