网站开发过程和里程碑,深圳网站设计 建设首选深圳市,点蜜免费空间上传网站,腾讯企点怎么注销前言 PHP本身并不直接支持多线程编程#xff0c;因为PHP的设计初衷是作为一个脚本语言#xff0c;主要面向的是Web开发。不过我们可以使用一些扩展和库来实现多进程的功能#xff0c;提高系统性能#xff0c;比如workerman和swoole。通过多进程异步执行任务。
安装workman…前言 PHP本身并不直接支持多线程编程因为PHP的设计初衷是作为一个脚本语言主要面向的是Web开发。不过我们可以使用一些扩展和库来实现多进程的功能提高系统性能比如workerman和swoole。通过多进程异步执行任务。
安装workman 简介 官网高性能PHP应用容器 workerman 文档 workerman 手册 Workerman · ThinkPHP5.0完全开发手册 · 看云 (kancloud.cn) ThinkPHP 5.1 Workerman 快速上手指南 · ThinkPHP5.1 Workerman上手指南 · 看云 (kancloud.cn) 环境要求 PHP 7.2Composer 2.0 安装扩展 composer require topthink/think-workerThinkphp5.0使用workman创建多进程任务 1.在项目根目录注意不是pubcli目录下创建文件server.php文件内容如下 ?php
define(APP_PATH, __DIR__ . /application/);
define(BIND_MODULE,workman/Worker);
// 加载框架引导文件
require __DIR__ . /thinkphp/start.php;2.在根目录创建\application\workman\controller目录然后在该目录下新建Worker.php文件内容如下 ?phpnamespace app\workman\controller;use think\worker\Server;class Worker extends Server
{//websocket服务端地址和端口protected $socket websocket://0.0.0.0:2346;//设置进程数默认为4根据自己的需要和服务器配置合理设置一般设置进程数为CPU核数的1倍-3倍protected $processes 4;/*** 收到信息* param $connection* param $data*/public function onMessage($connection, $data){}/*** 当连接建立时触发的回调函数* param $connection*/public function onConnect($connection){}/*** 当连接断开时触发的回调函数* param $connection*/public function onClose($connection){}/*** 当客户端的连接上发生错误时触发* param $connection* param $code* param $msg*/public function onError($connection, $code, $msg){echo error $code $msg\n;}/*** 每个进程启动* param $worker*/public function onWorkerStart($worker){echo workman进程启动,进程id . $worker-id . PHP_EOL;//监听redis队列$redis new \Redis();$redis-connect(192.168.204.128, 6379);while (true) {//读取redis队列$data $redis-lPop(test-queue);if ($data) {//处理业务echo 进程id . $worker-id . 开始处理业务数据 . $data . PHP_EOL;//模拟耗时任务sleep(5);echo 进程id . $worker-id . 处理业务数据 . $data . 完成 . PHP_EOL;} else {echo 进程id . $worker-id . 空闲中休息5秒. PHP_EOL;sleep(5);}}}
}这里主要的功能就是创建一个workman的websocket服务端使用其他tcp服务也是可以的然后在每个进程启动的时候监听redis队列利用这些进程异步去处理redis队列里的任务代码里的模拟耗时任务可以直接替换成你在tp框架里写的耗时任务。 3.在tp框架中将任务加入redis队列例如我这里写一个添加redis列表元素的方法 ?phpnamespace app\index\controller;class Index
{//新增队列数据public function addQueue(){$redis new \Redis();$redis-connect(192.168.204.128, 6379);$redis-rPush(test-queue, 1);$redis-rPush(test-queue, 2);$redis-rPush(test-queue, 3);$redis-rPush(test-queue, 4);$redis-rPush(test-queue, 5);$redis-rPush(test-queue, 6);$redis-rPush(test-queue, 7);echo success;}
}4.启动workman 直接在根目录下运行第一步创建的server.php php server.php start可以看到下面的输出 Workerman[server.php] start in DEBUG mode
-------------------------------------------- WORKERMAN --------------------------------------------
Workerman version:3.5.35 PHP version:7.4.33 Event-Loop:\Workerman\Events\Select
--------------------------------------------- WORKERS ---------------------------------------------
proto user worker listen processes status
tcp root none websocket://0.0.0.0:2346 4 [OK]
---------------------------------------------------------------------------------------------------
Press CtrlC to stop. Start success.
workman进程启动,进程id 0
workman进程启动,进程id 3
workman进程启动,进程id 2
workman进程启动,进程id 1
进程id 1 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 2 空闲中休息5秒
进程id 3 空闲中休息5秒注意如果是在windows下设置进程数是没有用的就只会启动一个worker进程也就是只有单进程要体验多进程只能在Linux环境下同时也无法守护进程cmd窗口关掉后服务即停止 5.访问tp框架中的将任务加入redis队列接口直接用浏览器或者命令行curl访问http://网站域名/index/index/addQueue即可然后你就可以看到所有的redis队列将被workman进程分配并执行以下是我启动workman-添加redis队列-workman处理-队列处理结束打印的结果 Workerman[server.php] start in DEBUG mode
-------------------------------------------- WORKERMAN --------------------------------------------
Workerman version:3.5.35 PHP version:7.4.33 Event-Loop:\Workerman\Events\Select
--------------------------------------------- WORKERS ---------------------------------------------
proto user worker listen processes status
tcp root none websocket://0.0.0.0:2346 4 [OK]
---------------------------------------------------------------------------------------------------
Press CtrlC to stop. Start success.
workman进程启动,进程id 0
workman进程启动,进程id 3
workman进程启动,进程id 2
workman进程启动,进程id 1
进程id 1 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 2 空闲中休息5秒
进程id 3 空闲中休息5秒
进程id 2 空闲中休息5秒
进程id 1 空闲中休息5秒
进程id 3 空闲中休息5秒
进程id 0 空闲中休息5秒
这里开始将任务加入redis队列然后workman开始消费队列
进程id 0 开始处理业务数据1
进程id 1 开始处理业务数据3
进程id 3 开始处理业务数据4
进程id 2 开始处理业务数据2
进程id 0 处理业务数据1 完成
进程id 1 处理业务数据3 完成
进程id 2 处理业务数据2 完成
进程id 1 开始处理业务数据6
进程id 3 处理业务数据4 完成
进程id 0 开始处理业务数据5
进程id 3 开始处理业务数据7
进程id 2 空闲中休息5秒
进程id 1 处理业务数据6 完成
进程id 0 处理业务数据5 完成
进程id 3 处理业务数据7 完成
到这里所有的7项任务已经处理完成
进程id 1 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 3 空闲中休息5秒
进程id 2 空闲中休息5秒TP5.1及TP6使用workman创建多进程任务 1.在根目录创建\application\workman\controller目录然后在该目录下新建Worker.php文件内容如下 ?phpnamespace app\workman;use think\worker\Server;class Worker extends Server
{protected $host 127.0.0.1;protected $port 2346;protected $protocol websocket;protected $option [count 4, //设置进程数默认为4根据自己的需要和服务器配置合理设置一般设置进程数为CPU核数的1倍-3倍name think];/*** 收到信息* param $connection* param $data*/public function onMessage($connection, $data){}/*** 当连接建立时触发的回调函数* param $connection*/public function onConnect($connection){}/*** 当连接断开时触发的回调函数* param $connection*/public function onClose($connection){}/*** 当客户端的连接上发生错误时触发* param $connection* param $code* param $msg*/public function onError($connection, $code, $msg){echo error $code $msg\n;}/*** 每个进程启动* param $worker*/public function onWorkerStart($worker){echo workman进程启动,进程id . $worker-id . PHP_EOL;//监听redis队列$redis new \Redis();$redis-connect(127.0.0.1, 6379);while (true) {//读取redis队列$data $redis-lPop(test-queue);if ($data) {//处理业务echo 进程id . $worker-id . 开始处理业务数据 . $data . PHP_EOL;//模拟耗时任务sleep(5);echo 进程id . $worker-id . 处理业务数据 . $data . 完成 . PHP_EOL;} else {echo 进程id . $worker-id . 空闲中休息5秒 . PHP_EOL;sleep(5);}}}
}这里主要的功能就是创建一个workman的websocket服务端使用其他tcp服务也是可以的然后在每个进程启动的时候监听redis队列利用这些进程异步去处理redis队列里的任务代码里的模拟耗时任务可以直接替换成你在tp框架里写的耗时任务。 2.指定workman服务类名 修改config/worker_server.php将worker_class的值改为app\workman\Worker worker_class app\workman\Worker, // 自定义Workerman服务类名 支持数组定义多个服务3.启动workman 直接在根目录下运行命令php think worker:server或者php think worker:server -d即可启动如果要调整workman参数修改config/worker_server.php中的选项即可 php think worker:server可以看到下面的输出 Starting Workerman server...
----------------------- WORKERMAN -----------------------------
Workerman version:3.5.35 PHP version:7.3.4
------------------------ WORKERS -------------------------------
worker listen processes status
none websocket://127.0.0.1:2346 1 [ok]
workman进程启动,进程id 0
进程id 0 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 0 空闲中休息5秒
进程id 0 空闲中休息5秒注意如果是在windows下设置进程数是没有用的就只会启动一个worker进程也就是只有单进程要体验多进程只能在Linux环境下同时也无法守护进程cmd窗口关掉后服务即停止 4.在tp框架中将任务加入redis队列例如我这里写一个添加redis列表元素的方法 ?php
namespace app\controller;use app\BaseController;class Index extends BaseController
{//新增队列数据public function addQueue(){$redis new \Redis();$redis-connect(127.0.0.1, 6379);$redis-rPush(test-queue, 1);$redis-rPush(test-queue, 2);$redis-rPush(test-queue, 3);$redis-rPush(test-queue, 4);$redis-rPush(test-queue, 5);$redis-rPush(test-queue, 6);$redis-rPush(test-queue, 7);echo success;}
}5.访问上面的将任务加入redis队列接口直接用浏览器或者命令行curl访问http://网站域名/index/addQueue即可然后你就可以看到所有的redis队列将被workman进程分配并执行以下是我启动workman-添加redis队列-workman处理-队列处理结束打印的结果 Starting Workerman server...
Workerman[think] start in DEBUG mode
-------------------------------------------- WORKERMAN ---------------------------------------------
Workerman version:3.5.35 PHP version:7.4.33 Event-Loop:\Workerman\Events\Select
--------------------------------------------- WORKERS ----------------------------------------------
proto user worker listen processes status
tcp root think websocket://127.0.0.1:2346 4 [OK]
----------------------------------------------------------------------------------------------------
Press CtrlC to stop. Start success.
workman进程启动,进程id 0
workman进程启动,进程id 3
进程id 0 空闲中休息5秒
进程id 3 空闲中休息5秒
workman进程启动,进程id 1
进程id 1 空闲中休息5秒
workman进程启动,进程id 2
进程id 2 空闲中休息5秒
进程id 0 开始处理业务数据2
进程id 3 开始处理业务数据1
进程id 1 开始处理业务数据3
进程id 2 开始处理业务数据4
进程id 0 处理业务数据2 完成
进程id 0 开始处理业务数据5
进程id 3 处理业务数据1 完成
进程id 1 处理业务数据3 完成
进程id 3 开始处理业务数据6
进程id 1 开始处理业务数据7
进程id 2 处理业务数据4 完成
进程id 2 空闲中休息5秒
进程id 0 处理业务数据5 完成
进程id 1 处理业务数据7 完成
进程id 3 处理业务数据6 完成
进程id 0 空闲中休息5秒
进程id 1 空闲中休息5秒
进程id 3 空闲中休息5秒
进程id 2 空闲中休息5秒
