7

我正在编写一个 python 客户端来接受来自 RabbitMQ 代理的作业消息并处理作业，将结果返回到另一台服务器。我的向 RabbitMQ 代理发送消息的脚本启动良好，但我的工作人员在运行 channel.declare_queue(queue='task_queue') 时抛出以下错误

pika.exceptions.AMQPChannelError：（406，“PRECONDITION_FAILED - vhost '/' 中队列 'task_queue' 的参数不等效”）

客户：

import pika    
connection = pika.BlockingConnection(pika.ConnectionParameters(host=cmdargs.server))
channel = connection.channel()
channel.queue_declare(queue='task_queue')
channel.basic_qos(prefetch_count=1)
channel.basic_consume(ProcJobCallback, queue='task_queue')
channel.start_consuming()

与 RabbitMQ 交互的服务器方法：

def addNewJob(self, newJob):
        self.jobList.append(newJob)
        connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
        channel = connection.channel()
        channel.queue_declare(queue='task_queue')

        for tile in newJob.TileStatus:
                message = "{0},{1},{2}".format(newJob, tile[0], tile[1])
                channel.basic_publish(exchange='', routing_key='task_queue', body=message, properties=pika.BasicProperties(delivery_mode = 2, ))
        connection.close()

非常感谢任何帮助或见解。

编辑：我发现了上面列出的代码出现错误的原因。我在发布消息时指定了 delivery_mode=2，但是当我声明队列时，我忘记添加 Durable=True 参数。

4

3 回答 3

3

如果您的队列是持久的，只需删除声明“channel.queue_declare(queue='task_queue')”，在您的情况下就足够了。

于 2016-01-22T18:03:26.737 回答
2

您确定要连接到发布者和消费者端的同一服务器（主机）吗？

connection = pika.BlockingConnection(pika.ConnectionParameters(host=cmdargs.server))

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
于 2012-09-09T20:37:55.523 回答
0

当我尝试使用耐用 = True 使队列消息持久化时，我遇到了同样的问题。

尝试重命名队列名称，它适用于我的脚本。也许杀死队列new_task，然后重新运行您的脚本也可以。

于 2016-07-11T08:15:07.070 回答