Rabbitmq使用龙卷风消费消息

作者: 不见你
发布时间: 2024-08-27 10:35:54 (6天前)
转自：

2 条回复

0#
回复此人
v-star*위위 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 尝试使用此代码： </p> <P> <a href="https://github.com/Gsantomaggio/rabbitmqexample/tree/master/webSocketPython" rel="nofollow noreferrer"> https://github.com/Gsantomaggio/rabbitmqexample/tree/master/webSocketPython </A> </p> <P> <code> def threaded_rmq(): channel.queue_declare(queue="my_queue") logging.info('consumer ready, on my_queue') channel.basic_consume(consumer_callback, queue="my_queue", no_ack=True) channel.start_consuming() </code> </p> <P> 和 <code> if __name__ == "__main__": logging.info('Starting thread RabbitMQ') threadRMQ = Thread(target=threaded_rmq) threadRMQ.start() </code> </p> </DIV>

编辑

登录后才能参与评论