thinkphp 6.0 swoole扩展websocket使用教程(life)

谁践踏了优雅 2023-03-05 09:37 17阅读 0赞

ThinkPHP即将迎来最新版本6.0，针对目前越来越流行的Swoole，thinkphp也推出了最新的扩展think-swoole 3.0。

**介绍**

即将推出的tp6.0，已经适应了woole。并推出了think-swoole 3.0，并且已替换了socketio。和2.0版本在使用方法上有些许不同。

Websocket继承与Http，进行websocket连接之前需要一次HTTP请求，如果当期地址支持websocket则返回101，然后进行连接。并不是我的服务支持websocket后，请求每个连接地址都可以进行websocket连接，甚至需要预先适应才可以连接。

参数配置

'服务器'=> ['主机'=>'0.0.0.0'，//监听地址
 
 'port'=> 808，//监听端口
 
 'mode'=> SWOOLE_PROCESS，//运行模式默认为SWOOLE_PROCESS
 
 'sock_type'=> SWOOLE_SOCK_TCP，//袜子类型默认为SWOOLE_SOCK_TCP
 
 'options'=> ['pid_file'=> runtime_path（）。'swoole.pid'，'log_file'=> runtime_path（）。'swoole.log'，'daemonize'=> false，//通常，此值应根据您的cpu内核大1〜4倍。
 
 'reactor_num'=> swoole_cpu_num（），'worker_num'=> swoole_cpu_num（），'task_worker_num'=> 4，// swoole_cpu_num（），
 
 'enable_static_handler'=> true，'document_root'=> root_path（'public'），'package_max_length'=> 20 * 1024 * 1024，'buffer_output_size'=> 10 * 1024 * 1024，'socket_buffer_size'=> 128 * 1024 * 1024，'max_request'=> 3000，'send_yield'=> true，
 
 ]，
 
 ]，'websocket'=> ['已启用'=> true，//开启websocket
 
 'handler'=> Handler :: class，//自定义wbesocket绑定类
 
 'parser'=> Parser :: class，//自定义解析类
 
 'route_file'=> base_path（）。'websocket.php'，'ping_interval'=> 25000，'ping_timeout'=> 60000，'room'=> [''type'=> TableRoom :: class，'room_rows'=> 4096，'room_size'=> 2048， 'client_rows'=> 8192，'client_size'=> 2048，
 
 ]，
 
 ]，'auto_reload'=> true，'enable_coroutine'=> true，'resetters'=> []，'tables'=> []，

handler和parser大大方便了自定义websocket服务，交替系统集成了socketio。

本文主要介绍如何使用socketio，这里假设大家有socketio有一定了解和使用基础。

socketIo默认会在请求地址后加相应的参数

## [【社群福利】30G-PHP进阶资料，助力大家都能30K][30G-PHP_30K] ##

![format_png][]

同时，socketio至少在情况下，会认为http：//url/[http://socket.io/][http_socket.io]是支持websocket服务的地址。

![format_png 1][]

而在tp-swoole3.0内部已经该地址请求进行了处理

<？phpnamespace think \ swoole \ websocket \ socketio;使用think \ Config;使用think \ Cookie;使用think \ Request;类控制器{protected $ transports = ['polling'，'websocket']; 公共功能升级（请求$ request，配置$ config，Cookie $ cookie）
 
 {如果（！in_array（$ request-> param（'transport'），$ this-> transports））{返回json（
 
 ['code'=> 0，'message'=>'未知运输，
 
 ]，400
 
 ）;
 
 }如果（$ request-> has（'sid'））{
 
 $ response = response（'1：6'）;
 
 }其他{
 
 $ sid = base64_encode（uniqid（））;
 
 $ payload = json_encode（
 
 ['sid'=> $ sid，'upgrades'=> ['websocket']，'pingInterval'=> $ config-> get（'swoole.websocket.ping_interval'），'pingTimeout'=> $ config-> get （'swoole.websocket.ping_timeout'），
 
 ]
 
 ）;
 
 $ cookie-> set（'io'，$ sid）;
 
 $ response = response（'97：0'。$ payload。'2:40'）;
 
 }返回$ response-> contentType（'text / plain'）;
 
 } public function reject（请求$ request）
 
 {返回json（
 
 ['code'=> 3，'message'=>'错误请求'，
 
 ]，400
 
 ）;
 
 }
 
 }

TP6.0，插件注册采用了服务方式进行了注册，可在tp-swoole服务注册文件中查看路由注册信息，如果想自定义链接规则，则可以覆盖该路由。

<？php // + -------------------------------------------- -------------------------- // | ThinkPHP [我们可以考虑一下] // + ------------------------------------- --------------------------------- // | | 版权所有（c）2006-2018 http://thinkphp.cn保留所有权利.// + ----------------------------- ----------------------------------------- // | | 许可（http://www.apache.org/licenses/LICENSE-2.0）// + ----------------------------- ----------------------------------------- // | | 作者：yunwuxin <448901948@qq.com> // + ------------------------------------- ---------------------------------命名空间think \ swoole;将Swoole \ Http \ Server用作HttpServer;使用Swoole \ Websocket \ Server作为WebsocketServer;使用think \ App;使用think \ Route;使用think \ swoole \ command \ Server作为ServerCommand;使用think \ swoole \ facade \ Server;使用think \ swoole \ websocket \ socketio \ Controller; 使用think \ swoole \ websocket \ socketio \ Middleware;类服务扩展\ think \ Service {受保护的$ isWebsocket = false; / **
 
 * @var HttpServer | WebsocketServer
 
 * /
 
 受保护的静态$ server; 公共功能寄存器（）
 
 {$ this-> isWebsocket = $ this-> app-> config-> get（'swoole.websocket.enabled'，false）; $ this-> app-> bind（Server :: class，function（）{if（is_null（static :: $ server））{$ this-> createSwooleServer（）;
 
 }返回static :: $ server;
 
 }）; $ this-> app-> bind（'swoole.server'，Server :: class）; $ this-> app-> bind（Swoole :: class，function（App $ app）{返回新的Swoole（$ app）;
 
 }）; $ this-> app-> bind（'swoole'，Swoole :: class）;
 
 }公共功能启动（Route $ route）
 
 {$ this-> commands（ServerCommand :: class）; 如果（$ this-> isWebsocket）{
 
 $ route-> group（function（）use（$ route）{
 
 $ route-> get（'socket.io/'，'@upgrade'）;
 
 $ route-> post（'socket.io/'，'@reject'）;
 
 }）->前缀（Controller :: class）->中间件（Middleware :: class）;
 
 }
 
 } / **
 
 *创建Swoole服务器。
 
 * /
 
 受保护的函数createSwooleServer（）
 
 {
 
 $ server = $ this-> isWebsocket吗？WebsocketServer :: class：HttpServer :: class;
 
 $ config = $ this-> app-> config;
 
 $ host = $ config-> get（'swoole.server.host'）;
 
 $ port = $ config-> get（'swoole.server.port'）;
 
 $ socketType = $ config-> get（'swoole.server.socket_type'，SWOOLE_SOCK_TCP）;
 
 $ mode = $ config-> get（'swoole.server.mode'，SWOOLE_PROCESS）; static :: $ server = new $ server（$ host，$ port，$ mode，$ socketType）;
 
 $ options = $ config-> get（'swoole.server.options'）; static :: $ server-> set（$ options）;
 
 }
 
 }

套接字使用演示

<！DOCTYPE html> <html lang =“ zh-CN”> <head>
 
 <meta charset =“ UTF-8”>
 
 <title>标题</ title>
 
 <script src =“ ./ static / js / socket.io.js”> </ script> </ head> <body> <script>
 
 const socket = io（'http：// localhost：808'）;
 
 socket.emit（“ test”，“您的消息”）;
 
 socket.on（“ test”，function（res）{console.log（res）}）; </ script> </ body> </ html>

Websocket路由配置方法

在app目录下新建websocket.php文件，其中需要注意，由于使用了反射，闭包参数名称不能随意定义，不然无法注入。第一个参数是websocket，是当前websocket的服务器对象，第二个参数data是客户端发送的数据。其中，socketio发出的第一个参数和Websocket :: on的第一个参数一致，作为事件名称。

<？php / **
 
 *作者：Xavier Yang
 
 *日期：2019/6/5
 
 *电子邮件：499873958@qq.com
 
 * /使用\ think \ swoole \ facade \ Websocket;
 
 Websocket :: on（“ test”，function（\ think \ swoole \ Websocket $ websocket，$ data）{// var_dump（$ class）;
 
 $ websocket-> emit（“ test”，“ asd”）;
 
 }）;
 
 Websocket :: on（“ test1”，函数（$ websocket，$ data）{
 
 $ websocket-> emit（“ test”，“ asd”）;
 
 }）;
 
 Websocket :: on（“ join”，function（\ think \ swoole \ Websocket $ websocket，$ data）{
 
 $ websocket-> join（“ 1”）;
 
 }）;

![format_png 2][]

tp-swoole3.0同时还有许多其他的新功能，这些功能需要大家去摸索尝试。

我也会在接下来的文章中，一起与大家分享我的使用过程。

**以上内容希望帮助到大家，**很多PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提升，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家**，需要的可以加入**我的官方群[点击此处][Link 1]。

[30G-PHP_30K]: https://zhuanlan.zhihu.com/p/161960302
[format_png]: /images/20230208/1af7cb18a26645b6a69c1762febf3daf.png
[http_socket.io]: https://link.zhihu.com/?target=http%3A//socket.io/
[format_png 1]: /images/20230208/7c1aa47bf88345b7ba6df87b0e1fff4f.png
[format_png 2]: /images/20230208/937cea1cc77d4d4d8b7111cf93eb9c22.png
[Link 1]: https://link.zhihu.com/?target=https%3A//jq.qq.com/%3F_wv%3D1027%26k%3DJNZRtm7R