Gearman 是什么？
Gearman是一個(gè)用來(lái)把工作委派給其他機(jī)器彻消、分布式的調(diào)用更適合做某項(xiàng)工作的機(jī)器宙拉、并發(fā)的做某項(xiàng)工作在多個(gè)調(diào)用間做負(fù)載均衡、或用來(lái)在調(diào)用其它語(yǔ)言的函數(shù)的系統(tǒng)煌贴。
Gearman 工作原理
- Client(客戶(hù)端)：創(chuàng)建一個(gè)Job锥忿。
- Server(服務(wù))：找到合適的Worker,把 Job 交給 Worker。
- Worker(工人)：執(zhí)行Job淹朋。
Gearman 工作原理
Web 中常用的場(chǎng)景础芍。
- 裁剪圖片数尿，生成縮略圖。
- 文件分發(fā)（針對(duì)用戶(hù)上傳的文件诊杆，進(jìn)行多臺(tái)服務(wù)器分發(fā)）。
- 視頻轉(zhuǎn)碼（對(duì)上傳的視頻豹储，進(jìn)行轉(zhuǎn)碼存儲(chǔ)）宰缤。
- 系統(tǒng)報(bào)警（當(dāng)系統(tǒng)出現(xiàn)問(wèn)題的時(shí)候晃洒，第一時(shí)間通知相關(guān)人）。
這篇文章主要講解 系統(tǒng)報(bào)警 場(chǎng)景
在開(kāi)發(fā)系統(tǒng)的過(guò)程中氧骤，往往程序會(huì)出現(xiàn)這樣吃引，那樣的問(wèn)題。
我們要第一時(shí)間獲取錯(cuò)誤問(wèn)題朦佩，通知短信庐氮，郵件通知給相關(guān)人員。
因?yàn)橄善瑁绦乓羯簟⑧]件的發(fā)送比較耗時(shí)，并發(fā)量大的情況下寸士，會(huì)出現(xiàn)延時(shí)現(xiàn)象碴卧。
所以螟深，使用 Gearman 實(shí)現(xiàn)短信，郵件的異步發(fā)送界弧。
Gearman 安裝的兩種方式
-
方式一：官網(wǎng)推薦安裝方法
官網(wǎng)地址：http://gearman.org/getting-started/
yum install gearmand 方式二：自定義安裝
-
安裝libevent：
wget get https://github.com/libevent/libevent/releases/download/release-2.0.22-stable/libevent-2.0.22-stable.tar.gz tar zxvf libevent-2.0.22-stable.tar.gz ./configure --prefix=/usr make && make install -
安裝Gearman server and library：
wget get https://launchpad.net/gearmand/1.2/1.1.12/+download/gearmand-1.1.12.tar.gz tar zxvf gearmand-1.1.12.tar.gz cd gearmand-1.1.12 ./configure 如果報(bào)錯(cuò)：configure: error: could not find boost yum install -y boost boost-devel 如果報(bào)錯(cuò)：configure: error: could not find gperf yum install gperf 如果報(bào)錯(cuò)：configure: error: Unable to find libuuid yum install libuuid-devel make && make install 安裝成功后，執(zhí)行 gearmand -V 查詢(xún)版本號(hào)兑巾。 gearmand -d 開(kāi)啟服務(wù)忠荞。 溫馨提示： 僅供參考，遇到不可預(yù)測(cè)的問(wèn)題堂油，請(qǐng)進(jìn)行Google碧绞。 -
安裝Gearman PHP extension：
wget get http://pecl.php.net/get/gearman-1.1.2.tgz tar zxvf gearman-1.1.2.tgz cd gearman-1.1.2 /usr/local/php/bin/phpize ./configure --with-php-config=/usr/local/php/bin/php-config --with-gearman 如果報(bào)錯(cuò)：configure: error: Please install libgearman yum install -y libgearman-devel.x86_64
案例（系統(tǒng)報(bào)警）
- 開(kāi)啟服務(wù)
gearmand -d
- 執(zhí)行Worker
php worker.php
- client.php
<?php
//設(shè)置錯(cuò)誤處理器
set_error_handler('errorHandler');
//在腳本結(jié)束時(shí)運(yùn)行的函數(shù)
register_shutdown_function('fatalErrorHandler');
//這里發(fā)生一個(gè)警告錯(cuò)誤,被errorHandler 捕獲
$a = $b;
//發(fā)生致命錯(cuò)誤讥邻，腳本停止運(yùn)行觸發(fā) fatalErrorHandler
$c = new Test();
/**
* 錯(cuò)誤處理
* @param int $err_no 錯(cuò)誤代碼
* @param string $err_msg 錯(cuò)誤信息
* @param string $err_file 錯(cuò)誤文件
* @param int $err_line 錯(cuò)誤行號(hào)
* @param int $is_fatal_error 是否為致命錯(cuò)誤
* @return string
*/
function errorHandler($err_no = 0, $err_msg = '', $err_file = '', $err_line = 0, $is_fatal_error = 0)
{
$strEmailInfo = ($is_fatal_error == 1) ? "【致命錯(cuò)誤】\n" : "【警告錯(cuò)誤】\n";
$strEmailInfo .= "時(shí)間:".date('Y-m-d H:i:s')."\n";
$strEmailInfo .= "錯(cuò)誤代碼:{$err_no}\n";
$strEmailInfo .= "錯(cuò)誤信息:{$err_msg}\n";
$strEmailInfo .= "錯(cuò)誤文件:{$err_file}\n";
$strEmailInfo .= "錯(cuò)誤行號(hào):{$err_line}\n";
$strSmsInfo = "[致命錯(cuò)誤]錯(cuò)誤代碼:{$err_no},錯(cuò)誤信息:{$err_msg},錯(cuò)誤文件:{$err_file}";
$client= new GearmanClient();
$client->addServer("127.0.0.1", 4730);
$client->doNormal("send_mail", $strEmailInfo);
if ($is_fatal_error == 1) {
$client->doNormal("send_sms", $strSmsInfo);
}
}
/**
* 捕捉致命錯(cuò)誤
* @return string
*/
function fatalErrorHandler() {
$e = error_get_last();
switch ($e['type']) {
case 1:
errorHandler($e['type'], $e['message'], $e['file'], $e['line'], 1);
break;
}
}
- worker.php
<?php
$worker = new GearmanWorker();
$worker->addServer("127.0.0.1", 4730);
$worker->addFunction("send_mail", "doSendMail");
$worker->addFunction("send_sms", "doSendSms");
while ($worker->work());
/**
* 執(zhí)行發(fā)送郵件的Job
* @param $job
* @return string
*/
function doSendMail($job)
{
$strEmailInfo = $job->workload();
/**
* 在這個(gè)方法里完善發(fā)送郵件的操作
* ......
* Demo是把信息寫(xiě)入到文件中
*/
return file_put_contents("gearman.txt", $strEmailInfo."\n", FILE_APPEND);
}
/**
* 執(zhí)行發(fā)送短信的Job
* @param $job
* @return string
*/
function doSendSms($job)
{
$strSmsInfo = $job->workload();
/**
* 在這個(gè)方法里完善發(fā)送短信的操作
* ......
* Demo是把信息寫(xiě)入到文件中
*/
return file_put_contents("gearman.txt", $strSmsInfo."\n", FILE_APPEND);
}
- gearman.txt
【警告錯(cuò)誤】
時(shí)間:2016-09-22 23:15:10
錯(cuò)誤代碼:8
錯(cuò)誤信息:Undefined variable: b
錯(cuò)誤文件:/home/www/mi/gearman/client.php
錯(cuò)誤行號(hào):9
【致命錯(cuò)誤】
時(shí)間:2016-09-22 23:15:10
錯(cuò)誤代碼:1
錯(cuò)誤信息:Class 'Test' not found
錯(cuò)誤文件:/home/www/mi/gearman/client.php
錯(cuò)誤行號(hào):12
[致命錯(cuò)誤]錯(cuò)誤代碼:1,錯(cuò)誤信息:Class 'Test' not found,錯(cuò)誤文件:/home/www/mi/gearman/client.php
溫馨提示
- 也可以用 Redis Queue 來(lái)實(shí)現(xiàn)上面的需求系宜。
- 也可以用 Swoole 來(lái)實(shí)現(xiàn)上面的需求发魄。
- 也可以了解下 Gearman 與 Swoole 的區(qū)別欠母。
Thanks ~
