一、概述:
Gearman是一款非常優秀的任務分發框架,可以用于分布式計算。具體的gearmand服務的安裝啟動及gearman的python 模塊的安裝以及簡單示例如下:
操作系統:rnel 5.7
1. 首先,我們需要安裝gearmand,在centos和rhel環境下,我們只需運行以下命令:
yum install gearmand -y
注意:如果不希望通過yum的方式來安裝gearmand,可以通過源碼編譯安裝,具體安裝方法可以參考:http://www.gxlcms.com/article/51999.htm
安裝完畢之后,就可以啟動gearmand服務:
gearmand -p 4730 -L 10.22.10.90 --log-file=/tmp/gearmand-4730.log --pid-file=/tmp/gearmand-4730.pid -d
2. 安裝python-gearman
gearman的python模塊,下載地址為:https://pypi.python.org/pypi/gearman/2.0.2
我們可以用以下命令安裝(兩個命令均可,二選一):
easy_install gearman
pip install gearman
或者也可以通過源碼安裝:
wget https://pypi.python.org/packages/source/g/gearman/gearman-2.0.2.tar.gz --no-check-certificate tar zxvf gearman-2.0.2.tar.gz cd gearman-2.0.2 python setup.py install
這樣,我們就完成了python-gearman的安裝。
二、使用示例:
下面,列舉一個簡單的python例子:
首先,我們需要編寫一個worker,代碼如下:
1.文件名:echoWorker.py
#!/usr/bin/env python import os import gearman import math class MyGearmanWorker(gearman.GearmanWorker): def on_job_execute(self, current_job): print "Job started" print "=================== " return super(MyGearmanWorker, self).on_job_execute(current_job) def task_callback(gearman_worker, gearman_job): print gearman_job.data print "----------- " return gearman_job.data my_worker = MyGearmanWorker(['10.22.10.47:4730']) my_worker.register_task("echo", task_callback) my_worker.work()
2.編寫client,如下:
文件名:echoClient.py
#!/usr/bin/env python2.7 from gearman import GearmanClient gearman_client = GearmanClient(['192.168.12.34:4730']) gearman_request = gearman_client.submit_job('echo', 'test gearman') result_data = gearman_request.result print result_data
注意上面GearmanClient(['192.168.12.34:4730'])中的IP地址,需要根據實際啟動gearmand服務的IP地址和端口號為準。
3.然后,我們運行以下命令:
python echoWorker.py python echoClient.py
至此,即可看到輸出。
聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com