定时任务的进程问题

我看了php -m
pcntl这个是有的

代码按照手册规范要放在Applications/项目/start.php中，不知道killhook放在哪里运行的。

例如新建文件Applications/Test/start.php

use \Workerman\Worker;

$task = new Worker();
// 开启多少个进程运行定时任务，注意多进程并发问题
$task->count = 1;
$task->onWorkerStart = function($task)
{
    $time_interval = 2;
    \Workerman\Lib\Timer::add($time_interval, function()
    {
        echo "task run\n";
    });
};

这样表示要建立了一个Worker进程，Worker进程在启动的时候建立了一个定时任务，2秒运行一次，输出 “task run\n”

在workerman根目录运行 php start.php start 运行查看结果

首先很感谢你的耐心回答
问题确实如你所说，若要建立一个进程的话，这份代码必须放在项目的start.php文件中。
我的是放在自己建立的文件里了，所以不能新建进程，只能添加一个定时任务于当前进程。

另外还有一个问题想请教，我希望在start.php文件里添加一个定时任务，定时执行我自己建立的一个文件里的类里的函数。

但引入路径无论怎么写，都说致命错误，找不到类。
该文件路径为 Applications/项目/MyFunction/TictakEvent.php

TictakEvent.php的代码为

namespace MyFunction;
use \GatewayWorker\Lib\Gateway;
use \GatewayWorker\Lib\Store;

class TictakEvent
{

    public static function renwu_send($name){
        echo $name;
    }

}

按以下方式并不能引入。
use MyFunction\TictakEvent;
$task = new Worker();

$task->count = 1;
$task->onWorkerStart = function($task)
 {
     $time_interval = 3;
     \Workerman\Lib\Timer::add($time_interval, function()
     {
        \MyFunction\TictakEvent::renwu_send(‘test’);
     });
 };

use \Workerman\Worker; 这个已经引入了，我怕我描述的不够详细。
详细错误是说找不到这个类 \MyFunction\TictakEvent

可以更新下workerman
之前Worker没有实现业务类的自动加载，Gateway/Worker是有自动加载的
现在都加上了自动加载，可以试下

可以了，非常感谢

你好，之后又产生了新的问题。
已经可以在项目start文件里添加新进程定时运行我自己建立的文件了
在我自己的文件函数里，有用到
Gateway::sendToAll('{"message":"hehe","type":"test"}',$user_list);
但使用时报错

PHP Warning:  Invalid argument supplied for foreach() in /home/www/workerman/GatewayWorker/Lib/Gateway.php on line 54

$user_list 我var_dump出来是有值的。

array(2) {
  =>
  int(4)
  =>
  int(3)
}

但不知为何，传入sendToAll后，我在Gateway文件里加入了var_dump的语句来检查我传入的数组，结果却是
bool(false)

我可以确认，我的数组里的用户是在线的。

我这测试没有问题，这里是start.php的全部代码

<?php
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Lib\Timer;
use \Workerman\Worker;

// gateway
$gateway = new Gateway("Websocket://0.0.0.0:8585");

$gateway->name = 'TodpoleGateway';

$gateway->count = 4;

$gateway->lanIp = '127.0.0.1';

$gateway->startPort = 4000;

$gateway->pingInterval = 10;

$gateway->pingData = '{"type":"ping"}';

// bussinessWorker
$worker = new BusinessWorker();

$worker->name = 'TodpoleBusinessWorker';

$worker->count = 4;

// ##############让一个小蝌蚪定时说hello 开始#########
$task = new Worker();
$task->onWorkerStart = function($task){
    Timer::add(5, function(){
        $client_list = \GatewayWorker\Lib\Gateway::getOnlineStatus();
        \GatewayWorker\Lib\Gateway::sendToAll(json_encode(array('type'=>'message', 'id'=>current($client_list), 'message' => 'hello')));
    });
};
// ##############让一个小蝌蚪定时说hello 完毕#########

// WebServer
$web = new WebServer("http://0.0.0.0:8686");

$web->count = 2;

$web->addRoot('www.your_domain.com', __DIR__.'/Web');

你可以自己var_dump定位下是哪里的问题，问题应该很好找

你的代码我测试下来是没有问题的
我的代码放到项目/Event.php里于当前进程执行也是没有问题的
但是一旦放在我自己新建的文件里，问题就出来了。
经过跟踪调试发现，在\GatewayWorker\Lib\Gateway.php 文件的第42行起
如果是在项目的start.php文件里做的新建进程或者是在项目的Event.php里做的添加至当前进程，
在执行sendToAll时，self::$businessWorker为真，执行if里的语句
而如果是在项目start.php里新建进程去定时调用我自己建立的文件里的函数。
这个函数在执行sendToAll时，self::$businessWorker为假，执行的是else里的语句。
我想这就是问题所在吧。。

// 如果有businessWorker实例，说明运行在workerman环境中，通过businessWorker中的长连接发送数据
if(self::$businessWorker)
{
    foreach(self::$businessWorker->gatewayConnections as $gateway_connection)
    {
        $gateway_connection->send($gateway_data);
    }
}
// 运行在其它环境中，使用udp向worker发送数据
else
{
    $all_addresses = Store::instance('gateway')->get('GLOBAL_GATEWAY_ADDRESS');
    foreach($all_addresses as $address)
    {
        self::sendToGateway($address, $gateway_data);
    }
}

但是一旦放在我自己新建的文件里，问题就出来了。

这种情况是因为一个项目是基于Gateway/Worker的，另外一个项目是基于Worker的，Workerman/Applications下的多个项目是不相干的，Worker项目里面找不到Gateway/Worker的配置导致

解决办法：
可以手动require_once下Gateway/Worker项目下的Config/Store.php试下

经过尝试在项目里包含配置文件，这没有解决问题。

先把代码放start.php里跑起来再说吧。暂时不想折腾这个问题了。。。。

非常感谢你的耐心回答。

walkor,我郑重的向你道歉，我始终还是咽不下定时进程这口气，盯着你的源码看了良久，又在脑海里把Gateway/Worker 的进程模型翻来覆去的想。终于明白。都是我的错，为了便于调试，我在我自己的业务处理类里的客户登陆那加入了以下代码。
$store = Store::instance('room');
$store->flush();
这样，你的Gateway.php又哪里能取到值。。。。。
$all_addresses = Store::instance('gateway')->get('GLOBAL_GATEWAY_ADDRESS');

非常抱歉。以及感谢你的耐心和专业。

现在代码已经在愉快的正常工作了。

好的