如何获取 gearman 中特定类型的排队作业数量？

Question

我有很多 gearman 客户发送了一份作业，比如 job1。

$client = new GearmanClient();
$client->addServer();
$client->doBackground('job1', 'workload');

处理此作业需要 10 秒钟。 我想跟踪在任何给定时间有多少“job1”工作正在等待工人处理。我怎样才能做到这一点？

Answer 1

为了快速检查，我使用了这个 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/protocol/ 。只需搜索“管理协议”即可。

Answer 2

为了扩展 d5ve 的答案，添加一个 -w 参数来“超时”你的 netcat 连接，否则你永远不会回到命令提示符。

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

Answer 3

telnet localhost 4730
status

worker_name total_queue currently_running number_of_workers
job1         1          1                 9

Answer 4

我使用 gearman_top，它是 mod 的一部分-齿轮工。

网站的输出示例：

+-----------------------+--------+-------+-------+---------+
| Name                  | Worker | Avail | Queue | Running |
+-----------------------+--------+-------+-------+---------+
| check_results         | 1      | 1     | 0     | 0       |
| host                  | 3      | 3     | 0     | 0       |
| service               | 3      | 3     | 0     | 0       |
| eventhandler          | 3      | 3     | 0     | 0       |
| servicegroup_jmx4perl | 3      | 3     | 0     | 0       |
| hostgroup_japan       | 3      | 3     | 0     | 0       |
+-----------------------+--------+-------+-------+---------+

Answer 5

在 Ubuntu 18.04 上，我默认使用 gearman 包安装了 gearadmin 二进制文件。

gearadmin --help
可以使用 gearadmin --status 代替 netcat 替代方案：

gearadmin --status
queue1    334     10      10

还有一个衬垫：
<代码>同时:;执行 gearadmin --status；睡觉1；完成

Answer 6

看起来没有任何直接的方法可以获取此信息。

这里有几个选项。首先，您是否可以在创建作业句柄时获取作业句柄 （搜索“谈到检查状态”），您可以将它们存储在某个中心位置并从任何客户端查询它们。

其次，您可以将 Gearman 服务器设置为使用持久队列，并且然后自己对队列运行查询。这可能是两个选项中更简单、更干净的一个。

Answer 7

Gearmand有一个telnet接口可以查询。 （协议的具体细节可以在 gearman 网站上找到 - http://gearman.org/?id=协议）

我在这里使用此代码作为滚动我自己的代码的起点。
https://github.com/liorbk/php/blob/master/GearmanTelnet.php
（这段代码本身就非常好，您应该能够直接使用它）

这是一个不太漂亮的解决方案，但直到有人改进 gearman 管理界面，以便您可以直接通过 PHP 进行对话或为其编写一个插件，您靠你自己