怎么在PHP中使用gearman實(shí)現(xiàn)異步的郵件

這篇文章將為大家詳細(xì)講解有關(guān)怎么在PHP中使用gearman實(shí)現(xiàn)異步的郵件，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

一、準(zhǔn)備工作

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

上述兩條請(qǐng)看我之前寫的兩篇文章

二、編寫測(cè)試腳本

sendEmail.php代碼如下：

<?php
//注意函數(shù)名與文件名相同
function sendEmail($job) {
  $workId = uniqid();

  //workload()獲取客戶端發(fā)送來(lái)的序列化數(shù)據(jù)
  $data = json_decode($job->workload(), true);
  
  //這里模擬處理過(guò)程
  //具體的業(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)求，不過(guò)數(shù)據(jù)都被保存在了mysql中。
當(dāng)我們重新把worker啟動(dòng)時(shí)，gearman會(huì)重新載入沒(méi)有處理的進(jìn)行處理。

關(guān)于怎么在PHP中使用gearman實(shí)現(xiàn)異步的郵件就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。