Python 的消息队列模块（pika）

标签：

1.     parameters = pika.ConnectionParameters(‘localhost‘,5672,‘/‘,credentials    )    　　#参数
2.     connection = pika.BlockingConnection(parameters)    #连接
3.     channel = connection.channel()　　# 连接之后的 channel（引导）

1.     channel.queue_declare(queue=‘hello‘)    # 申明
   
2.         
3.     print ‘ [*] Waiting for messages. To exit press CTRL+C‘    
4.         
5.     def callback(ch, method, properties, body):    
6.         print " [x] Received %r" % (body,)    
7.         
8.     channel.basic_consume(callback,    
9.                           queue=‘hello‘,    
10.                           no_ack=True)    
11.         
12.     channel.start_consuming() 

参考链接：

http://blog.csdn.net/zyz511919766/article/details/41946521

Python 的消息队列模块（pika）

标签：

原文地址：http://www.cnblogs.com/IDomyself/p/4797306.html