接到一个需求:定时检查设备信息,2分钟没有心跳的机器,推送消息给相关人员,用thinkphp5框架,利用框架自带的任务功能与crontab配合来完成定时任务。
第一步:分析需求
- 先写获取设备信息,2分钟之内没有心跳的设备信息数据的功能;
- 再写推送消息给相关人员的功能;
- 写定时任务,调用推送消息的功能,将设备故障的数据通过飞书推送给相关人员处理;
第二步:开始编写代码
这个需求的难点在于推送消息和利用框架编写定时任务的功能,本文就定时任务的功能进行代码展示。
用的框架是thinkphp5框架,利用框架自带的任务功能与crontab配合来完成定时任务。
1. 在tp框架中编写逻辑代码
- 创建command模块,定义任务类:在项目application目录下创建command模块文件夹->创建任务类文件,继承
think\console\Command; think\console\Input; think\console\Output; 这三个文件。
- 编写任务逻辑代码:通过实现configure方法来设置任务的名称和描述,execute方法来实现执行任务的逻辑,可以调用其他的方法来实现具体的任务逻辑,例如:发送通知、处理数据等。
- 配置命令文件:在项目的application目录下的command.php文件中配置,返回一个数组,包含所有类的命名空间,这样thinkphp就知道可以执行的命令。
下面贴上代码,仅供参考:
<?php
namespace app\command;
use app\admin\controller\Message;
use think\console\Command;
use think\console\Input;
use think\console\Output;
/**
* 定时任务类
* Class Task
* User:赫陈
* Date: 2024-07-02
*/
class TaskF extends Command
{
// 设置命令名称和描述
protected function configure()
{
$this->setName('sendmessage')
->setDescription('设备故障发送消息到飞书群');
}
// 执行命令的逻辑
protected function execute(Input $input, Output $output)
{
// 在这里编写具体的任务逻辑,例如发送消息给用户
$output->writeln("开始发送消息...");
// 假设有一个方法 sendMessageToUser() 用于发送消息
$res = $this->sendMessageToUser();
$output->writeln("消息发送结果:".$res["message"]);
if($res['status'] != 'no'){
$output->writeln("消息发送完成!");
}
}
private function sendMessageToUser()
{
// 实现发送消息的具体逻辑,例如调用API或数据库操作等
$Message = new Message();
$res = $Message -> sendMessage();
return $res;
}
}
2. 测试代码
逻辑代码编写完后,打开终端,输入thinkphp的命令开始测试
命令:php think sendmessage
回车执行命令
第三步:配置crontab
1. 打开终端,输入crontab -e 命令,编写crontab文件
输入如下命令:
*/5 * * * * /usr/php/bin/php /home/www/project/think sendtofeishu >> /home/wwwroot/tuoluo/runtime/log/task.log 2>&1
解释:
命令*号的部分为分、时、日、月、周,把想要执行的时间写上,这个是每5分钟执行一次;
/usr/php/bin/php 这部分是php的安装路径,必须得写这个,要不然系统找不到可执行的系统;
/home/www/project/think sendtofeishu 这部分是项目的根目录路径,必须写全了,这样系统才能找到应用;
/home/wwwroot/project/runtime/log/task.log 这部分是执行任务产生的日志文件路径,文件若是没有会自动创建。
2. 保存并退出,用crontab -l 命令查看crontab命令。
第四步:查看执行日志
查看文件中配置的日志文件:用cat 文件名 或者tail -f 命令查看都行。