pika import sysconnection = pika.BlockingConnection(pika.ConnectionParameters(host = ))channel = connection.channel()channel.exchange_declare(exchange = ,type = )routing_key = sys.argv[1] message = c
pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters( host=)) channel = connection.channel() channel.exchange_declare(exchange=, type=) routing_key = sys.argv[1] message = channel.basic_publish(exchange=, routing_key=routing_key, body=message) % (routing_key, message)) connection.close()
生产者
1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，请转载时务必注明文章作者和来源，不尊重原创的行为我们将追究责任；3.作者投稿可能会经我们编辑修改或补充。
相关文章
快来一起打飞机、大牛带你用最2代码、写出外挂版微信打飞机 - 索宁
2016-08-04 12:00
网友点评
精彩导读
热门资讯
关注我们
