### Python 中 Gearman 的使用教程 #### 安装 Gearman 和其依赖项 要在 Linux 系统上安装 Gearman 及其服务端组件，可以通过包管理工具完成。例如，在基于 Debian/Ubuntu 的系统中，可以运行以下命令来安装 Gearman 服务器[^3]: ```bash sudo apt-get update && sudo apt-get install gearman-job-server ``` 对于 RedHat/CentOS 系统，则可以执行如下命令： ```bash yum -y install gearmand chkconfig gearmand on && /etc/init.d/gearmand start ``` 通过编辑 `/etc/sysconfig/gearmand` 文件中的 `OPTIONS=""` 参数，还可以配置持久化功能或其他高级选项。 #### 配置 Python 支持 Gearman 由于官方的 `gearman` 库不再支持 Python 3.x 版本，因此推荐使用社区维护的替代方案，比如 `python-gearman-v2` 或其他兼容版本。以下是安装方法： ```bash pip install python-gearman-v2 ``` 此库提供了与原始 `gearman` 类似的接口设计，能够满足大多数开发需求[^1]。 #### 编写 Worker 脚本 Worker 是负责处理任务的工作单元。下面是一个简单的反向字符串示例代码片段[^4]: ```python import gearman def task_listener_reverse(gearman_worker, gearman_job): reversed_data = gearman_job.data[::-1] print(f"Reversing string: {reversed_data}") return reversed_data + " Done" gm_worker = gearman.GearmanWorker(['localhost:4730']) gm_worker.register_task('reverse', task_listener_reverse) print("Waiting for jobs...") gm_worker.work() ``` 这段脚本定义了一个名为 `'reverse'` 的任务监听器函数，它接收输入数据并返回反转后的结果加上 `" Done"` 字符串作为响应消息。 #### 创建 Client 并提交作业 客户端用于发送请求给 Workers 执行特定的任务。这里展示如何批量创建多个任务并将它们交给远程服务器去计算[^5]: ```python import gearman from gearman.constants import JOB_UNKNOWN import time def check_request_status(job_request): if job_request.complete: print(f"Job {job_request.gearman_job.unique} finished! Result: {job_request.state}, Output={job_request.result}.") elif job_request.timed_out: print(f"Job {job_request.gearman_job.unique} timed out!") elif job_request.state == JOB_UNKNOWN: print(f"Job {job_request.gearman_job.unique} connection failed!") client = gearman.GearmanClient(['127.0.0.1:4730']) jobs_to_submit = [] for index in range(10): unique_id = f"id-{index}" payload = {"task": "echo", "data": f"Message #{unique_id}"} jobs_to_submit.append(payload) submitted_requests = client.submit_multiple_jobs(jobs_to_submit, background=False, wait_until_complete=True) time.sleep(2) # Allow some processing delay before checking status. completed_requests = client.get_job_statuses(submitted_requests) for request in completed_requests: check_request_status(request) ``` 以上程序展示了怎样利用循环结构生成一系列待办事项列表，并将其传递至指定地址上的 Gearman Daemon 进行异步并发运算；最后再逐一验证每条记录的状态信息反馈情况。 --- ###