Como criar um sistema de Fila de Php
tive de construir um sistema de Fila de PHP, e encontrei este artigobrilhante
e eu usei-o para criar um sistema de Fila de PHP, é muito fácil de configurar e usar.http://squirrelshaterobots.com/programming/php/building-a-queue-server-in-php-part-1-understanding-the-project
Abaixo está o código para a fila.php, run from shell (puTTy or somesuch).
<?PHP
//. set this constant to false if we ever need to debug
//. the application in a terminal.
define('QUEUESERVER_FORK', true);
//////// fork into a background process ////////
if(QUEUESERVER_FORK){
$pid = pcntl_fork();
if($pid === -1) die('error: unable to fork.');
else if($pid) exit(0);
posix_setsid();
sleep(1);
ob_start();
}
$queue = array();
//////// setup our named pipe ////////
$pipefile = '/tmp/queueserver-input';
if(file_exists($pipefile))
if(!unlink($pipefile))
die('unable to remove stale file');
umask(0);
if(!posix_mkfifo($pipefile, 0666))
die('unable to create named pipe');
$pipe = fopen($pipefile,'r+');
if(!$pipe) die('unable to open the named pipe');
stream_set_blocking($pipe, false);
//////// process the queue ////////
while(1){
while($input = trim(fgets($pipe))){
stream_set_blocking($pipe, false);
$queue[] = $input;
}
$job = current($queue);
$jobkey = key($queue);
if($job){
echo 'processing job ', $job, PHP_EOL;
process($job);
next($queue);
unset($job, $queue[$jobkey]);
}else{
echo 'no jobs to do - waiting...', PHP_EOL;
stream_set_blocking($pipe, true);
}
if(QUEUESERVER_FORK) ob_clean();
}
?>
A parte mais difícil foi conseguir que as funções do pcntl funcionassem no meu servidor.
a minha pergunta é: "como é que consigo que o trabalho comece automaticamente quando/se o servidor tem de reiniciar?"
Como observado nos comentários, o link quebrado editado e apontou para excelente arquivo web para a posteridade.
1 answers
A minha pergunta é: "como é que consigo que o trabalho comece automaticamente quando/se o servidor tiver de reiniciar?"
Adicionando - o à lista de coisas iniciadas quando o servidor inicia. Infelizmente, as instruções para fazê-lo variam loucamente por sistema operacional e Versão OS. Você provavelmente quer usar algo um pouco mais cross-platform. Tive muita sorte com o supervisor, que provavelmente pode encontrar nos relatórios de embalagem do seu SO. escolha.
Dito isto, estás a seguir o caminho da loucura. O que estás a fazer já foi feito antes, melhor, por pessoas espectaculares. Confira o sistema de Fila de trabalho Gearman e a extensão PECL ([14]}. Acontece que o supervisor é muito útil para manter os seus trabalhadores de Gearman vivos também.