thinphp/swoole 扩展包的使用

composer require topthink/think-swoole=2.0.*

php think swoole

use appcommonlibutilsTask;
use thinkfacadeEnv;
use thinkfacadeLog;

// +----------------------------------------------------------------------
// | 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);
    }
];

<?php

namespace appindexcontroller;

use appcommonlibtaskSmsTask;
use appcommonlibutilsTool;use thinkController;
use thinkRequest;

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(‘‘,‘短信发送成功‘);
    }

<?php


namespace appcommonlibtask;

use FairySmsSender;
use thinkfacadeConfig;
use thinkswooletemplateTask;

/**
 * 使用 topthink/swoole 自带的Task任务
 * Class SmsTask
 * @package appcommonlibtask
 */
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();
        }
    }
}

<?php

namespace appcommonlibutils;

use FairySmsSender;use thinkfacadeConfig;

/**
 * 异步任务类
 * Class Task
 * @package appcommonlibutils
 */
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();
        }
    }
}