RabbitMQ消息队列(二):”Hello, World“

本文将使用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。

  • On Ubuntu:

    $ sudo apt-get install python-pip git-core
    
  • On Debian:
    $ sudo apt-get install python-setuptools git-core
    $ sudo easy_install pip
    
  • On Windows:To install easy_install, run the MS Windows Installer for setuptools
    > easy_install pip
    > pip install pika==0.9.8
    

    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

时间: 2024-10-06 12:42:44

RabbitMQ消息队列(二):”Hello, World“的相关文章

(转)(二)RabbitMQ消息队列-RabbitMQ消息队列架构与基本概念

http://blog.csdn.net/super_rd/article/details/70238869 没错我还是没有讲怎么安装和写一个HelloWord,不过快了,这一章我们先了解下RabbitMQ的基本概念. RabbitMQ架构 说是架构其实更像是应用场景下的架构(自己画的有点丑,勿嫌弃) 从图中可以看出RabbitMQ主要由Exchange和Queue两部分组成,然后通过RoutingKey关联起来,消息投递到Exchange然后通过Queue接收. RabbitMQ消息队列基本概

RabbitMQ消息队列应用

RabbitMQ消息队列应用 消息通信组件Net分布式系统的核心中间件之一,应用与系统高并发,各个组件之间解耦的依赖的场景.本框架采用消息队列中间件主要应用于两方面:一是解决部分高并发的业务处理:二是通过消息队列传输系统日志.目前业界使用较多的消息队列组件有RabbitMQ.ActiveMQ.MSMQ.kafka.zeroMQ等,本文对系统架构之MQ Component诠释,并采用RabbitMQ作为消息队列中间件. 图1- 消息队列组件示意图 一.RabbitMQ介绍 RabbitMQ是一款基

RabbitMQ 消息队列 应用

安装参考    详细介绍   学习参考 RabbitMQ 消息队列 RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统.他遵循Mozilla Public License开源协议. MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法.应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们.消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术.

(转)RabbitMQ消息队列(六):使用主题进行消息分发

在上篇文章RabbitMQ消息队列(五):Routing 消息路由 中,我们实现了一个简单的日志系统.Consumer可以监听不同severity的log.但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity设定.不支持更多的标准. 比如syslog unix的日志工具,它可以通过severity (info/warn/crit...) 和模块(auth/cron/kern...).这可能更是我们想要的:我们可以仅仅需要cron模块的log. 为了实现类似的功能,我们需

RabbitMQ消息队列(六):使用主题进行消息分发

在上篇文章RabbitMQ消息队列(五):Routing 消息路由 中,我们实现了一个简单的日志系统.Consumer可以监听不同severity的log.但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity设定.不支持更多的标准. 比如syslog unix的日志工具,它可以通过severity (info/warn/crit...) 和模块(auth/cron/kern...).这可能更是我们想要的:我们可以仅仅需要cron模块的log. 为了实现类似的功能,我们需

(转)RabbitMQ消息队列(九):Publisher的消息确认机制

在前面的文章中提到了queue和consumer之间的消息确认机制:通过设置ack.那么Publisher能不到知道他post的Message有没有到达queue,甚至更近一步,是否被某个Consumer处理呢?毕竟对于一些非常重要的数据,可能Publisher需要确认某个消息已经被正确处理. 在我们的系统中,我们没有是实现这种确认,也就是说,不管Message是否被Consume了,Publisher不会去care.他只是将自己的状态publish给上层,由上层的逻辑去处理.如果Message

(转)RabbitMQ消息队列(七):适用于云计算集群的远程调用(RPC)

在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成.那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例. 1. 客户端接口 Client interface 为了展示一个RPC服务是如何使用的,我们将创建一段很简单的客户端class. 它将会向外提供名字为call的函数,这个call会发送RPC请求并且阻塞知道收到RPC运算的结果.代码如下: [python] vie

RabbitMQ消息队列(九):Publisher的消息确认机制

在前面的文章中提到了queue和consumer之间的消息确认机制:通过设置ack.那么Publisher能不到知道他post的Message有没有到达queue,甚至更近一步,是否被某个Consumer处理呢?毕竟对于一些非常重要的数据,可能Publisher需要确认某个消息已经被正确处理. 在我们的系统中,我们没有是实现这种确认,也就是说,不管Message是否被Consume了,Publisher不会去care.他只是将自己的状态publish给上层,由上层的逻辑去处理.如果Message

RabbitMQ消息队列1: Detailed Introduction 详细介绍

1. 历史 RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现.AMQP 的出现其实也是应了广大人民群众的需求,虽然在同步消息通讯的世界里有很多公开标准(如 COBAR的 IIOP ,或者是 SOAP 等),但是在异步消息处理中却不是这样,只有大企业有一些商业实现(如微软的 MSMQ ,IBM 的 Websphere MQ 等),因此,在 2006 年的 6 月,Cisco .Redhat.iMatix 等联合制定了 AMQP 的公开标

rabbitmq 消息队列

rabbitmq 消息队列: 解耦:降低一个程序降低耦合性 异步: 优点:--解决排队的问题. --解决资源浪费的问题.   --讲要处理的事物,进行存放,集中处理. 缺点:--不能保证任务被及时执行 应该场景:--去哪儿网 --12306 同步: 优点:--可以保证任务被及时执行 缺点:--排队问题,占用资源,造成资源浪费 大并发: web环境: --Nginx (epoll模式)   10000-20000 --Apache(epoll模式)1000-2000 pv = page visit