您好,登錄后才能下訂單哦!
本篇文章給大家分享的是有關(guān)PHP如何使用gearman進(jìn)行異步的郵件或短信發(fā)送,小編覺得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
本文實(shí)例講述了PHP使用gearman進(jìn)行異步的郵件或短信發(fā)送操作。分享給大家供大家參考,具體如下:
一、準(zhǔn)備工作
1、為了防止,處理業(yè)務(wù)途中出現(xiàn)的宕機(jī),請(qǐng)配置好gearman的持久化方式。
2、使用gearmanManager來管理我們的worker腳本,方便測試。
二、編寫測試腳本
sendEmail.php
代碼如下:
<?php //注意函數(shù)名與文件名相同 function sendEmail($job) { $workId = uniqid(); //workload()獲取客戶端發(fā)送來的序列化數(shù)據(jù) $data = json_decode($job->workload(), true); //這里模擬處理過程 //具體的業(yè)務(wù),這里應(yīng)該是請(qǐng)求發(fā)送郵件的接口,這里只做演示 sleep(1); echo "workId: {$workId} 發(fā)送 {$data['email']} 成功\n"; }
client.php
代碼如下:
<?php //創(chuàng)建一個(gè)客戶端 $client = new GearmanClient(); //添加一個(gè)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' => "郵件標(biāo)題{$i}", 'body' => "我是內(nèi)容{$i}", ))); }
三、修改gearmanManager中配置信息
我的gearmanManager是安裝在/data/GearmanManager/下
> vi /data/GearmanManager/etc/GearmanManager.ini
添加如下信息,我們?yōu)閟endEmail啟動(dòng)五個(gè)進(jìn)程
[sendEmail] ;指定5個(gè)進(jìn)程 dedicated_count=5 ;5個(gè)進(jìn)程都只做sendEmail工作 dedicated_only=1
四、啟動(dòng)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 &
五、啟動(dòng)gearmanManager
> cd /data/GearmanManager > ./bin/pecl_manager.php -c /data/GearmanManager/etc/GearmanManager.ini -vvv
六、運(yùn)行client.php
> /data/php56/bin/php /data/client.php
當(dāng)我們對(duì)pecl_manager.php進(jìn)行ctrl+c時(shí),強(qiáng)行關(guān)閉worker,client.php那邊仍可正常的發(fā)送請(qǐng)求,不過數(shù)據(jù)都被保存在了mysql中。
當(dāng)我們重新把worker啟動(dòng)時(shí),gearman會(huì)重新載入沒有處理的進(jìn)行處理。
我的mysql是裝在主機(jī)的,虛擬機(jī)里裝了gearman,如果有朋友發(fā)現(xiàn)gearman無法連接mysql,可暫時(shí)關(guān)閉win10防火墻,和開啟win10被ping的回顯。
以上就是PHP如何使用gearman進(jìn)行異步的郵件或短信發(fā)送,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。