php workerman定时任务的实现代码(3)
示例
shipments.php用来写定时任务
<?php /** * Created by PhpStorm. * User: Administrator * Date: 2018/11/29 * Time: 16:59 */ use Workerman\Worker; use \Workerman\Lib\Timer; require_once "Workerman/Autoloader.php"; require_once "Connection.php"; $task = new Worker(); $task->onWorkerStart = function ($task) { global $db, $redis; $db = new \Workerman\MySQL\Connection('127.0.0.1', '3306', 'root', 'root', 'test'); $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->auth("qqq123123."); $time_interval = 0.1; Timer::add($time_interval, function () { global $db, $redis; $insert['name'] = 123; $db->insert('shipments')->cols($insert)->query(); // sleep(100); }); }; function curlGet($url = '', $options = []) { $ch = curl_init($url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_TIMEOUT, 30); if (!empty($options)) { curl_setopt_array($ch, $options); } //https请求 不验证证书和host curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); $data = curl_exec($ch); curl_close($ch); return $data; } function newGetOrderInfo($taobao, $orderId) { $taobao = urlencode($taobao); $url = "http://114.55.144.79/taobao/TradeFullinfoGetRequest.php?shop=$taobao&tid=$orderId"; $json = curlGet($url); return json_decode($json, true)['trade']; } Worker::runAll();
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。