利用 Gearman 實現系統錯誤報警功能

Gearman 是什麼?php

Gearman是一個用來把工做委派給其餘機器、分佈式的調用更適合作某項工做的機器、併發的作某項工做在多個調用間作負載均衡、或用來在調用其它語言的函數的系統。git

Gearman 工做原理github

  • Client(客戶端):建立一個Job。
  • Server(服務):找到合適的Worker,把 Job 交給 Worker。
  • Worker(工人):執行Job。

Gearman 工做原理

Web 中經常使用的場景。服務器

  • 裁剪圖片,生成縮略圖。
  • 文件分發(針對用戶上傳的文件,進行多臺服務器分發)。
  • 視頻轉碼(對上傳的視頻,進行轉碼存儲)。
  • 系統報警(當系統出現問題的時候,第一時間通知相關人)。

這篇文章主要講解 系統報警 場景併發

在開發系統的過程當中,每每程序會出現這樣,那樣的問題。負載均衡

咱們要第一時間獲取錯誤問題,通知短信,郵件通知給相關人員。異步

由於,短信、郵件的發送比較耗時,併發量大的狀況下,會出現延時現象。分佈式

因此,使用 Gearman 實現短信,郵件的異步發送。函數

Gearman 安裝的兩種方式ui

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

若是報錯:configure: error: could not find boost

yum install -y boost boost-devel

若是報錯:configure: error: could not find gperf

yum install gperf

若是報錯:configure: error: Unable to find libuuid

yum install libuuid-devel

make && make install

安裝成功後,執行 gearmand -V 查詢版本號。

gearmand -d 開啓服務。

舒適提示:
僅供參考,遇到不可預測的問題,請進行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

若是報錯:configure: error: Please install libgearman

yum install -y libgearman-devel.x86_64複製代碼

案例(系統報警)

  • 開啓服務
gearmand -d複製代碼
  • 執行Worker
php worker.php複製代碼
  • client.php
 addServer("127.0.0.1", 4730);
    $client->doNormal("send_mail", $strEmailInfo);
    if ($is_fatal_error == 1) {
        $client->doNormal("send_sms", $strSmsInfo);
    }
}

/**
 * 捕捉致命錯誤
 * @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
 addServer("127.0.0.1", 4730);
  $worker->addFunction("send_mail", "doSendMail");
  $worker->addFunction("send_sms", "doSendSms");
  while ($worker->work());

  /**
   * 執行發送郵件的Job
   * @param $job
   * @return string
   */
  function doSendMail($job)
  {
    $strEmailInfo = $job->workload();

    /**
     * 在這個方法裏完善發送郵件的操做
     * ......
     * Demo是把信息寫入到文件中
     */

    return file_put_contents("gearman.txt", $strEmailInfo."\n", FILE_APPEND);
  }

  /**
   * 執行發送短信的Job
   * @param $job
   * @return string
   */
  function doSendSms($job)
  {
    $strSmsInfo = $job->workload();

    /**
     * 在這個方法裏完善發送短信的操做
     * ......
     * Demo是把信息寫入到文件中
     */

    return file_put_contents("gearman.txt", $strSmsInfo."\n", FILE_APPEND);
  }複製代碼
  • gearman.txt
【警告錯誤】
時間:2016-09-22 23:15:10
錯誤代碼:8
錯誤信息:Undefined variable: b
錯誤文件:/home/www/mi/gearman/client.php
錯誤行號:9

【致命錯誤】
時間:2016-09-22 23:15:10
錯誤代碼:1
錯誤信息:Class 'Test' not found
錯誤文件:/home/www/mi/gearman/client.php
錯誤行號:12

[致命錯誤]錯誤代碼:1,錯誤信息:Class 'Test' not found,錯誤文件:/home/www/mi/gearman/client.php複製代碼

舒適提示

  • 也能夠用 Redis Queue 來實現上面的需求。
  • 也能夠用 Swoole 來實現上面的需求。
  • 也能夠了解下 Gearman 與 Swoole 的區別。

Thanks ~


IT小圈兒
相關文章
相關標籤/搜索