A.K.I. Home
コンピュータ / blogn / ping送信の非同期化
投稿後の待ち時間が長くなるのを防ぐために、pingを受信した後非同期でping送信を行うように修正してみます。
・まず、pingproxy.phpは受信したパラメータの１番目と２番目をbase64エンコードしてsystem関数で呼び出し、すぐに結果を返し終了する。
・pingproxy_cli.phpに実際のping送信部を移し、バックグラウンドで処理。
ということでこんなかんじ。
pingproxy.php
<?php
require_once("XML/RPC.php");
require_once("XML/RPC/Server.php");
$GLOBALS['XML_RPC_defencoding'] = "UTF-8";
function pingproxy ($params) {
$p1 = base64_encode($params->getParam(0)->scalarval());
$p2 = base64_encode($params->getParam(1)->scalarval());
system("/usr/bin/php /***********/pingproxy_cli.php $p1 $p2 > /dev/null &");
$value = new XML_RPC_Value(
array(
"flerror" => new XML_RPC_Value(0, "boolean"),
"message" => new XML_RPC_Value("Thanks for the ping."),
),"struct");
return new XML_RPC_Response($value);
}
//RPCの実行
$s = new XML_RPC_Server(array("weblogUpdates.ping" => array("function" => "pingproxy")));
?>
pingproxy_cli.php
<?php
require_once("XML/RPC.php");
$GLOBALS['XML_RPC_defencoding'] = "UTF-8";
$logfile="/**********/pinglog.txt";
$pinglist="/**********/pinglist.txt";
function pingproxy ($params) {
global $logfile;
global $pinglist;
global $XML_RPC_erruser; // import user errcode value
$msg=new XML_RPC_Message('weblogUpdates.ping',$params);
//ここループ
$lines = file($pinglist);
foreach ($lines as $line_num => $line) {
preg_match ("/^[^\\/]+\\/\\/([^\\/]+)(\\/.*)$/", rtrim($line) ,$match);
if($match[1]!=""){
$client=new XML_RPC_Client($match[2],$match[1],80);
$response=$client->send($msg,30);
if($response!=0){
if(!$response->faultCode()){
file_put_contents($logfile,$match[1].":success\n",FILE_APPEND);
}else{
file_put_contents($logfile,$match[1].":fail\n",FILE_APPEND);
}
}else{
file_put_contents($logfile,$match[1].":fail:".$client->errno.":".$client->errstring."\n",FILE_APPEND);
}
}
//ここまでループ
}
$value = new XML_RPC_Value(
array(
"flerror" => new XML_RPC_Value(0, "boolean"),
"message" => new XML_RPC_Value("Thanks for the ping."),
),"struct");
return new XML_RPC_Response($value);
}
file_put_contents($logfile,"---start---:".date("r")."\n",FILE_APPEND);
$value = array(
new XML_RPC_Value(base64_decode($argv[1]),'string'),
new XML_RPC_Value(base64_decode($argv[2]),'string'),
);
$r=pingproxy($value);
file_put_contents($logfile,"----end----:".date("r")."\n",FILE_APPEND);
?>
前回忘れたタイムアウトの設定を
$response=$client->send($msg,30);
ここに入れています。30秒応答がないと次に進みます。
リストのサンプル
http://api.my.yahoo.com/RPC2 http://rpc.weblogs.com/RPC2 http://rpc.pingomatic.com/ http://rpc.reader.livedoor.com/ping http://ping.weblogalot.com/rpc.php http://ping.weblog.ne.jp/ http://ping.syndic8.com/xmlrpc.php http://ping.speenee.com/xmlrpc http://ping.maplog.jp/ http://ping.feedburner.com/
※ドメイン名だけで終るURLは必ず最後に/を付けてください。