php rabbitmq 如何实现消费者自动触发读取消息

Question

1、根据rabbitmq 官方文档 搭建了一个测试 创建队列 以及 发送消息 接受消息 但是都是 用 php server.php 和 php client.php 这样的形式 来执行的 如果部署到服务器 如何实现 client.php 来自动消费这个队列里面的消息 始终与服务器保持联系 网上的一些资料是写一个sell 脚本 以及while 循环来处理 不知道还有什么其他的方式。

Answer 1

    public function receive($callback, $routingKey = null)
    {
        if (self::$connection === null) {
            $this->openConnection();
        }
        //channel
        $channel = new \AMQPChannel(self::$connection);
        $channel->setPrefetchCount($this->preFetchCount);
        $queue = new \AMQPQueue($channel);
        $queue->setName($this->queue);
        $queue->bind($this->exchange, empty($routingKey) ? $this->routingKey : $routingKey);
        while (true) {
            $queue->consume($callback);
        }
    }

参考一下。目前PHP只有while循环的形式（当然，你可以考虑一下php的多线程）

Answer 2

正常定时执行 php client.php了