rabbitmq php basic_consume 怎么在没有消息接收的时候退出脚本

发布于 2022-09-12 04:29:08 字数 756 浏览 11 评论 0

require_once __DIR__ . '/vendor/autoload.php';  
    use PhpAmqpLib\Connection\AMQPStreamConnection;  
    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');  
    $channel = $connection->channel();  
      
    $channel->queue_declare('hello', false, false, false, false);  
      
    echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";  
    $callback = function($msg) {  
      echo " [x] Received ", $msg->body, "\n";  
    };  
      
    //在接收消息的时候调用$callback函数  
    $channel->basic_consume('hello', '', false, true, false, false, $callback);  
      
    while(count($channel->callbacks)) {  
        $channel->wait();  
    }

当我使用网上这段代码消费队列时,怎么会php脚本一直卡住,不会停止退出呢

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

孤檠 2022-09-19 04:29:08

这个东西不需要关闭啊,为什么要关闭呢?你可以发我amqp的消息来实现他的关闭

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文