Workerman 能提供类似 StopHandler 的功能来让用户控制安全停止吗？

pader 更新于2021-05-08

比如一个定时任务在执行中有两步操作，Workerman 在使用 stop 停止时可能会出现前一个操作完成后一个操作未完成就停止的情况，虽然 Workerman 提供了 -g 参数来等待链接全部关闭后停止，但是这两个操作可能没有链接，也可能是长链接不会主动关闭。

有没有一种机制，让用户自己控制这个关闭流程，比如向 Workerman 中注册一个 StopHandler，当 Workerman 使用 stop 时，触发这些 StopHandler，然后每个 Handler 以回调的形式告诉 Workerman 自己是否已经可以结束了，当所有 StopHandler 都告诉 Workerman 完成时，才真正结束。

现在有些长时间执行的任务，从零点几秒到几十秒不等，中间去读数据库，也会操作本地文件，也可能还有生成图片，还有可能去连接远程的 http 接口，很容易出现这种情况下停止 Workerman 导致任务和数据处理了一半的情况。。

 2002  5 0

5个回答

walkor 2021-04-21

打赏

如果stop不用-g，workerman主进程给子进程发出stop信号后，如果对应子进程2秒没没有正常退出，主进程会发送kill信号强行杀死对应进程，这种情况可能会导致业务处理一半的情况。

如果stop使用-g则不会强行杀死子进程，就不会有这个问题了。

我觉得你说的这个问题用-g就能解决。

暂无评论

pader 2021-05-08

@walkor

-g 并不能完全解决，-g 只是等待连接关闭然后停止进程，但是业务可能建立了不会关闭的长连接，比如与 Channel 之间的连接，也有可能有一个循环执行的定时器，这个定时器要安全停止必须要做一些相关的工作，也有可能正在作一些其它的工作，这个工作是与连接无关的。

我看到国外的框架有个很好的思路，这里可以参考一下，比如我可以主动安装一个信号监听器，当发起停止命令时（也可以针对 -g 的停止，但 -g 的问题就是它要等待连接关闭，对有长链接时一直无法停止），就会触发这个监听器，这个监听器需要主动解除自己的监听，当所有的监听器都解除后，程序才退出。

示例如下：

Worker::onSignal(SIGHUP, function($watcherId) {
    echo "收到 SIGHUP 安全停止信号，正在处理中..\n";

    MyTasks::stopWorking();

    //做一些收尾工作
    //停止接收新的任务
    //等待正在进行的任务的结束

    MyTasks::onCurrentTaskFinished(function() use ($watcherId) {
        echo "MyTasks 已安全结束。\n";
        Worker::cancel($watcherId);
    });
});

这样的话，用户可以控制自己的业务安全退出。

暂无评论

walkor 2021-05-08

打赏

workerman 提供了 onWorkerStop 回调，MyTasks::stopWorking(); 可以在这里运行，在这里你可以关闭所有连接，等所有连接关闭了就自动退出了。

暂无评论

pader 2021-05-08

重点是些工作并不是关闭连接那么简单，而且有些清理工作是异步的。而 onWorkerStop 并不会等我去清理，它同步执行完了就关闭了。

暂无评论

pader 2021-05-08

这个 -g 只是等待连接关闭我觉得其实没有什么用处，只能用在简单的短连接场景，比如我使用异步的 Redis 建立了连接，我和 Channel 建立了连接，这些连接本身是处于一层层的封装之下，并不适合把他们都收集来关闭，再比如我可能有一个定时器，每秒钟执行，这个定时器要安全关闭必须要等里面的东西完全执行完，而这个定时器内部的东西又有可能是异步的动作，这些异步操作也可能不是网络请求啊，也可能我装了个扩展是异步写文件呢。

这时去主动关闭这些连接显然很复杂，需要更有效的办法，我觉得自定义信号监听器就是个不错的办法。

每添加一个监听器，就有一个 countDown 计数增加，当它们收到信息号主动 cancel($watcherId) 的时候，这个 countDown 就减少，当减少到 0 的时候就退出，这样用户可以自己手动控制安全关闭的过程。

算了，有空我来提个 Pull Request 吧。。