This commit is contained in:
2021-04-15 20:01:16 +08:00
parent 5947b98b53
commit 7341a6fe4b
+3 -2
View File
@@ -69,8 +69,9 @@ class Zookeeper extends Process
$params['action'] = 'crontab'; $params['action'] = 'crontab';
$params['handler'] = $redis->get('crontab:' . $value); $params['handler'] = $redis->get('crontab:' . $value);
$redis->del('crontab:' . $value); $redis->del('crontab:' . $value);
$result = $server->sendMessage($params, random_int(0, $setting - 1)); $result = $server->sendMessage($params, $workerId = random_int(0, $setting - 1));
var_dump($result);
logger()->addError('send crontab to ' . $workerId . ' ' . intval($result));
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
logger()->addError($exception); logger()->addError($exception);
} }