rabbitmq python 搭建和测试文档

1、今天简单学习了rabbitmq 原因是因为有个同学要做网站的快照，所以进而谈到了对了顺便学习了下 rabbitmq准备 因为我要用python做个简单的接口所以 软件环境如下python 环境python 2.6zlibzlib-develpensslopenssl-devel , 并且要修改yum /usr/bin/yum 讲最上方的python 路径改成 /usr/bin/python2.4 这样保证yum可用然后安装pyton2.6 这里装到了 /usr/local/python2.6 然后更新系统python ln -s /usr/bin/python /usr/local/pytho

2、n2.6/bin/python 并且备份原有的python2. 因为python 调用 rabbitmq 需要安装pika 所以就需要安装 pip 准备安装setuptools/pypi/setuptools/#downloads点击 bitbutcket repo 去下载一个解压然后安装解压后注意安装其中的 ez_install.py 就可以安装easy_install 了 安装好之后 去到/usr/local/pyton2.6中看下已经可以了 ，然后就是安装pip很简单 到pip官网上 去找个get-pip.py 这个东西下载下来然后直接 用py

3、thon 运行他 就可以安装了 这个也会帮你安装setuptoolspip是python的包管理工具类似于 nodejs 的npm 安装好之后就可以安装pika 了 直接到pip所在的目录运行pip piks=0.9.8python的准备工作做完了安装rabbitmqrabbitmq 有几个重要的组建 simplejson 这个是存储的数据格式需要的库，erlang（一个语言环境必须) ，amqclient (rabbitmq客户端)我是这样安装的erlang下载所需的源码：wget /download/otp_src_R13B04.tar.gz解压源码：tar

4、 xzf otp_src_R13B04.tar.gz进入解压后生产的目录：cd otp_src_R13B04安装前配置：./configure -prefix=/opt/erlang（此条命令下面有修改）make & make install建立软连ln-s /opt/erlang/bin/erl /usr/bin/erl#seterlangenvironmentexportPATH=$PATH:/opt/erlang/bin 至于这两句我觉的没用 因为/etc/profile 运行了这两句 并没有任何增加的内容simplejson安装1. cd/2. wgethttp:/pypi.pytho

5、/packages/source/s/simplejson/simplejson-下载simplejson3. tarzxvfsimplejson-2.4.0.tar.gz解压缩文件4. cdsimplejson-2.4.0，pythonsetup.pyinstall。这是由于simplejson是依赖python脚本以上必须要保证 python bin目录下有easy_install 否则不成功安装rabbitmq到官方去下载或者wget/releases/rabbitmq-server/v2.7.1/rabbitmq-server-ge

6、neric-unix-2.7.1.tar.gztar zxvf rabbitmq_server-2.7.1.tar.gz -C /opt这时候在opt 目录会有个rabbitmq_server-2.7.1 至于网上从这下面有两部 建立目录软连接 我觉的没必要 按照他们的方式也是建立不成功的 忽悠人的我是直接计入 /opt/rabbitmq_server-2.7.1 目录 进行设置的其中 rabbitmqctl 是停止用的rabbitmq_server 是启动用的至此 rabbitmq其实已经安装成功了 我们使用的是他的默认配置 如果项配置大家可以自己查查资料此外 有个管理系统 rabbitmq

7、是插件形式的所有的应用都是以插件形式介入的 这些插件在你安装目录/opt/rabbitmq_server-2.7.1/plugins 有个*.ez的文件都是启动管理系统到rabbitmq安装目录./rabbitmq-plugins enable rabbitmq_management然后启动 rabbitmq-server -detached 可以实现后台启动我们通过localhost:55672访问管理系统 如图管理系统主要是管理队列的列表 监控队列的状态等等 。我应用官方的python 写了个收发程序import pikaconnection = pika.BlockingConnecti

8、on(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()存储为 send.py在存储一个recievie.py 内容如下import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters( host=localhost)channel = connection.channel()channel.queue_declare(queue=hello)print * Waiting for messages. To exit press CTRL+Cdef callback(ch, method, properties, body): print x Received %r %(body,)channel.