使用Redis实施消息队列时出错,使用BLPOP时出错

使用Redis实施消息队列时出错,使用BLPOP时出错,第1张

使用Redis实施消息队列出错,使用BLPOP时出错

它现在对我有用,但是我不确定这是否是正确的方法。现在,我正在捕获错误并在连接失败的情况下递归调用该函数。我的新slave.php看起来像这样:

function process_data(){    try {        $client = new PredisClient();        require_once("logger.php");        while (true) { list($queue, $message) = $client->brPop(["bookmark_queue"], 0); // logic        }    } catch (Exception $ex) {        $error = $ex->getMessage();        log_error($error, "slave.php");        process_data(); // call the function recursively if connection fails    }}process_data(); // call the function


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/4952713.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-11-13
下一篇 2022-11-13

发表评论

登录后才能评论

评论列表(0条)

保存