phpスクリプト - 入力を別のインスタンスにリダイレクト

Question

私はflock()を使用しているPHPスクリプトを使用して、すでにスクリプトが実行中の場合は複数のインスタンスを拒否します。

スクリプトコールで提供される引数が、それらを処理できる既存のプロセスに転送されることを希望します。

すなわち：

test.phpを：

#!/usr/bin/env php 
<?php 

$lock_file = fopen (getcwd() . '/'. basename(__FILE__, '.php') . '.pid', 'c'); 
$got_lock = flock ($lock_file, LOCK_EX | LOCK_NB, $wouldblock); 
if ($lock_file === false || (! $got_lock && ! $wouldblock)) : 
    throw new Exception ("Error opening or locking lock file"); 
    error_log("execption thrown"); 
elseif (! $got_lock && $wouldblock) : 
    exit ("Another instance is already running; terminating.\n"); 
endif; 

while (true) : 
    $input = $argv; // or incomming datas from other script ? 
    unset($argv); 
    if (is_array($input)) : 
     foreach ($input as $a) : 
      echo $a; 
     endforeach; 
    else : 
     echo $input; 
    endif; 
endwhile; 

?> 

さて、私が実行した場合：

php -f test.php arg1 arg2

php -f test.php arg3 arg4

2番目の呼び出しにも出たが、私arg3とarg4がmaiにパイプされるようにしたいnプロセス。

どうすればいいですか？

Answer 1

つまり、すでに存在するプロセスと通信する方法が必要ですか？別名IPC、これを行う方法はたくさんあります。絶対的な最速の方法は共有メモリです。データベースやUNIXソケットを使用する方が実装が簡単です。 、メッセージを処理するたびに便利

この操作を行います：ここでのSQLiteを使用した例です

while(NULL!==($message=check_for_message())){//handle all messages 
echo "got a mesage!:"; 
var_dump($message); 
} 

と "check_for_message" 機能：

//returns string("message") if there is a message available. 
// else returns NULL 
//Warning, do not try to optimize this function with prepared statements, unless you know what you're doing, in SQLIte they will lock the database from writing. 
function check_for_message(){ 
static $db=false; 
if($db===false){ 
$db=new PDO('sqlite:ipc.db3','','',array(PDO::ATTR_EMULATE_PREPARES => false,PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION)); 
$db->exec(
' 
CREATE TABLE IF NOT EXISTS messages (id INTEGER PRIMARY KEY AUTOINCREMENT, message TEXT); 

' 
); 
register_shutdown_function(function()use(&$db){ 
$db=NULL; 
unset($db); 
unlink("ipc.db3"); 
}); 
} 
$message=$db->query("SELECT id,message FROM messages LIMIT 1",PDO::FETCH_ASSOC); 

foreach($message as $ret){ 
$db->query("DELETE FROM messages WHERE id = ".$db->quote($ret['id'])); 
return $ret['message']; 
} 
return NULL; 
} 

とメッセージを送信する：

を使用例：

foreach($argv as $arg){ 
sendmessage($arg); 
} 

機能：

function sendmessage(string $message){ 
$db=new PDO('sqlite:ipc.db3','','',array(
PDO::ATTR_EMULATE_PREPARES => false, 
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION 
)); 
$db->query('INSERT INTO messages (message) VALUES('.$db->quote($message).');'); 
} 

ノート：私はあなたがWALモードsqliteのと準備されたステートメントを使用してその機能を最適化することができると思います。 PDO :: ATTR_PERSISTENTを使用して共有メモリに入れることでさらに最適化できると思いますが、文書化されていない機能を使用してhackishしているので、HHVM PHPのようなものでは動作しません。 unix（* BSD、Mac OS X、Linuxなど）では、UNIXソケットを使用する方が速いでしょう。生の共有メモリを使用する方が速いですが、共有メモリにメッセージキューを実装するのはやや難解です。 SIGUSR1などのシグナルハンドラをインストールして、メッセージが待機していることを確認することもできます。http://php.net/manual/en/function.pcntl-signal.php