脚本宝典收集整理的这篇文章主要介绍了thinphp/swoole 扩展包的使用,脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。
本想自己适配的,奈何keng貌似不少,所以果断选择官方提供的包来适配233。。。
默认条件:thinkPHP5.1.*版本下,且安装了swoole扩展
主要演示 task 任务的投递
composer require topthink/think-swoole=2.0.*
如果你要运行 swoole 的 http 服务器来启动 thinkPHP框架,执行
PHP think swoole
默认启动完成后,会在0.0.0.0:9501启动一个HTTP Server,可以直接访问当前的应用。
swoole的参数可以在应用配置目录下的 swoole.PHP 里面配置,配置详情见 thinkPHP官网
扩展中定义了 onWorkerStart
和 onRequest
事件回调方法(如果不熟悉请不要随意替换),如果你需要自定义swoole
的事件回调方法,可以在配置文件中使用闭包定义。
以下是我的配置(自定义了task任务回调):
use app\common\lib\utils\Task; use think\faCADe\env; use think\facade\LOG; // +---------------------------------------------------------------------- // | Swoole设置 PHP think swoole命令行下有效 // +---------------------------------------------------------------------- return [ // 扩展自身配置 ‘host‘ => ‘0.0.0.0‘,// 监听地址 ‘port‘ => 9501,// 监听端口 ‘mode‘ => ‘‘,// 运行模式 默认为SWOOLE_PROCESS ‘sock_tyPE‘ => ‘‘,// sock type 默认为SWOOLE_SOCK_TCP ‘server_type‘ => ‘http‘,// 服务类型 支持 http websocket ‘app_path‘ => ‘‘,// 应用地址 如果开启了 ‘daemonize‘=>true 必须设置(使用绝对路径) ‘file_monITor‘ => false,// 是否开启PHP文件更改监控(调试模式下自动开启) ‘file_monitor_interval‘ => 2,// 文件变化监控检测时间间隔(秒) ‘file_monitor_path‘ => [],// 文件监控目录 默认监控application和config目录 // 可以支持swoole的所有配置参数 ‘pid_file‘ => Env::get(‘runtime_path‘) . ‘swoole.pid‘,‘log_file‘ => Env::get(‘runtime_path‘) . ‘swoole.log‘,‘document_root‘ => Env::get(‘root_path‘) . ‘public‘,‘enable_static_handler‘ => true,‘timer‘ => true,//是否开启系统定时器 ‘interval‘ => 500,//系统定时器 时间间隔 ‘task_worker_num‘ => 1,//swoole 任务工作进程数量 /** * 自定义投递任务 * @param swoole_server $serv * @param int $taskId * @param int $srcWorkerId * @param mixed $data */ ‘Task‘ => function($serv,$taskId,$srcWorkerId,$data){ $taskObj = new Task(); $classMethods = get_class_methods(Task::class); if (!in_array($data[‘method‘],$classMethods)) { return ‘method:‘.$data[‘method‘].‘ not find in‘.Task::class; } return call_user_func_array([$taskObj,$data[‘method‘]],$data[‘params‘]); },/** * onTask事件中没有调用finish方法或者return结果,worker进程不会触发onFinish * @Param swoole_server $serv * @param int $taskId 任务的ID * @param string $data 任务处理的结果内容 */ ‘Finish‘ => function ($serv,$data) { // echo ‘taskId:‘ . $taskId . PHP_EOL; echo ‘Finished:‘ . $data; Log::record($data); } ];
Index控制器中:
<?PHP namespace app\index\controller; use app\common\lib\task\SmsTask; use app\common\lib\utils\Tool;use think\Controller; use think\Request; class Index extends Controller {
public function sendSms(Request $request) { $result = $this->validate($request->post(),[‘mobile‘ => ‘require|mobile‘]); if (true !== $result) { return Tool::json(‘‘,$result,250); } $mobile = $request->post(‘mobile‘); // 1、使用topthink/swoole自带的任务投递方式,传递参数必须是对象或者swoole回调函数 // $smsObj = new SmsTask($mobile); // app(‘swoole‘)->task($smsObj); // app(‘swoole‘)->task($smsObj); // 2、自定义任务投递方式 app(‘swoole‘)->task(Tool::taskParam(‘sendSms‘,(array)$mobile)); return Tool::json(‘‘,‘短信发送成功‘); }
SmsTask.PHP
使用系统默认的回调模板,
且投递的参数必须是对象或者swoole回调函数,
投递任务后默认会执行 run()方法或者swoole回调函数
<?PHP namespace app\common\lib\task; use Fairy\SmsSender; use think\facade\Config; use think\swoole\template\Task; /** * 使用 topthink/swoole 自带的Task任务 * Class SmsTask * @package app\common\lib\task */ class SmsTask extends Task { private $mobile; public function initialize($args) { // TODO: Implement initialize() method. $this->mobile = $args[0]; } public function run($serv,$FromWorkerId) { // TODO: Implement run() method. $smsObj = SmsSender::getInstance(Config::get(‘mail.‘)); $bool = $smsObj->send($this->mobile); if ($bool) { return ‘send sms to ‘ . $this->mobile . ‘ success‘; } else { return $smsObj->getError(); } } }
Task.PHP
<?PHP namespace app\common\lib\utils; use Fairy\SmsSender;use think\facade\Config; /** * 异步任务类 * Class Task * @package app\common\lib\utils */ class Task { /** * 异步发送短信 * @param $mobile * @return mixed|string * @throws \ErrorException */ public function sendSms($mobile) { $smsObj = SmsSender::getInstance(Config::get(‘sms.‘)); $bool = $smsObj->send($mobile); if ($bool) { return ‘send sms to ‘ . $mobile . ‘ success‘; } else { return ‘send sms to ‘ . $mobile . ‘ Failed: ‘ . $smsObj->getError(); } } }
参考:
以上是脚本宝典为你收集整理的thinphp/swoole 扩展包的使用全部内容,希望文章能够帮你解决thinphp/swoole 扩展包的使用所遇到的问题。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。