首页 > 代码库 > RabbitMQ - 介绍
RabbitMQ - 介绍
RabbitMQ是个健壮、易用、开源、支持多种操作系统和语言的message broker。
当然，一切的前提是机器里面正在运行着rabbitmq-server。
点击下面的图片下载：
rabbitMQ和AMQP的关系是什么样的？rabbitMQ负责哪部分?
如图所示，就是provider和consumer之间那一块。
message broker，比如ActiveMQ、RabbitMQ什么的，简单而言就是可以收发消息的。
我跟着官方的Tutorial简单写一个Hello World。
实现一个producer到queue到consumer的小程序。
不要忘了添加java client ：
<dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.3.4</version></dependency>
provider：
private final static String QUEUE_NAME = "hello"; public static void main(String[] args) throws IOException { //创建Connection 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!"; System.out.println(" [x] Sent ‘" + message + "‘"); channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); channel.close(); connection.close(); }
Receiver的步骤与provider大致相同，只需要注意QUEUE_NAME要相同：
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); 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 + "‘" + new Date()); }}
如果不出意外的话，consumer可以正常打印出"Hello World!"。
(PS：磁盘太满也可能导致消息无法接收，可以在配置文件中设置disk_free_limit项。)
RabbitMQ - 介绍
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。