根据你的需求,py-amqplib或者txAMQP都是可以的。因为是基于Twisted的,txAMQP可以保证用异步IO构建超高性能的AMQP程序。但是Twisted编程本身就是一个很大的主题……因此清晰起见,我们打算用 py-amqplib。
2、安装:
非常easy,解压后进入目录直接
【linux】sudo ./setup.py install
【windows】Python setup.py install
欧了,安装完毕,可以在python中import了:)
简单Demo测试
py-amqplib中带有简单的demo,在amqplib-0.6/demo中,我们先用这俩测试下消息的发送和接受
demo_receive.py -------------------》消息消费者
demo_send.py ----------------------》消息生产者
运行RabbitMQ后,先运行 ./demo_receive.py,创建Broker(其实就是交换机和队列啦)
接着另开一终端,运行 ./demo_send.py "hello, Linvo"
哇,在第一个终端显示出来了,好神奇啊~~~
运行时可以指定RabbitMQ的host、userid、password等参数,默认host是本机,userid和password都是guest
自己可以通过rabbitmqctl工具来删除、新建用户,并设置权限等
./rabbitmqctl delete_user guest -------》删除默认的guest用户
./rabbitmqctl add_user linvo 111 ---------》添加新用户linvo,密码111
./rabbitmqctl set_permissions -p / linvo ".*" ".*" ".*" -----------》设置linvo在/的虚拟主机的权限和之前的guest一样
PS:暂时没弄懂明白具体的权限正则规则 囧@&^%$……
再测试就改这样了
./demo_receive.py -u linvo -p 111
./demo_send.py -u linvo -p 111 "hello,Linvo"
rabbitmqctl的更多功能可参考官方文档 ,或者自行google:P