相关疑难解决方法(0)

当RabbitMQ有消息时,RabbitMQ是否为消费者调用回调函数,或者消费者是否必须轮询RabbitMQ客户端？

所以在消费者方面,如果有PHP脚本,RabbitMQ可以调用它并将消息/参数传递给它.例如,如果在shard 1上提交了rating并且aggregateRating表在shard 2上,那么在shard 2上的RabbitMQ使用者会触发脚本说aggRating.php并传递插入到shard 1中的参数吗？

while (true)
{
    BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue();
    IBasicProperties properties = e.BasicProperties;
    byte[] body = e.Body;
    Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body));
    ch.BasicAck(e.DeliveryTag, false);
}

这是我们通过订阅检索消息时所做的事情.我们使用While循环,因为我们希望消费者不断地听...如果我想让这个甚至基于......那就是当时新消息到达队列的时候只有消费者应该消费消息..或任何类似的事件..