初次在python中使用pika模块,RabbitMq执行报错
原因是pika版本不同导致的用法不同
第一类
Traceback (most recent call last): File "D:/python_work/consumer.py", line 15, in <module> no_ack=True) TypeError: basic_consume() got multiple values for argument 'queue'
生产者:
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters('localhost')
)
channel = connection.channel()#声明一个管道
#声明queue
channel.queue_declare(queue="hello")
channel.basic_publish(exchange='',
routing_key='hello', #就是queue
body='HELLO WORLD!' #消息内容
)
print(" [x] Sent 'HELLO WORLD!'") #打印发送了什么
connection.close() #关闭管道
消费者:
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
'localhost'))
channel = connection.channel() #建立管道
channel.queue_declare(queue='hello') #建立一个队列收消息
def callback(ch, method, properties, body):
print("--->",ch,method,properties)
print(" [x] Received %r " % body)
channel.basic_consume(callback, #如果收到消息,就调用callback函数来处理消息
queue='hello',
no_ack=True)
#channel.basic_consume('hello',callback, False)
print('[*] 等待收消息')
channel.start_consuming() #会一直收消息
运行消费者会产生上述错误,经过修改将channel.basic_consume(callback, #如果收到消息,就调用callback函数来处理消息 queue='hello', no_ack=True)
修改为channel.basic_consume(‘hello’,callback, False)就可以接收到生产者发送出的消息
第二类:
queue_declare() missing 1 required positional argument: 'queue'
#生成随机queue_name
result = channel.queue_declare(exclusive=True)
原因:生成了随机的channle,错误要求我指定channle
解决:给个空值
result = channel.queue_declare('',exclusive=True)
版权声明:本文为weixin_45961525原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。