php異步處理任務工具,PHP實現異步任務分發處理利器-Gearman

通常,多語言多系統之間的集成是個大問題,一般來說,人們多半會采用WebService的方式來處理此類集成問題,但不管采用何 種風格的WebService,如RPC風格,或者REST風格,其本身都有一定的復雜性。相比之下,Gearman也能實現類似的作用,而且更簡單易 用。

一個Gearman請求的處理過程涉及三個角色:Client -> Job -> Worker。

Client:請求的發起者,可以是C,PHP,Perl,MySQL UDF等等。

Job:請求的調度者,用來負責協調把Client發出的請求轉發給合適的Work。

Worker:請求的處理者,可以是C,PHP,Perl等等。

因為Client,Worker并不限制用一樣的語言,所以有利于多語言多系統之間的集成。

甚至我們通過增加更多的Worker,可以很方便的實現應用程序的分布式負載均衡架構。

下面看看如何安裝運行一個例子,條件所限,我們把Client,Job,Worker三個角色運行在一臺服務器上:

安裝Gearman server and library:

wget http://launchpad.net/gearmand/trunk/0.8/+download/gearmand-0.8.tar.gz

tar zxf gearmand-0.8.tar.gz

cd gearmand-0.8

./configure

make

make install

安裝Gearman PHP extension:

wget http://pecl.php.net/get/gearman-0.4.0.tgz

tar zxf gearman-0.4.0.tgz

cd gearman-0.4.0

phpize

./configure

make

make install

編輯php.ini配置文件加載相應模塊并使之生效:

extension = “gearman.so”

啟動Job:

gearmand -d

如果當前用戶是root的話,則需要這樣操作:

gearmand -d -u root

缺省會使用4730端口,下面會用到。

注意:如果找不到gearmand命令的路徑,別忘了用whereis gearmand確認。

編寫Worker:

worker.php文件內容如下:

$worker= new GearmanWorker();

$worker->addServer(’127.0.0.1′, 4730);

$worker->addFunction(‘reverse’, ‘my_reverse_function’);

while ($worker->work());

function my_reverse_function($job)

{

return strrev($job->workload());

}

?>

設置后臺運行work:

php worker.php &

編寫Client:

client.php文件內容如下:

$client= new GearmanClient();

$client->addServer(’127.0.0.1′, 4730);

echo $client->do(‘reverse’, ‘Hello World!’), “\n”;

?>

運行client:

php client.php

輸出:!dlroW olleH

出于方便的考慮,Worker,Client使用的都是PHP,但這并不影響演示,實際應用中,你完全可以通過Gearman集成不同語言實現的 Worker,Client。或許此時你還想了解前面提到的負載均衡功能:很簡單,只要增加多個Worker即可,你可以按照worker.php的樣子 多寫幾個類似的文件,并設置不同的返回值用以識別演示效果。然后依次啟動這幾個Worker文件,并多次使用client.php去請求,你就會發現 Job會把Client請求轉發給不同的Worker。

命令行工具

如果你覺得安裝PHP之類的東西太麻煩的話,你也可以僅僅通過命令行工具來體驗Gearman的功能:

啟動Worker:gearman -w -f wc — wc -l &

運行Client:gearman -f wc < /etc/passwd

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/530858.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/530858.shtml
英文地址,請注明出處:http://en.pswp.cn/news/530858.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

java dos窗口小工具下載,maxdos 9 3-maxdos工具箱 v9.3 官方版

maxdos 9 3maxdos工具箱是一個dos工具箱&#xff0c;maxdos工具箱為安裝好的電腦系統加入dos&#xff0c;方便用戶維護與備份還原&#xff0c;是完全傻瓜化的工作模式&#xff0c;更是可以直接啟動硬盤上的光盤ISO鏡像一鍵啟動。maxdos工具箱特色說明&#xff1a;1、支持進入DO…

java 1.7 linux rpm,linux下用rpm 安裝jdk 7的jdk-7u79-linux-x64.rpm

linux下用rpm 安裝jdk 7的jdk-7u79-linux-x64.rpm步驟一、下載jdk的rpm安裝包步驟二、如果linux是centos的話&#xff0c;請先卸載openjdk&#xff0c;參考文檔&#xff1a;使用rpm命令卸載CentOS 6.4自帶的OpenJDK步驟三、安裝jdk-7u79-linux-x64.rpm安裝包先執行以下命令給所…

普通用戶無法執行java,CentOS tomcat普通用戶執行配置安裝

CentOS tomcat經過長時間的發展&#xff0c;這里我發表一下個人理解&#xff0c;下面就這就來講術CentOS tomcat。CentOS tomcat6_jdk1.6_安裝配置_開啟自動運行,普通用戶執行 (轉)秀脫linux筆記之CentOS tomcat6實戰篇由于前段時間一直在外頭出差&#xff0c;沒有完成CentOS t…

elementui樹形復選框,element-ui checkbox 組件的樹形聯動

前言示例版本為 Element-ui 2.13.0 Vue 2.6.11最近想弄 Element-ui checkbox 的多級聯動&#xff0c;網上相關的例子大多數為二級聯動&#xff0c;自己研究了一下&#xff0c;弄了一個樹形菜單的多級聯動&#xff0c;常用于角色管理等業務。(僅供參考&#xff0c;未考慮性能問…

php 魔術方法 sleep,php 魔術方法 sleep() wakeup()

__sleep() 和 __wakeup()public array __sleep ( void )void __wakeup ( void )serialize() 函數會檢查類中是否存在一個魔術方法 __sleep()。如果存在&#xff0c;該方法會先被調用&#xff0c;然后才執行序列化操作。此功能可以用于清理對象&#xff0c;并返回一個包含對象中…

java 先入先出,java_阻塞隊列(FIFO先進先出)

java_阻塞隊列(FIFO先進先出)ArrayBlockingQueue&#xff1a;由數組結構組成的有界阻塞隊列&#xff1b;LinkedBlockingQueue&#xff1a;由鏈表結構組成的有界阻塞隊列(但大小默認值為&#xff1a;Integer.MAX_VALUE)&#xff1b;PriorityBlockingQueue&#xff1a;支持優先級…

PHP能在Mac上運行嗎,PHP Composer無法在Mac上運行

我安裝了bitnami mac堆棧主要是因為我的項目需要至少PHP 5.4.7版本.但是,我遇到了作曲家的問題.這是我跑步時遇到的錯誤&#xff1a;php composer.phar install --dev錯誤&#xff1a;Richard-Knops-MacBook-Pro:my-project richardknop$php composer.phar install --devdyld: …

主機安裝php網站,php支持虛擬主機(php網站空間)

php設置虛擬主機&#xff0c;主要是為了在ie輸入地址欄是&#xff0c;可以輸入任意的&#xff0c;而不是localhost/&#xff0c;為了方便&#xff0c;但是設置起來很不方便的。。發現不能實現每個站點使用不同的PHP版本&#xff0c;想向大家求教一下&#xff0c;有沒有能讓。支…

php時分獲取秒數,javascript與php時/分/秒與秒數互轉

javascript&#xff1a;/*時間轉換成秒*/function time_to_second(time){var arr time.split(‘:‘)var hour arr[0]?arr[0]:0var minute arr[1]?arr[1]:0var second arr[2]?arr[2]:0var ret hour * 3600 minute * 60 secondreturn ret}/*秒轉換成時間*/function sec…

lbp matlab程序,求教大神給解釋一下LBP特征提取每部分程序是干什么的

該樓層疑似違規已被系統折疊 隱藏此樓查看此樓function X1 LBP(Resimage)% Returns a rotation invariant LBP (uniform patterns) histogram (10 bins)% of picture X.% the size of picture X must be at least 3x3 pixelsw1 (1/sqrt(2))^2;%根號1/2平方w2 (1-1/sqrt(2))*…

python以20字符寬居中輸出,Python 字符串內置方法(一)

以下方法只需要知道用法就行了&#xff0c;權當了解&#xff0c;不用硬背&#xff0c;以后需要用到的時候再回來看說明&#xff1a;一般方法中前面是is開頭的就是判斷來的&#xff0c;輸出不是True就是False&#xff0c;例如isalpha()方法capitalize()方法&#xff1a;首字母大…

php 復選框全選和取消,基于JavaScript實現復選框的全選和取消全選

這篇文章主要為大家詳細介紹了基于JavaScript實現復選框的全選和取消全選&#xff0c;具有一定的參考價值&#xff0c;感興趣的小伙伴們可以參考一下本文實例為大家分享了js復選框的全選和取消全選的具體代碼&#xff0c;供大家參考&#xff0c;具體內容如下效果圖&#xff1a;…

oracle 字段全大寫,Oracle如何批量將表中字段名全轉換為大寫(利用簡單存儲過程)...

前言今天查詢一個數據字段一直提示字符無效&#xff0c;明明在數據庫表字段中是存在的&#xff1b;查詢后得知&#xff0c;數據庫表字段為小寫時&#xff0c;查詢需要將字段名小寫并加上雙引號&#xff1b;表名同理&#xff0c;我這里表名是大寫&#xff0c;暫時不需要改。搜到…

oracle的al32utf8,oracle字符集修改(AL32UTF8-UTF8)

author&#xff1a;skatetime&#xff1a;2012/04/10AL32UTF8->UTF8步驟shutdown immediate;startup mount;alter session set sql_tracetrue;alter system enable restricted session;alter system set job_queue_processes0;alter system set aq_tm_processes0;alter data…

javascript date php date,JavaScript Date 知識淺析

Date函數new Date()Date 對象會自動把當前日期和時間保存為其初始值。date.getDate()從 Date 對象返回一個月中的某一天 (1 ~ 31)。date.getDay()從 Date 對象返回一周中的某一天 (0 ~ 6)。周日是0。date.getMonth()從 Date 對象返回月份 (0 ~ 11)。date.getFullYear()從 Date …

16字節 oracle md5,Oracle中的MD5加密

因為要用到MD5加密&#xff0c;所以在網上搜了一下相關資料&#xff0c;并進行仔細研究。其核心就是MD5編碼的數據包函數&#xff1a;DBMS_OBFUSCATION_TOOLKIT.M因為要用到MD5加密&#xff0c;所以在網上搜了一下相關資料&#xff0c;并進行仔細研究。其核心就是MD5編碼的數據…

ip字符串轉換 linux,Linux網絡編程入門

在日常使用&#xff0c;我們更多的使用十進制字符串表示IP地址&#xff0c;比如192.169.130.66&#xff0c;而不是記憶32位的IP地址(關鍵是太長了記不住呀)&#xff0c;使用字符串IP更為方便&#xff0c;可讀性也更好。但是根據上述in_addr定義&#xff0c;網絡編程中需要的是網…

linux php目錄是否存在,PHP判斷文件或者目錄是否可寫,兼容windows/linux系統

在PHP中&#xff0c;可用is_writable()函數來判斷一個 文件/目錄 是否可寫&#xff0c;用是否可生成文件的方式判斷目錄是否可寫&#xff1b;網上的一些代碼大多數能判斷linux系統&#xff0c;但windows服務器下判斷不準確。下面的代碼兼容windows和linux判斷文件或目錄是否可寫…

linux 腳本 發送郵件,shell 腳本發送郵件

有時候會使用腳本完成一系列的自動化工作&#xff0c;工作完成后還需要郵件通知相關人員&#xff0c;此時可以使用第三方的工具&#xff1a;SendEmail,最新版本sendEmail-v1.56.tar.gz下載地址&#xff1a;http://caspian.dotconf.net/menu/Software/SendEmail/sendEmil的使用范…

link linux 跨設備,Linux中的兩種link方式

Linux系統中包括兩種鏈接方式&#xff1a;硬鏈接(hard link)和符號鏈接(symbolic link)&#xff0c;其中符合鏈接就是所謂的軟鏈接(soft link)&#xff0c;那么兩者之間到底有什么區別呢&#xff1f;inode在Linux系統中&#xff0c;內核為每一個新創建的文件分配一個inode&…