通過PHP CLI實現(xiàn)簡單的數(shù)據(jù)庫實時監(jiān)控調(diào)度
更新時間:2009年07月01日 00:52:06 作者:
繼續(xù)CLI模式試驗,這次通過使用之前的“帶延時的死循環(huán)”方法,來實現(xiàn)個簡單的數(shù)據(jù)庫實時監(jiān)控調(diào)度功能。
要實現(xiàn)的功能:監(jiān)控user表,若有新紀錄增加,將其向user2表中添加。(實際應(yīng)用上可以引深一些,例如對數(shù)據(jù)進行相關(guān)處理等)
下面是PHP代碼(dbtest.php)
!#/usr/local/php/bin/php
<?php
mysql_connect('localhost', 'username', 'password');
mysql_select_db("test");
echo 'PID: '.posix_getpid().' '; //當前進程PID(linux下)
$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);
$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_id = max($old_id, $new_id);
sleep(3); //3秒后進入下次循環(huán)
}
業(yè)務(wù)流程應(yīng)該沒什么說的,就有幾處需要注意的地方:
第一行是PHP CLI模式需要添加的命令路徑,還有就是那個while(1)和sleep(3),其余都是普通的php代碼寫法。
通過shell命令php dbtest.php運行即可,我在虛擬機上測試,正常情況下占用率CPU 0%,內(nèi)存1%。
實際應(yīng)用中可以放到后臺運行:
php dbtest.php &
bg 1
PS:&命令很多地方說的很不清楚,甚至錯誤。它只是將程序放入后臺,而并沒有實際運行!
順帶總結(jié)復習一下linux的前后臺運行相關(guān)命令
下面是PHP代碼(dbtest.php)
復制代碼 代碼如下:
!#/usr/local/php/bin/php
<?php
mysql_connect('localhost', 'username', 'password');
mysql_select_db("test");
echo 'PID: '.posix_getpid().' '; //當前進程PID(linux下)
$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);
$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_id = max($old_id, $new_id);
sleep(3); //3秒后進入下次循環(huán)
}
業(yè)務(wù)流程應(yīng)該沒什么說的,就有幾處需要注意的地方:
第一行是PHP CLI模式需要添加的命令路徑,還有就是那個while(1)和sleep(3),其余都是普通的php代碼寫法。
通過shell命令php dbtest.php運行即可,我在虛擬機上測試,正常情況下占用率CPU 0%,內(nèi)存1%。
實際應(yīng)用中可以放到后臺運行:
php dbtest.php &
bg 1
PS:&命令很多地方說的很不清楚,甚至錯誤。它只是將程序放入后臺,而并沒有實際運行!
順帶總結(jié)復習一下linux的前后臺運行相關(guān)命令
命令 前后臺 狀態(tài) 使用方式
& 后臺 暫停 加在命令后
bg 后臺 運行 后跟作業(yè)號
fg 前臺 運行 后跟作業(yè)號
Ctrl+Z 后臺 暫停 (組合鍵)
jobs (查看所有作業(yè)號) 命令
相關(guān)文章
基于PHP實現(xiàn)解密或加密Cloudflar郵箱保護
這篇文章主要介紹了基于PHP實現(xiàn)解密Cloudflar郵箱保護,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-06-06PHP開發(fā)的文字水印,縮略圖,圖片水印實現(xiàn)類與用法示例
這篇文章主要介紹了PHP開發(fā)的文字水印,縮略圖,圖片水印實現(xiàn)類與用法,結(jié)合完整實例形式分析了php文字水印、縮略圖操作類定義與簡單使用方法,需要的朋友可以參考下2019-04-04