django如何使用消息中间件接收消息的

http请求到来时,需要从rabbitmq消息中间件上获取数据并返回。 目前有2中方法。一个是channel.start_consuming()阻塞的不合适;另一个channel.basic_get(queue='hello')虽然不是阻塞的但却是立即返回的,如果要收消息需要循环sleep直到收到消息,每个消息都这么等估计会成为高并发的瓶颈。 请问下各位怎么在django中接收消息中间件信息的,或者只能发布消息吗?

评论 0