吾爱破解 - 52pojie.cn

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 922|回复: 1
收起左侧

[求助] 关于RabbitMQ的消费者问题

[复制链接]
zihang.wang 发表于 2020-11-23 15:53
RabbitMQ消费者如何一次只消费一条数据,而不是全部消费;
我用以下代码会报错
def consumer(request):    credentials = pika.PlainCredentials('xxxx', '123456')  # mq用户名和密码
    connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='xxxxx', port=5672, credentials=credentials))  # 定义连接池
    channel = connection.channel()
    channel.basic_consume(on_message_callback=callback, queue='test', auto_ack=True)
    channel.basicQos(1)
    channel.start_consuming()  # 开始监听 接受消息
    return HttpResponse("success")
image.png

发帖前要善用论坛搜索功能,那里可能会有你要找的答案或者已经有人发布过相同内容了,请勿重复发帖。

 楼主| zihang.wang 发表于 2020-12-2 22:25
最终我只能够通过多个消费者来平均消费,但是并不能实现指定消费一条或者几条
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

返回列表

RSS订阅|小黑屋|处罚记录|联系我们|吾爱破解 - LCG - LSG ( 京ICP备16042023号 | 京公网安备 11010502030087号 )

GMT+8, 2024-11-26 09:31

Powered by Discuz!

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表