Clean gearmand job queue

README.md

php clear_queue.php --address=127.0.0.1 --port=4730

clear_queue.php

<?php

$cmdOptions = getopt('', ['address::', 'port::']);
$address = $cmdOptions['address'];
$port = $cmdOptions['port'];
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, $address, $port);
$command = 'status' . PHP_EOL;
socket_write($socket, $command, strlen($command));
$out = socket_read($socket, 2048);
$items = explode("\n", substr($out, 0, strlen($out) - 2));
foreach ($items as $item) {
    $item = explode("\t", $item);
    if (count($item) != 4) {
        continue;
    }
    if ($item[1] == 0) {
        continue;
    }
    $jobCount = intval($item[1] - $item[2]);
    if ($jobCount > 0) {
        $command = 'gearman -n -h ' . $address . ' -p ' . $port . ' -w -f ' . $item[0]
            . ' -c ' . $jobCount . ' > /dev/null';
        exec('gearman -n -h ' . $address . ' -p ' . $port . ' -w -f ' . $item[0] . ' -c ' . $jobCount . ' > /dev/null');
    }
}
socket_close($socket);