用Python尝试RabbitMQ(2)

根据你的需求,py-amqplib或者txAMQP都是可以的。因为是基于Twisted的,txAMQP可以保证用异步IO构建超高性能的AMQP程序。但是Twisted编程本身就是一个很大的主题……因此清晰起见,我们打算用 py-amqplib。

1、下载:

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

linux

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wyjxxg.html