rabbitmq 测试


用消息队列更多的是解服务之间的调用关系,调用关系异步化。把控制关系/拓扑结构放出来。

# --*-- coding:utf-8 --*-- import pika import datetime connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost')) channel = connection.channel() channel.queue_declare(queue='hello') def callback(ch, method, properties, body): print " [x] Received %r" % (body,) channel.basic_consume(callback, queue='hello', no_ack=True) print ' [*] Waiting for messages. To exit press CTRL+C' channel.start_consuming() ----------------received # --*-- coding:utf-8 --*-- import pika connection = pika.BlockingConnection(pika.ConnectionParameters( '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
原文地址:https://www.cnblogs.com/i80386/p/3953225.html