既然是结合tp5，咱当然要借鉴tp5的优势

# tp5自定义命令行

这个需要自己看tp5的官方文档，直接搜索就能找到，自己添加command.php文件，我的如下

~~~

/**

* Time: 13:55

*/

return [

'iss\crontab\command\IssServer',

'iss\crontab\command\IssClient',

];

~~~

但是要特别注意，文件的位置，放在目录application/command.php处，或者在入口文件中指定了配置文件目录，则将command.php放在配置目录下的根目录(必须的)，因为查看源码如下：


然后再添加个实例类来调用extend扩展中的服务端类，这样写只是为了规范些

~~~

namespace iss\crontab\command;

use think\console\Command;

use think\console\Input;

use think\console\Output;

class IssServer extends Command {

protected function configure(){

$this->setName('IssServer')->setDescription('定时任务服务端');

}

/**

* 启动服务端服务

* @return \lib\crontab\IssServer

*/

protected function execute(Input $input,Output $output){

$issServer= new \lib\crontab\IssServer();

if($issServer){

$output->writeln('服务端启动成功!');

}else{

$output->writeln('Sorry,服务端启动失败!');

}

}

}

?>

~~~

然后linux中cd到项目根目录，因为我们要用到项目中cli跟入口文件think，所以必须先cd到项目根目录

运行命令

`php think IssServer`

就可以将服务端实例化了，就不必在服务端类里自己new对象了

有些同学可能在安装的时候没有将php变量加入到环境变量中，系统不能识别php命令

可以运行如下命令(/usr/local/php是服务器上php的安装目录)同样可以启动

`/usr/local/php/bin/php -c /usr/local/php/etc/php.ini think IssServer`

这样就可以在扩展中轻松使用tp5的数据库连接等特性

# 设置程序进入后台作为守护进程一直运行


首先是配置server的daemonize属性并加载到服务器启动中，开启守护进程，接着在linux窗口运行启动命令时在命令后加“&”即可，例如

`php think IssServer &`

~~~

class IssServer{

private $serv;

private $debug = true;

public function __construct()

{

$config = config('crontab.server');

//extract($config);

$this->serv = new \swoole_server($config['host'], $config['port']);

$this->serv->set(array(

'daemonize' => $config['daemonize'], //设置程序进入后台作为守护进程运行

'dispatch_mode' => $config['dispatch_mode'], //指定数据包分发策略。1 => 轮循模式，收到会轮循分配给每一个worker进程 2 => 固定模式，根据连接的文件描述符分配worker。这样可以保证同一个连接发来的数据只会被同一个worker处理 3 => 抢占模式，主进程会根据Worker的忙闲状态选择投递，只会投递给处于闲置状态的Worker

'task_worker_num' => $config['task_worker_num'], //服务器开启的task进程数。

'task_ipc_mode' => $config['task_ipc_mode'], //设置task进程与worker进程之间通信的方式。

'log_file' => $config['log_file']

));

$this->serv->on('Start', array($this, 'onStart'));

$this->serv->on('WorkerStart', array($this, 'onWorkerStart'));

$this->serv->on('Connect', array($this, 'onConnect'));

$this->serv->on('Receive', array($this, 'onReceive'));

~~~