rabbitMq之:Hello World!
2015-11-23 18:08
260 查看
pom.xml
jar包
发送消息:Send.java
RabbitMqParm.HOST如果把rabbitMq装在本机了,就写“localhost”,本人把rabbitMq搭在阿里云服务器了,所以就是相应的外网ip
接收消息:Recv.java
运行Send.java后,到http://ip:15672/ 界面可看到已经创建了一个名为simple-queue的queue
![](https://img-blog.csdn.net/20151123180623960)
点进去,看到有消息发送过来:
![](https://img-blog.csdn.net/20151123180656101)
启动Recv.java以后,消息被消费:
jar包
<dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.5.6</version> </dependency> <dependency> <groupId>commons-lang</groupId> <artifactId>commons-lang</artifactId> <version>2.6</version> </dependency>
发送消息:Send.java
RabbitMqParm.HOST如果把rabbitMq装在本机了,就写“localhost”,本人把rabbitMq搭在阿里云服务器了,所以就是相应的外网ip
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.zheng.model.RabbitMqParm; public class Send { private final static String QUEUE_NAME = "simple-queue"; public static void main(String[] argv) throws java.io.IOException, TimeoutException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(RabbitMqParm.HOST); Connection 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("发送的消息:" + message + "'"); channel.close(); connection.close(); } }
接收消息:Recv.java
import com.rabbitmq.client.*; import com.zheng.model.RabbitMqParm; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.concurrent.TimeoutException; public class Recv { private static final Logger logger = LoggerFactory.getLogger(Recv.class); private final static String QUEUE_NAME = "simple-queue"; public static void main(String[] argv) throws TimeoutException, IOException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(RabbitMqParm.HOST); Connection connection = factory.newConnection();//建立tcp连接 Channel channel = connection.createChannel(); channel.queueDeclare(QUEUE_NAME, false, false, false, null); 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("接收到的消息" + message ); } }; channel.basicConsume(QUEUE_NAME, true, consumer); } }
运行Send.java后,到http://ip:15672/ 界面可看到已经创建了一个名为simple-queue的queue
点进去,看到有消息发送过来:
启动Recv.java以后,消息被消费:
相关文章推荐
- Rabbitmq集群搭建笔记
- python使用rabbitmq实现网络爬虫示例
- Linux下PHP扩展amqp安装
- rabbitmq学习
- CentOS6.5 安装rabbitmq
- 非常不错的rabbitmq集群高可用部署
- Rabbitmq 安装与配置
- rabbitmq可靠性保证(原文加上部分标记)
- rabbitmq流控制(原文标记)
- win7安装RabbitMQ
- AMQP协议
- RabbitMQ 系列——1.初始
- rabbitMQ安装
- rabbitmq——用户管理
- rabbitmq 消息传送与监听
- rabbitmq 消息传送与监听
- [翻译] [RabbitMQ+Python入门经典] 兔子和兔子窝
- RabbitMQ的WEB管理器rabbitmq_management
- RabbitMQ修改端口号和心跳时间
- Rabbitmq的网络层浅析