一、安装swoole

 1.宝塔环境下直接安装相对应的PHP版本扩展

开放9501端口号

 

 3.如阿里等云服务器还要设置安全规则。放行9501

至此，宝塔上安装swoole就完成了！

二、测试swoole

 1.在要测试的网站目录中创建文件名为sw_server.php

set([    'worker_num' => 1,    'daemonize' => false,  // 守护进程,开启后，关闭SSH面也可进行    'log_file' => 'swoole_task.log',    'task_worker_num' => 200       // task进程数量]);// 主进程启动时回调函数$server->on('start', function ($server) {    echo "服务端启动:" . date("Y-m-d H:i:s") . PHP_EOL;});// 收到信息时执行$server->on('receive', function ($server, $fd, $reactor_id, $data) {    $data = json_decode($data, true);        #echo "收到数据" . $data['access_token'];  //这里根据要求拼接要传给微信接口的参数info                $info = [            'touser' => $touser,            'template_id'=>$blog['tempID'],'data'=>$datadetail,'url'=>$blog['linkurl']        ];        $info = json_encode($info);        echo "数据值：" . $info;                    $url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" . $data['access_token'];        // 投递异步任务        $server->task([            'url' => $url,            'info' => $info,            'id' => $id,            'lid' => $lid                    ]);        // 记录到文件        echo "服务端执行时间:" . date("Y-m-d H:i:s") . PHP_EOL;        swoolelogs(date('Y-m-d H:i:s') . " [{$value}]\r\n");    }}    }});// 处理异步任务$server->on('task', function ($server, $task_id, $reactor_id, $data) {    echo "开始处理异步";    $res = httpRequest($data['url'], $data['info']);    if ($res) {      //异步返回开始处理数据库更新        try {            // 推送成功条数               $pdo = new PDO('mysql:host=localhost;dbname=数据库名称', '用户名', '密码');            $res = $pdo->exec('UPDATE `templist` SET `totalnum`=`totalnum`+1 WHERE `id` = ' . $data['lid']);        } catch (Exception $e) {            $pdo->rollBack();            echo "Failed: " . $e->getMessage();        }    }    echo $res . PHP_EOL;    $server->finish('请求回调方法');});// 异步任务完成通知回调$server->on('finish', function ($server, $task_id, $data) {    echo "完成回调" . date("Y-m-d H:i:s") . ':' . $data;});// 建立连接$server->on('connect', function ($server, $fd, $reactor_id) {    echo "客户端连接成功:" . date("Y-m-d H:i:s") . PHP_EOL;});// 关闭连时回调函数$server->on('close', function ($server, $fd, $reactor_id) {    echo "客户端关闭连接:" . date("Y-m-d H:i:s") . PHP_EOL;});$server->start();function httpRequest($url, $data){    $options = array(        'http' => array(            'method' => 'POST',            'header' => 'Content-type:application/x-www-form-urlencoded',            'content' => $data,            // 'protocol_version' => 1.1,            // 'header' => [            // 'Connection: close',            // ],            'timeout' => 2 // 超时时间(单位:s)        )    );    $context = stream_context_create($options);    $result = file_get_contents($url, false, $context);    return $result;}function swoolelogs($str){    // 记录到文件    if (($fp = fopen(__DIR__ . '/swoole_task_logs.txt', 'a+')) !== false) {        fputs($fp, $str);        fclose($fp);    }}

同样创建文件名为client.php

connect('127.0.0.1', 9501,3)) {    exit("connect failed. Error: {$client->errCode}\n");}    // 传递参数，这里获取缓存好的access_token     $accessToken = $sdk->getAccessToken();        $sendData = [        'access_token' => $accessToken,        'data' => '123',        'id' => $id    ];//给服务器发送数据==可以发送函数if (!$client->send(json_encode($sendData))){    die("send failed.");}//从服务器接收数据$data = $client->recv();if (!$data){    die("recv failed.");}echo $data;//关闭连接$client->close();

三、运行中问题

在服务端运行sw_server.php

        进宝塔终端，进相应的网站目录如cd /www/wwwroot/test.co

m

        运行  php sw_server.php

        

        表示正常启动成功。

        如果安装了扩展发现启动失败查看PHP版本是否选择正确

         

 2.在网页端运行client.php，服务器端会自动调异步命步

如果提示服务已启动，查找到对应服务

ps -ef | grep sw_server.php

然后再杀掉相应进程

kill 2723425   //这个为占用的进程

来源地址：https://blog.csdn.net/xu303wei/article/details/126947544