有什么方法可以访问 Gearman 管理吗？

Question

我希望能够查询 gearman 服务器以确定我正在运行的工作线程的实例数（基本上我想确保 RunTaskA 可用并且 RunTaskB 可用如果没有工作人员处理这些任务，我希望能够发送警报。

有什么方法可以做到这一点吗？

另外：如果你知道查询 gearman 服务器的 PHP 方法，那就太疯狂了

。 /strong>：我知道本机可用的 PHP gearman 扩展，但我不是在寻找任务提交扩展，我需要一些允许我查询 gearman 服务器并查看有多少工作人员正在执行特定任务的东西。

Answer 1

class Waps_Gearman_Server {

    /**
     * @var string
     */
    protected $host = "127.0.0.1";
    /**
     * @var int
     */
    protected $port = 4730;

    /**
     * @param string $host
     * @param int $port
     */
    public function __construct($host=null,$port=null){
        if( !is_null($host) ){
            $this->host = $host;
        }
        if( !is_null($port) ){
            $this->port = $port;
        }
    }

    /**
     * @return array | null
     */
    public function getStatus(){
        $status = null;
        $handle = fsockopen($this->host,$this->port,$errorNumber,$errorString,30);
        if($handle!=null){
            fwrite($handle,"status\n");
            while (!feof($handle)) {
                $line = fgets($handle, 4096);
                if( $line==".\n"){
                    break;
                }
                if( preg_match("~^(.*)[ \t](\d+)[ \t](\d+)[ \t](\d+)~",$line,$matches) ){
                    $function = $matches[1];
                    $status['operations'][$function] = array(
                        'function' => $function,
                        'total' => $matches[2],
                        'running' => $matches[3],
                        'connectedWorkers' => $matches[4],
                    );
                }
            }
            fwrite($handle,"workers\n");
            while (!feof($handle)) {
                $line = fgets($handle, 4096);
                if( $line==".\n"){
                    break;
                }
                // FD IP-ADDRESS CLIENT-ID : FUNCTION
                if( preg_match("~^(\d+)[ \t](.*?)[ \t](.*?) : ?(.*)~",$line,$matches) ){
                    $fd = $matches[1];
                    $status['connections'][$fd] = array(
                        'fd' => $fd,
                        'ip' => $matches[2],
                        'id' => $matches[3],
                        'function' => $matches[4],
                    );
                }
            }
            fclose($handle);
        }

        return $status;
    }

}

Answer 2

为了快速检查，我使用了这个 bash 单行代码：

# (echo status ; sleep 0.1) | netcat 127.0.0.1 4730

这将打开与本地主机上运行的 gearman 实例的连接，并发送“状态”查询。其中包含该实例上作业的名称和数量。然后可以使用 grep/awk/wc 等处理该信息以进行报告和警报。

我也对“workers”查询执行相同的操作，该查询显示所有连接的工作人员。

# (echo workers ; sleep 0.1) | netcat 127.0.0.1 4730

睡眠是为了保持连接打开足够长的时间以进行回复。

管理命令的完整列表以及输出的含义位于 http://gearman.org/index .php?id=protocol 只需搜索“管理协议”

Answer 3

为了扩展 d5ve 的答案，由于 netcat 将坐在套接字上等待，因此您可以添加一个 -w 参数以及运行的最大秒数。因此，如果您正在查询 localhost:

# (echo status ; sleep 0.1) | netcat 127.0.0.1 4730 -w 1

...，否则您将永远不会回到命令提示符。

Answer 4

据我所知，gearman 中没有这样的扩展，管理和监视工作脚本是您的责任，您可以为此目的尝试其中一个 -

Supervisord 是一个 python 应用程序，用于在后台运行应用程序并监视它们。

或者您可以使用 brian Moon 的 gearman manager

Answer 5

我想你需要这个
http://github.com/liorbk/php

Answer 6

Gearman 有一个 php 扩展。你调查过了吗？

PHP 链接

Answer 7

今天偶然发现它，我自己还没有测试过，但看起来很有希望。

https://github.com/yugene/Gearman-Monitor

Answer 8

在 Python 中，您可以执行以下操作：

import gearman

admin_client = gearman.GearmanAdminClient(['127.0.0.1:4730',])
status = admin_client.get_status()
for w in status:
   if w["task"] == "YOUR_TASK_NAME":
      print(w)

注意：您必须使用 pip 或 easy_install 安装名为“gearman”的软件包，以避免运行上述代码时出现任何异常。

另外，请检查以下管理客户端，它们总体上简化了 gearman 的管理。

• 通过基于 Django 的界面轻松监控和管理 Gearman 服务器
• Gearman 服务器的监控工具
• PHP 守护进程管理 gearman 工作人员
• Gearman 作业服务器的 PHP 监控仪表板
• 位于 gearman 之上的 http 服务器

Answer 9

当其他一切都失败时，您可以使用 Ubuntu 中 gearman-tools 包中的 gearadmin 工具，通过调用 exec() 来执行它新流程。这是对其输出格式的参考。

这假设 PHP 和 Gearman 在同一服务器上运行。