本文實例講述了PHP使用gearman進行異步的郵件或短信發(fā)送操作。分享給大家供大家參考，具體如下：

一、準備工作

1、為了防止，處理業(yè)務(wù)途中出現(xiàn)的宕機，請配置好gearman的持久化方式。
2、使用gearmanManager來管理我們的worker腳本，方便測試。

相關(guān)學(xué)習(xí)推薦：PHP編程從入門到精通

二、編寫測試腳本

sendEmail.php代碼如下：

<?php //注意函數(shù)名與文件名相同 function sendEmail($job) {   $workId = uniqid();    //workload()獲取客戶端發(fā)送來的序列化數(shù)據(jù)   $data = json_decode($job->workload(), true);      //這里模擬處理過程   //具體的業(yè)務(wù)，這里應(yīng)該是請求發(fā)送郵件的接口，這里只做演示   sleep(1);      echo "workId: {$workId} 發(fā)送 {$data['email']} 成功n"; }

client.php代碼如下：

<?php //創(chuàng)建一個客戶端 $client = new GearmanClient(); //添加一個job服務(wù) $client->addServer('127.0.0.1', 4730);  $cnt = 5000; $ret = array();  //循環(huán)發(fā)送5000條郵件 for($i = 0; $i < $cnt; ++$i) {   //doBackground異步，返回提交任務(wù)的句柄   $ret[$i] = $client->doBackground('sendEmail', json_encode(array(     'email' => "{$i}@qq.com",     'title' => "郵件標題{$i}",     'body' => "我是內(nèi)容{$i}",   ))); }

三、修改gearmanManager中配置信息

我的gearmanManager是安裝在/data/GearmanManager/下

> vi /data/GearmanManager/etc/GearmanManager.ini

添加如下信息，我們?yōu)閟endEmail啟動五個進程

[sendEmail] ;指定5個進程 dedicated_count=5 ;5個進程都只做sendEmail工作 dedicated_only=1

四、啟動gearman

> gearmand -d -q mysql  --mysql-host=192.168.1.100  --mysql-port=3306  --mysql-user=gearman  --mysql-password=123456  --mysql-db=gearman  --mysql-table=gearman_queue &

五、啟動gearmanManager

> cd /data/GearmanManager > ./bin/pecl_manager.php -c /data/GearmanManager/etc/GearmanManager.ini -vvv

六、運行client.php

> /data/php56/bin/php /data/client.php

當(dāng)我們對pecl_manager.php進行ctrl+c時，強行關(guān)閉worker，client.php那邊仍可正常的發(fā)送請求，不過數(shù)據(jù)都被保存在了mysql中。
當(dāng)我們重新把worker啟動時，gearman會重新載入沒有處理的進行處理。

我的mysql是裝在主機的，虛擬機里裝了gearman，如果有朋友發(fā)現(xiàn)gearman無法連接mysql，可暫時關(guān)閉win10防火墻，和開啟win10被ping的回顯。