编译安装Gearman、python简单测试

sudo yum install boost-devel libevent-devel sqlite-devel libuuid-devel

./configure --with-mysql=/opt/db/Percona-Server-5.5.21-rel25.0/bin/mysql_config --prefix=/opt/gearmand-0.33

* Building with libsqlite3  yes
 * Building with libdrizzle  no
 * Building with libmemcached no
 * Building with libpq    no
 * Building with tokyocabinet no
 * Building with libmysql   yes

make && make install

libgearman-server/plugins/queue/mysql/queue.cc:49:25: fatal error: mysql/mysql.h: No such file or directory

checking if MySQL version is >= 5.0... yes

checking for mysqld... /opt/db/Percona-Server-5.5.21-rel25.0/bin/mysqld

./gearmand -L 127.0.0.1 -p 7003

easy_install gearman

#!/usr/bin/env python2.7
# -*- coding: utf-8 -*-
# file: worker.py
           
import os  
import gearman  
import math  
              
class CustomGearmanWorker(gearman.GearmanWorker):  
    def on_job_execute(self, current_job):  
        print "开始......"
        print "工作中......"
        print '结束'
           
        return super(CustomGearmanWorker, self).on_job_execute(current_job)  
            
def task_callback(gearman_worker, job):  
    print job.data  
    return job.data  
            
new_worker = CustomGearmanWorker(['127.0.0.1:7003'])  
new_worker.register_task("echo", task_callback)  
new_worker.work()

python worker.py

#!/usr/bin/env python2.7
# -*- coding: utf-8 -*-
# file: client.py
           
from gearman import GearmanClient  
            
new_client = GearmanClient(['127.0.0.1:7003'])  
current_request = new_client.submit_job('echo', 'foo')  
new_result = current_request.result  
print new_result

python client.py