click.simba.taobao.com 透過PHP CLI實現簡單的資料庫即時監控調度

要實現的功能：監控user表，若有新紀錄增加，將其新增至user2表。 （實際應用上可以引深一些，例如對資料進行相關處理等）
下面是PHP程式碼（dbtest.php）

複製程式碼 程式碼如下:

!#/usr/local/php/bin/php
mysql_connect('localhost', 'username', 'password');
mysql_select_db("test");
echo 'PID: '.posix_getpid().' '; //目前處理PID（linux下）
$old_id = 0;
while (1)
$old_id = 0;
while (1)
{
$sql = "SELECT `id` FROM `user` ORDER BY `id` DESC LIMIT 1";
$result = mysql_query($sql);
$item = mysql_fetch_assoc($result_assoc($result);
$new_id = $item['id'];
$values_arr = array();
for ($i=$new_id; $i>$old_id && $old_id!=0; $i- -)
{
$sql = "SELECT `name`,`age` FROM `user` WHERE `id`='{$i}' LIMIT 1";
$result = mysql_query($sql );
$item = mysql_fetch_assoc($result);
$name = $item['name'];
$age = $item['age'];
$values_arr[] = "('{$name}', '{$age}')";
}
if (!emptyempty($values_arr))
{
$values_str = implode(',', $values_arr);
$sql = "INSERT INTO `user2`(`name`, `age`) VALUES {$values_str}";
mysql_query($sql);
}
$old_mysql_query($sql);
}

$old_mysql_query($sql);
}
$old_mysql_query($sql);
}
$old_mysql_query($sql);
}
$old_mysql_query($sql);
}
$old_mysql_query($sql);
}

$old_mysql_query($sql);

}

$old_mysql_query($sql)； = max($old_id, $new_id); sleep(3); //3秒後進入下次循環}

業務流程應該沒什麼說的，就有幾處需要注意的地方：

第一行是PHP CLI模式需要加入的指令路徑，還有就是那個while(1)和sleep(3)，其餘都是普通的php程式碼寫法。

透過shell指令php dbtest.php運行即可，我在虛擬機器上測試，正常情況下佔用率CPU 0%，記憶體1%。

實際應用中可以放到後台運行：

php dbtest.php &

bg 1

PS：&指令很多地方說的很不清楚，甚至錯誤。它只是將程式放入後台，而並沒有實際運行！

順帶總結複習一下linux的前後台執行相關指令

指令     前後台   狀態       使用方式

bg         後台       運轉       與作業編號fg              後台       暫停        （組合鍵）jobs     （請參閱所有作業編號）    指令 以上就介紹了click.simba.taobao.com 透過PHP CLI實現簡單的資料庫即時監控調度，包括了click.simba.taobao.com方面的內容，希望對PHP教程有興趣的朋友有所幫助。