<== RabbitMQ消息队列(一): Detailed Introduction 详细介绍
本文将使用Python(pika 0.9.8)实现从Producer到Consumer传递数据”Hello, World“。
首先复习一下上篇所学:RabbitMQ实现了AMQP定义的消息队列。它实现的功能”非常简单“:从Producer接收数据然后传递到Consumer。它能保证多并发,数据安全传递,可扩展。
和任何的Hello world一样,它们都不复杂。我们将会设计两个程序,一个发送Hello world,另一个接收这个数据并且打印到屏幕。
整体的设计如下图:
1. 环境配置
RabbitMQ 实现了AMQP。因此,我们需要安装AMPQ的library。幸运的是对于多种编程语言都有实现。我们可以使用以下lib的任何一个:
在这里我们将使用pika. 可以通过
pip 包管理工具来安装:
$ sudo pip install pika==0.9.8
这个安装依赖于pip和git-core。
2. Sending
第一个program send.py:发送Hello world 到queue。正如我们在上篇文章提到的,你程序的第一句话就是建立连接,第二句话就是创建channel:
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
'localhost'))
channel = connection.channel()
创建连接传入的参数就是RabbitMQ Server的ip或者name。
关于谁创建queue,上篇文章也讨论过:Producer和Consumer都应该去创建。
接下来我们创建名字为hello的queue:
channel.queue_declare(queue='hello')
创建了channel,我们可以通过相应的命令来list queue:
$ sudo rabbitmqctl list_queues
Listing queues ...
hello 0
...done.
现在我们已经准备好了发送了。
从架构图可以看出,Producer只能发送到exchange,它是不能直接发送到queue的。现在我们使用默认的exchange(名字是空字符)。这个默认的exchange允许我们发送给指定的queue。routing_key就是指定的queue名字。
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print " [x] Sent 'Hello World!'"
退出前别忘了关闭connection。
connection.close()
3. Receiving
第二个program receive.py 将从queue中获取Message并且打印到屏幕。
第一步还是创建connection。第二步创建channel。第三步创建queue,name = hello:
channel.queue_declare(queue='hello')
接下来要subscribe了。在这之前,需要声明一个回调函数来处理接收到的数据。
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
subscribe:
channel.basic_consume(callback,
queue='hello',
no_ack=True)
最后,准备好无限循环监听吧:
print ' [*] Waiting for messages. To exit press CTRL+C'
channel.start_consuming()
4. 最终版本
send.py:
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()
receive.py:
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
print ' [*] Waiting for messages. To exit press CTRL+C'
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
channel.start_consuming()
5. 最终运行
先运行 send.py program:
$ python send.py
[x] Sent 'Hello World!'
send.py 每次运行完都会停止。注意:现在数据已经存到queue里了。接收它:
$ python receive.py
[*] Waiting for messages. To exit press CTRL+C
[x] Received 'Hello World!'
接下来,就要奉上更接近实际环境的例子。取决与我的课余时间啊。。。
尊重原创,转载请注明出处 anzhsoft: http://blog.csdn.net/anzhsoft/article/details/19570187
参考文献:
1. http://www.rabbitmq.com/tutorials/tutorial-one-python.html
分享到:
相关推荐
rabbitMQ官方Demo,包含01HelloWorld,02WorkQueues,03PublishSubscribe,04Routing,05Topics,06RPC六个示例
rabbitmq-java-helloworld 只是第一个rabbitmq的例子 => hello world 消费者不能关闭连接,需要一直轮询查看是否存在消息 rabbitmq-java-queque rabbitmq任务队列示例 rabbitmq-java-publish-receive rabbitmq发布...
基于RabbitMQ实现的HelloWorld消息队列实现,入门级别
4、Hello World 5、work 模式. j! Z2 v2 e. j* r1 R2 R 6、消息确认 7、Publish_Subscribe发布订阅模式3 d) y5 t6 A1 R 8、route 路由模式1 W. q/ p. b0 C 9、topic模式 10、整合spring方式-1 11、整合sring方式-2 ...
http://blog.csdn.net/lmj623565791/article/category/2386657 提供了很多代码示例,代码中的01-05分别为:hello world、工作队列、发布订阅、路由选择和主题
Jackrabbit是一个非常有思想的抽象,建立在amqplib之上,专注于可用性并在RabbitMQ上实现了几种消息传递模式。简单的例子// producer.js'use strict' ;const jackrabbit = require ( '@pager/jackrabbit' ) ;const ...
mongodb-hello-world:介绍 MongoDB Java API 基本用法的项目。 mongodb-发布-订阅: mongodb-路由: mongodb-rpc: mongodb 主题: mongodb-工作队列: 基准测试 mongodb 基准测试: 执照 RabbitMQ 示例在 GNU...
用于完成 RabbitMQ 的 HelloWorld 案例
java-helloworld只是第一个rabbitmq的例子 => hello world消费者不能关闭连接,需要一直轮询查看是否存在消息rabbitmq-java-quequerabbitmq任务队列示例rabbitmq-java-publish-receiverabbitmq发布订阅示例rabbitmq-...
创建作业,将工作消息放在 RabbitMQ 队列中。 如何使用 下载、安装和运行 RabbitMQ。 编译项目然后运行 com.vanillaci.api.ApiApplication 运行工人 将以下文件发布到 /job url。 现在发布到以下 URL 以运行...
RabbitMQ是一个消息代理,核心原理:发送消息,接收消息...首先通过一个非常简单的”helloworld“例子介绍如何使用RabbitMQ,然后再介绍其涉及的基本概念并对交换机和队列多做点介绍。本例非常简单——发送一个消息”h
RabbitMQController RabbitMQController类用于通过RabbitMQ连接,公开和使用消息的简便方法。 要使用该类,您将需要... send_to_exchange ( "hello world" , "test_exchange" , "test" )rabbit . close_connection ()
样本 (如果您有任何要分享的示例,请提交PR以便将其添加到列表中!) 科达2.0 Azure服务总线队列 ...Azure通过Azure队列功能使Hello World正常运行 Azure队列存储中的Python作业 .Net作业与Azure存储队列 外
它是快速微服务原型制作的理想选择它使用合理的默认值来创建队列和交换重试无法处理的消息它将未处理的消息存储到死队列中,以供以后检查安装将此行添加到您的应用程序的Gemfile中: gem "rt-tackle" , :require =>...
3、RabbitMQMessageBus:一个 RabbitMQ 消息总线实现。4、AzureServiceBusMessageBus:一个Azure Service消息总线实现。例子using Foundatio.Messaging;public class Program{ public static void Main...