它现在对我有用,但是我不确定这是否是正确的方法。现在,我正在捕获错误并在连接失败的情况下递归调用该函数。我的新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
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)