了解Gearman,請造訪gearman官網:gearman.org/
+++++++++++++++++++++++++++++++++++++ +++++++++
安裝Gearman:
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ ++++++++++
基礎依賴函式庫:
yum install boost-devel libevent-devel sqlite-devel libuuid-devel wget https://launchpad.net/gearmand/trunk/0.33/+download/gearmand-0.33.tar.gz tar xzvf gearmand-0.33.tar.gz cd gearmand-0.33 ./configure make make install
+++++++++++++++++++++++++++++++ +++++++++++++
安裝Gearman Python客戶端
++++++++++++++++++++++++++++ ++++++++++++++++
wget http://pypi.python.org/packages/source/g/gearman/gearman-2.0.2.tar.gz#md5=3847f15b763dc680bc672a610b77c7a7 tar xvzf gearman-2.0.2.tar.gz python setup.py install
獲取直接用自動安裝: easy_install gearman
啟動服務:gearmand -d
啟動 Worker:gearman -w -f wc -- wc -l &
-w 代表啟動的是worker,-f wc 代表啟動一個task名字為wc, -- wc -l表示這個task是做wc -l 統計行數。
啟動Client:gearman -f wc < /etc/passwd
++++++++++++++++++++++++++++++++++ ++++++++++
python work程式碼:
++++++++++++++++++++++++++++++++ ++++++++++++
import os import gearman import math class MyGearmanWorker(gearman.GearmanWorker): def on_job_execute(self, current_job): print "Job started" return super(MyGearmanWorker, self).on_job_execute(current_job) def task_callback(gearman_worker, gearman_job): print gearman_job.data return gearman_job.data my_worker = MyGearmanWorker(['192.168.0.75:4730']) my_worker.register_task("echo", task_callback) my_worker.work()
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ +++++++++
python client程式碼:
+++++++++++++++++++++++++++++++++ +++++++++++
from gearman import GearmanClient gearman_client = GearmanClient(['192.168.0.75:4730']) gearman_request = gearman_client.submit_job('echo', 'foo') result_data = gearman_request.result print result_data