📅  最后修改于: 2023-12-03 15:31:24.929000             🧑  作者: Mango
Gearman 是一个分布式任务队列系统,可以在 Linux 上安装和管理。在本文中,我们将介绍如何在 Linux 上安装和设置 Gearman。
通过运行以下命令,可以在 Linux 上安装 Gearman 服务器和客户端:
sudo apt-get update
sudo apt-get install gearman-job-server gearman-tools
通过以下命令启动 Gearman 服务器:
sudo service gearman-job-server start
您还可以使用以下命令检查 Gearman 服务器是否正在运行:
sudo service gearman-job-server status
接下来,我们将测试 Gearman 是否正在工作。我们将运行以下命令,以便在 Gearman 服务器上注册一个名称为“reverse”的函数:
echo -n 'test' | gearman -h 127.0.0.1 -p 4730 -f reverse --no-utf8
现在,我们将编写一个 Python 脚本,该脚本将定义一个名为“reverse”的函数,该函数将接受一个字符串参数并将其反转,然后将其返回给 Gearman 客户端。
#!/usr/bin/env python
import gearman
import socket
gm_worker = gearman.GearmanWorker(['localhost:4730'])
def reverse_job_listener(gearman_worker, gearman_job):
print 'Received job: ' + gearman_job.data
reverse_str = gearman_job.data[::-1]
print 'Reversed string: ' + reverse_str
return reverse_str
gm_worker.set_client_id(socket.gethostname())
gm_worker.register_task('reverse', reverse_job_listener)
# Enter our work loop and call gm_worker.after_poll() after each time we timeout/see socket activity
gm_worker.work()
在运行上面的 Python 脚本之前,请确保您已安装 Gearman Python 模块。您可以使用以下命令来安装:
sudo pip install gearman
现在,可以运行 Python 脚本并发送一个字符串以测试 Gearman。使用以下命令运行 Python 脚本:
python gearman_worker.py
然后,运行以下命令将一个字符串传递给 Gearman:
echo -n 'test' | gearman -h 127.0.0.1 -p 4730 -f reverse --no-utf8
在 Gearman 终端中,您应该会看到类似以下输出的反向字符串:
Received job: test
Reversed string: tset
现在,您已经知道如何在 Linux 上安装和设置 Gearman,并使用 Gearman 完成基本任务。我们希望本文对您有所帮助!