Thinkphp 队列 think-queue 官方文档 官方文档安装composer require topthink/think-queue配置配置文件位于 config/queue.php公共配置[ 'default'=>'sync' //驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动//或其他自定义的完整的类名 ]创建任务类单模块项目推荐使用 app\job 作为任务类的命名空间多模块项目可用使用 app\module\job 作为任务类的命名空间也可以放在任意可以自动加载到的地方任务类不需继承任何类，如果这个类只有一个任务，那么就只需要提供一个fire方法就可以了，如果有多个小任务，就写多个方法，下面发布任务的时候会有区别 每个方法会传入两个参数 think\queue\Job $job（当前的任务对象） 和 $data（发布任务时自定义的数据）还有个可选的任务失败执行的方法 failed 传入的参数为$data（发布任务时自定义的数据）下面写两个例子namespace app\job; use think\queue\Job; class Job1{ public function fire(Job $job, $data){ //....这里执行具体的任务 if ($job->attempts() > 3) { //通过这个方法可以检查这个任务已经重试了几次了 } //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法 $job->delete(); // 也可以重新发布这个任务 $job->release($delay); //$delay为延迟时间 } public function failed($data){ // ...任务达到最大重试次数后，失败了 } } namespace app\lib\job; use think\queue\Job; class Job2{ public function task1(Job $job, $data){ } public function task2(Job $job, $data){ } public function failed($data){ } } 发布任务think\facade\Queue::push($job, $data = '', $queue = null) 和 think\facade\Queue::later($delay, $job, $data = '', $queue = null) 两个方法，前者是立即执行，后者是在$delay秒后执行$job 是任务名 单模块的，且命名空间是app\job的，比如上面的例子一,写Job1类名即可 多模块的，且命名空间是app\module\job的，写model/Job1即可 其他的需要些完整的类名，比如上面的例子二，需要写完整的类名app\lib\job\Job2 如果一个任务类里有多个小任务的话，如上面的例子二，需要用@+方法名app\lib\job\Job2@task1、app\lib\job\Job2@task2$data 是你要传到任务里的参数$queue 队列名，指定这个任务是在哪个队列上执行，同下面监控队列的时候指定的队列名,可不填监听任务并执行php think queue:listenphp think queue:work两种，具体的可选参数可以输入命令加 --help 查看可配合supervisor使用，保证进程常驻

thinkphp6.0 + Workerman+ GatewayWorker websocket通讯 毫无疑问 重点在 Workerman Workerman是一款纯PHP开发的开源高性能的PHP socket 服务框架。GatewayWorker基于Workerman开发的一个项目框架，用于快速开发TCP长连接应用，例如app推送服务端、即时IM服务端、游戏服务端、物联网、智能家居等等ThinkPHP 手册中有部分在框架中的使用说明首先通过 composer 安装composer require topthink/think-worker次扩展中说明了 两种启动方式 使用Workerman作为HttpServerphp think worker SocketServerphp think worker:server 其他按照文档配置足够或者按照 Workerman 手册 进行配置说到这好像没有 GatewayWorker 的影子 如果不使用 GatewayWorker 也可以不进行安装 单独安装workerman 也可以 ，同时 topthink/think-worker ThinkPHP 官方扩展包一样可以不用安装，如果使用 官方扩展包 以及 GatewayWorker 的话 怎么用呢 ![]![1583398260914.jpg]源码中使用命令 的只是文档没有说明 使用 php think worker:gateway 启动 扩展中的 GatewayWorker 即可 ![]![1583398260914.jpg]![1583398226142.jpg]之后只需要配置 gateway_worker.php配置文件中配置![]自定义业务处理就好了文件中都有说明，简单的很

ThinkPHP5.1+ Swoole 实现 websocket SwooleSwoole是一个面向生产环境的 PHP 异步网络通信引擎。使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP，WebSocket 服务。安装首先按照Swoole官网说明安装swoole扩展，然后安装think-swoole扩展。composer require topthink/think-swoole=2.0.*安装之后会在 config 目录下生成两个配置文件 swoole.phpswoole_server.php两者 作用不用 http 跟 socket使用 socket 看 swoole_server.php这是默认配置return [ // 扩展自身配置 'host' => '0.0.0.0', // 监听地址 'port' => 9501, // 监听端口 'type' => 'socket', // 服务类型 支持 socket http server 'mode' => SWOOLE_PROCESS, 'socket_type' => SWOOLE_SOCK_TCP, // 可以支持swoole的所有配置参数 'daemonize' => false, // 事件回调定义 'onOpen' => function ($server, $request) { echo "server: handshake success with fd{$request->fd}\n"; }, 'onMessage' => function ($server, $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); }, 'onRequest' => function ($request, $response) { $response->end("<h1>Hello Swoole. #" . rand(1000, 9999) . "</h1>"); }, 'onClose' => function ($ser, $fd) { echo "client {$fd} closed\n"; }, ];也可自行定义return [ 'swoole_class' => 'socket\Swoole\PustServer', ];自定义类需继承 \think\swoole\Server支持响应事件['Start', 'Shutdown', 'WorkerStart', 'WorkerStop', 'WorkerExit', 'Connect', 'Receive', 'Packet', 'Close', 'BufferFull', 'BufferEmpty', 'Task', 'Finish', 'PipeMessage', 'WorkerError', 'ManagerStart', 'ManagerStop', 'Open', 'Message', 'HandShake', 'Request']简单的 DEMO namespace socket\Swoole; use \think\swoole\Server; use socket\Swoole\libs\MessageHandler; class PustServer extends Server { protected $host = '0.0.0.0'; //监听所有地址 protected $port = 9501; //监听9501端口 protected $serverType = 'socket'; protected $option = [ 'worker_num' => 4, //设置启动的Worker进程数 'daemonize' => false, //守护进程化（上线改为true） 'backlog' => 128, //Listen队列长度 'dispatch_mode' => 2, //固定模式，保证同一个连接发来的数据只会被同一个worker处理 //心跳检测：每60秒遍历所有连接，强制关闭10分钟内没有向服务器发送任何数据的连接 'heartbeat_check_interval' => 60, 'heartbeat_idle_time' => 600 ]; private $messageHandler; /** * @title init 启动之前执行 */ protected function init() { parent::init(); } /** * @title onWorkerStart 此事件在Worker进程/Task进程启动时发生。这里创建的对象可以在进程生命周期内使用 */ public function onWorkerStart() { $this->messageHandler = new MessageHandler(); } /** * @title onOpen 建立连接时回调函数 * * @param $server * @param $req */ public function onOpen($server, $request) { echo "server: handshake success with fd{$request->fd}\n"; } /** * @title onMessage 接收数据时回调函数 * * @param $server * @param $frame */ public function onMessage($server, $frame) { // 重新执行 WorkerStart 不再需要在此命令重启 用户开发模式 $this->swoole->reload(); $data = json_decode($frame->data, true); $fd = $frame->fd; if (empty($data) && !is_object($data)) { //仅推送给当前连接用户 $server->push($fd, json_encode(['error' => 422, 'msg' => '参数错误'])); } if (method_exists($this->messageHandler, $data['act'])) { call_user_func([$this->messageHandler, $data['act']], $server, $frame); } } /** * @title onClose 连接关闭时回调函数 * * @param $server * @param $fd */ public function onClose($server, $fd) { echo "标识{$fd}关闭了连接\n"; } }messageHandler 为自定义处理逻辑namespace socket\Swoole\libs; class MessageHandler { public function single($server, $frame) { //仅推送给当前连接用户 $server->push($frame->fd, json_encode(['OK'])); } /** * @title group * * @param $server * @param $frame */ public function group($server, $frame) { //推送给全部连接用户 foreach ($server->connections as $fd) { $server->push($fd, json_encode([$fd . '===>OK'])); } } }客户端 websocket 自行处理 可以自行定义客户端认证等操作 自行定义 json 或 get 形式

使用nginx运行thinkphp的nginx配置 location / { index index.php; #如果文件不存在则尝试TP解析 if (!-e $request_filename) { rewrite ^(.*)$ /index.php?s=/$1 last; break; } } location ~ .+\.php($|/) { fastcgi_pass unix:/dev/shm/php-fcgi.sock; #fastcgi_pass 127.0.0.1:9000; fastcgi_index index.php; #设置PATH_INFO，注意fastcgi_split_path_info已经自动改写了fastcgi_script_name变量， #后面不需要再改写SCRIPT_FILENAME,SCRIPT_NAME环境变量，所以必须在加载fastcgi.conf之前设置 fastcgi_split_path_info ^(.+\.php)(/.*)$; fastcgi_param PATH_INFO $fastcgi_path_info; #加载Nginx默认"服务器环境变量"配置 include fastcgi.conf; }

ThinkPHP 5.1中容器(Container)和门面(Facade)的实现 tp5.1中引入了容器(Container)和门面(Facade)这两个新的类官方文档已经给出了定义：容器（Container）实现类的统一管理，确保对象实例的唯一性。门面（Facade）为容器（Container）中的类提供了一个静态调用接口，相比于传统的静态方法调用， 带来了更好的可测试性和扩展性，你可以为任何的非静态类库定义一个facade类。深入源码，我们来看看它到底是如何实现的：// 在框架目录下的base.php文件 // 注册核心类到容器 Container::getInstance()->bind([ 'app' => App::class, 'build' => Build::class, 'cache' => Cache::class, 'config' => Config::class, ... ]); // 注册核心类的静态代理 Facade::bind([ facade\App::class => App::class, facade\Build::class => Build::class, facade\Cache::class => Cache::class, facade\Config::class => Config::class, ... ]); // 注册类库别名 Loader::addClassAlias([ 'App' => facade\App::class, 'Build' => facade\Build::class, 'Cache' => facade\Cache::class, 'Config' => facade\Config::class, ... ]);容器实现：这里，框架已经帮我们绑定了系统常用类到容器中，在之后使用时，只需要调用助手函数 app()进行容器中的类解析调用，对于已经绑定的类标识，会自动快速实例化。 // 实例化缓存类 app('cache'); // app('cache', ['file']); 参数化调用 // 相当于执行了 Container::get('cache'); // 查看源码，Container调用的其实是make方法，在该方法里调用反射等实现类的实例化，过程如下： public function make($abstract, $vars = [], $newInstance = false) { if (true === $vars) { // 总是创建新的实例化对象 $newInstance = true; $vars = []; } if (isset($this->instances[$abstract]) && !$newInstance) { $object = $this->instances[$abstract]; } else { if (isset($this->bind[$abstract])) { $concrete = $this->bind[$abstract]; 　　　　　　　// 闭包实现 if ($concrete instanceof \Closure) { $object = $this->invokeFunction($concrete, $vars); } else { $object = $this->make($concrete, $vars, $newInstance); } } else { 　　　　　　　// 反射实现 $object = $this->invokeClass($abstract, $vars); } if (!$newInstance) { $this->instances[$abstract] = $object; } } return $object; } /** * 调用反射执行类的实例化 支持依赖注入 * @access public * @param string $class 类名 * @param array $vars 变量 * @return mixed */ public function invokeClass($class, $vars = []) { $reflect = new \ReflectionClass($class); $constructor = $reflect->getConstructor(); if ($constructor) { $args = $this->bindParams($constructor, $vars); } else { $args = []; } return $reflect->newInstanceArgs($args); } /** * 执行函数或者闭包方法 支持参数调用 * @access public * @param string|array|\Closure $function 函数或者闭包 * @param array $vars 变量 * @return mixed */ public function invokeFunction($function, $vars = []) { $reflect = new \ReflectionFunction($function); $args = $this->bindParams($reflect, $vars); return $reflect->invokeArgs($args); }简而言之，容器内部是通过反射类或闭包等来实现类的实例化。门面实现：以一个例子来分析： facade\Config::get('app_debug'); 我们来分析一下它的实现方式： // thinkphp\library\facade\Config 类 namespace think\facade; use think\Facade; class Config extends Facade { } // 从源代码上看 Config本身没有任何方法，它继承了Facade的方法，但Facade并没有get这个静态方法 // 此时，系统自动触发了魔术方法：__callStatic（）,Facade重写了此方法： public static function __callStatic($method, $params) { return call_user_func_array([static::createFacade(), $method], $params); } // 可见，最后调用的是用户自定义函数：call_user_func_array([实例, 方法], 参数)，为了获得Config实例，Facade又定义了一个获取对象的方法： /** * 创建Facade实例 * @static * @access protected * @param string $class 类名或标识 * @param array $args 变量 * @param bool $newInstance 是否每次创建新的实例 * @return object */ protected static function createFacade($class = '', $args = [], $newInstance = false) { $class = $class ?: static::class; $facadeClass = static::getFacadeClass(); if ($facadeClass) { $class = $facadeClass; } elseif (isset(self::$bind[$class])) { $class = self::$bind[$class]; } if (static::$alwaysNewInstance) { $newInstance = true; } return Container::getInstance()->make($class, $args, $newInstance); } // 其内部是通过容器来实例化对象 // 因为在base.php中已经将 think\Config 类绑定到 config 这个标识 Container::getInstance()->bind([ 　　'config' => Config::class ]) // 在 createFacade 方法中，获取类的名称：$class = $class ?: static::class; 即得到 config 这个标识 // 在容器的make方法中，根据config标识，找到绑定的 think\Config 类，并调用其动态方法 get。 facade\Config::get('app_debug'); // 最后调用的是： (new think\Config())->get('app_debug');简而言之，门面的实现是通过PHP的魔术方法 __callStatic，再配合容器来实现动态类的静态化调用。

ThinkPHP5 tablib标签库自定义 本文实例讲述了thinkPHP5 tablib标签库自定义方法。分享给大家供大家参考，具体如下：官方文档的标签库使用教程没有写得太细，自己摸索出来了一些。1 、在common（我是在common，你自己看，反正是用命名空间载入）里新建目录taglib2、在taglib里新建Tag.php 继承think的Tglib，代码如下：<?php namespace app\common\taglib; use think\template\TagLib; class Tag extends TagLib { /** * 定义标签列表 */ protected $tags = [ // 标签定义： attr 属性列表 close 是否闭合（0 或者1 默认1） alias 标签别名 level 嵌套层次 'links' => ['attr' => '', 'close' => 1],//友情链接 item,key 可传可不传 也可另加参数 ]; /** * 获取友情链接列表 * @param $tag * @param $content * @return string */ public function tagLinks($tag, $content) { $item = !empty($tag['item']) ? $tag['item'] : 'item'; $key = !empty($tag['key']) ? $tag['key'] : 'key'; $parse = <<<EOF <?php \$__LIST__ = app\cms\model\Link::getList(); //model你就随意发挥了 foreach(\$__LIST__ as \$$key =>\$$item): ?> EOF; $parse .= $content; $parse .= '<?php endforeach; ?>'; return $parse; } }3、不要忘记配置文件中设置 标签库预加载 'taglib_pre_load' => 'app\common\taglib\tag'使用实例： {tag:links } <li><a href="#">{$item.title}</a></li> {/tag:links}另外还有简化写法：配置文件中：'taglib_build_in' => 'cx,tag'标签库定义为内置标签库（前提是多个标签库没有标签冲突的情况下）使用方法：{links } <li><a href="#">{$item.title}</a></li> {/links}4、TP5.1中手册未完善，此部分看查看5.0 手册或者3.2手册另外建议多研究下 内置标签库Cx标签库。

ThinkPHP5 使用 QueryList4 教程 TP5中如何使用QueryList4,所以写了这篇教程。说实话我并不太想写这篇教程，因为实在是没有什么技术含量。安装步骤下载TP5去ThinkPHP官网下载最新的ThinkPHP5框架代码： http://www.thinkphp.cn安装QueryList在ThinkPHP5代码根目录执行composer命令安装QueryList:composer require jaeger/querylist使用QueryList下面演示在Index控制器中使用QueryList:<?php namespace app\index\controller; use QL\QueryList; class Index { public function index() { //采集某页面所有的图片 $data = QueryList::get('http://cms.querylist.cc/bizhi/453.html')->find('img')->attrs('src'); //打印结果 print_r($data->all()); } }就这样就好了。注意点PHP >= 7.0 PHP7以下环境无法安装和使用QueryList4！ PHP7以下环境无法安装和使用QueryList4！ PHP7以下环境无法安装和使用QueryList4！