Gearman如何正確的在PHP中使用

Gearman如何正確的在PHP中使用？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

Gearman可以做什么:

異步處理:圖片處理,訂單處理,批量郵件/通知之類的
要求高CPU或內(nèi)存的處理:大容量的數(shù)據(jù)處理,MapReduce運(yùn)算,日志聚集,視頻編碼
分布式和并行的處理
定時(shí)處理:增量更新,數(shù)據(jù)復(fù)制
限制速率的FIFO處理
分布式的系統(tǒng)監(jiān)控任務(wù)

Gearman工作原理：
使用Gearman的應(yīng)用通常有三部分組成：一個Client、一個Worker、一個 任務(wù)服務(wù)器。 Client的作用是提出一個 Job 任務(wù) 交給 Job Server 任務(wù)服務(wù)器。Job Server 會去尋找一個 合適的 Worker 來完成這項(xiàng)任務(wù)。Worker 執(zhí)行由 Client 發(fā)送過來的 Job，并且將結(jié)果通過 Job Server 返回給 Client。Gearman 提供了 Client 和 Worker 的 API，利用這些API 應(yīng)用可以同 Gearman Job Server來進(jìn)行通信。Gearman 內(nèi)部 Client 和 Worker 之間的通信都是通過 TCP 連接來進(jìn)行的。

Gearman可以將工作的負(fù)載分擔(dān)到不同的機(jī)器中。

安裝:

復(fù)制代碼 代碼如下:

rpm -ivh http://dl.iuscommunity.org/pub/ius/stable/Redhat/6/x86_64/epel-release-6-5.noarch.rpm
yum install -y gearmand

啟動：
gearmand -d

安裝PHP Gearman擴(kuò)展
我都是用pcel來安裝的，你也可以下載源碼包來編譯安裝，但是記得要先安裝libgearman和re2c，不然擴(kuò)展編譯安裝會出錯。

pecl install gearman #不成功并提示版本問題可以試試 pecl install gearman-1.0.3，默認(rèn)好像是1.1.2
編譯安裝也很簡單

復(fù)制代碼 代碼如下:

wget -c http://pecl.php.net/get/gearman-1.1.1.tgz
tar zxvf gearman-1.1.1.tgz
phpize
./configure
make && make install
echo "extension=gearman.so" >> /etc/php.ini

PHP接口函數(shù)
Gearman提供很多完善的擴(kuò)展函數(shù)，包括GearmanClient,GearmanJob,GearmanTask,GearmanWorker,具體可以查看PHP官方手冊.
這是官方提供的Example其中的一個，相當(dāng)與一個并發(fā)的分發(fā)任務(wù)處理的例子

<?php

$client = new GearmanClient();
$client->addServer();

// initialize the results of our 3 "query results" here
$userInfo = $friends = $posts = null;

// This sets up what gearman will callback to as tasks are returned to us.
// The $context helps us know which function is being returned so we can
// handle it correctly.
$client->setCompleteCallback(function(GearmanTask $task, $context) use (&$userInfo, &$friends, &$posts) {
switch ($context)
{
case 'lookup_user':
$userInfo = $task->data();
break;
case 'baconate':
$friends = $task->data();
break;
case 'get_latest_posts_by':
$posts = $task->data();
break;
}
});

// Here we queue up multiple tasks to be execute in *as much* parallelism as gearmand can give us
$client->addTask('lookup_user', 'joe@joe.com', 'lookup_user');
$client->addTask('baconate', 'joe@joe.com', 'baconate');
$client->addTask('get_latest_posts_by', 'joe@joe.com', 'get_latest_posts_by');

echo "Fetching...\n";
$start = microtime(true);
$client->runTasks();
$totaltime = number_format(microtime(true) - $start, 2);

echo "Got user info in: $totaltime seconds:\n";
var_dump($userInfo, $friends, $posts);

gearman_work.php

<?php

$worker = new GearmanWorker();
$worker->addServer();

$worker->addFunction('lookup_user', function(GearmanJob $job) {
// normally you'd so some very safe type checking and query binding to a database here.
// ...and we're gonna fake that.
sleep(3);
return 'The user requested (' . $job->workload() . ') is 7 feet tall and awesome';
});

$worker->addFunction('baconate', function(GearmanJob $job) {
sleep(3);
return 'The user (' . $job->workload() . ') is 1 degree away from Kevin Bacon';
});

$worker->addFunction('get_latest_posts_by', function(GearmanJob $job) {
sleep(3);
return 'The user (' . $job->workload() . ') has no posts, sorry!';
});

while ($worker->work());

我在3個終端中都執(zhí)行了gearman_work.php

ryan@ryan-lamp:~$ ps aux | grep gearman* | grep -v grep
gearman 1504 0.0 0.1 60536 1264 ? Ssl 11:06 0:00 /usr/sbin/gearmand --pid-file=/var/run/gearman/gearmand.pid --user=gearman --daemon --log-file=/var/log/gearman-job-server/gearman.log --listen=127.0.0.1
ryan 2992 0.0 0.8 43340 9036 pts/0 S+ 14:05 0:00 php /var/www/gearmand_work.php
ryan 3713 0.0 0.8 43340 9036 pts/1 S+ 14:05 0:00 php /var/www/gearmand_work.php
ryan 3715 0.0 0.8 43340 9036 pts/2 S+ 14:05 0:00 php /var/www/gearmand_work.php

來查看下執(zhí)行g(shù)earman_work.php的結(jié)果shell

代碼如下:

Fetching...
Got user info in: 3.03 seconds:
string(59) "The user requested (joe@joe.com) is 7 feet tall and awesome"
string(56) "The user (joe@joe.com) is 1 degree away from Kevin Bacon"
string(43) "The user (joe@joe.com) has no posts, sorry!"

看到上面的3.03 seconds，說明client請求過去的任務(wù)被并行分發(fā)執(zhí)行了。
看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注億速云行業(yè)資訊頻道，感謝您對億速云的支持。