首页 > 美文阅读

thinkphp6.0swoole扩展websocket使用教程（life）

更新时间:2023-05-22 01:53:51 阅读：评论：0

thinkphp6.0swoole扩展websocket使⽤教程（life）

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'，//监听地址

'mode'=> SWOOLE_PROCESS，//运⾏模式默认为SWOOLE_PROCESS'swoole.pid'，'log_file'=> runtime_path（）。

]，'websocket'=> ['已启⽤'=> true，//开启websocket

'handler'=> Handler :: class，//⾃定义wbesocket绑定类鸡蛋炸酱面的做法

'parr'=> Parr :: class，//⾃定义解析类

'route_file'=> ba_path（）。'websocket.php'，'ping_interval'=> 25000，'ping_timeout'=> 60000，'room'=> [''typ ]，

]，'auto_reload'=> true，'enable_coroutine'=> true，'retters'=> []，'tables'=> []，

handler和parr⼤⼤⽅便了⾃定义websocket服务，交替系统集成了socketio。

阴符七术

本⽂主要介绍如何使⽤socketio，这⾥假设⼤家有socketio有⼀定了解和使⽤基础。

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

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

<？phpnamespace think \ swoole \ websocket \ socketio；使⽤think \ Config；使⽤think \ Cook {如果（！in_array（$ request-> param（'transport'），$ this-> transports））{返回json（ 0，'message'=>'未知运输，

]，400

）;

}如果（$ request-> has（'sid'））{

$ respon = respon（'1：6'）;

}其他{

$ sid = ba64_encode（uniqid（））;

$ payload = json_encode（

['sid'=> $ sid，'upgrades'=> ['websocket']，'pingInterval'=> $ config-> get（'swoole.websocket.ping_interval'），'pingTimeout'=> $ config-> get （'swoo ]

）;<font

$ cookie-> t（'io'，$ sid）;

$ respon = respon（'97：0'。$ payload。'2:40'）; }返回$ respon-> contentType（'text / plain'）;

} public function reject（请求$ request）

{返回json（

['code'=> 3，'message'=>'错误请求'，

宝宝积食的症状]，400<font style="vertical-align: inhe

rit;">

）;

}

}

TP6.0，插件注册采⽤了服务⽅式进⾏了注册，可在tp-swoole服务注册⽂件中查看路由注册信息，如果想⾃定义链接规则，则可以覆盖该

路由。

<？php // + -------------------------------------------- -------------------------- // | WebsocketServer

受保护的静态$ rver; 公共功能寄存器（） isWebsocket = $ this-> app-> config-> get（'abled'，fal）; $ this-> app-> bind（Serv }返回static :: $ rver;

}）; $ this-> app-> bind（'swoole.rver'，Server :: class）; $ this-> app }）; $ this-> app-> bind（'swoole'，Swoole :: class）;其实我爱你

{$ this-> commands（ServerCommand :: class）; 如果（$ this-> isWebsocket）{ group（function（）u（$ route）{

$ route-> get（'socket.io/'，'@upgrade'）;

$ route-> post（'socket.io/'，'@reject'）;

}）->前缀（Controller :: class）->中间件（Middleware :: class）;

} / **

*创建Swoole服务器。

* /

外婆的歌受保护的函数createSwooleServer（）

{

$ rver = $ this-> isWebsocket吗？WebsocketServer :: class：HttpServer :: class;<fon $ config = $ this-> app-> config;

$ host = $ config-> get（'swoole.rver.host'）;

$ port = $ config-> get（'swoole.rver.port'）;

$ socketType = $ config-> get（'swoole.rver.socket_type'，SWOOLE_SOCK_TCP）; get（'de'，SWOOLE_PROCESS）; static :: $ rver = new $ rver（$ hos $ options = $ config-> get（'swoole.rver.options'）; static :: $ rver-> t（$ options）;</fo }

}

套接字使⽤演⽰

<！DOCTYPE html> <html lang =“ zh-CN”> <head>

爵位

<（“ test”，function（res）{console.log（res）}）; </ script> </ body> </ html>

Websocket路由配置⽅法

在app⽬录下新建websocket.php⽂件，其中需要注意，由于使⽤了反射，闭包参数名称不能随意定义，不然⽆法注⼊。第⼀个参数是websocket，是当前websocket的服务器对象，第⼆个参数data是客户端发送的数据。其中，socketio发出的第⼀个参数和Websocket ::

on的第⼀个参数⼀致，作为事件名称。

<？php / **

*⽇期：2019/6/5

武则天后的皇帝*电⼦邮件：

* /使⽤\ think \ swoole \ facade \ Websocket;

Websocket :: on（“ test”，function（\ think \ swoole \ Websocket $ websocket，$ data）{// var_dum

p（$ class）;

}）;

Websocket :: on（“ test1”，函数（$ websocket，$ data）{

$ websocket-> emit（“ test”，“ asd”）;

}）;

Websocket :: on（“ join”，function（\ think \ swoole \ Websocket $ websocket，$ data）{ join（“ 1”）;

}）;

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

我也会在接下来的⽂章中，⼀起与⼤家分享我的使⽤过程。

以上内容希望帮助到⼤家，很多PHPer在进阶的时候总会遇到⼀些问题和瓶颈，业务代码写多了没有⽅向感，不知道该从那⾥⼊⼿去提升，对此我整理了⼀些资料，包括但不限于：分布式架构、⾼可扩展、⾼性能、⾼并发、服务器性能调优、

TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点⾼级进阶⼲货需要的可以免费分享给⼤家，需要的可以加⼊我的官⽅群。列夫托尔斯泰

本文发布于:2023-05-22 01:53:51，感谢您对本站的认可！

本文链接：https://www.wtabcd.cn/fanwen/fan/82/726458.html

上一篇：2023年金字塔的原理读后感金字塔原理第一篇读后感(6篇)

下一篇：关羽失荆州的歇后语及答案

标签：需要定义请求参数地址注册功能

留言与评论（共有 0 条评论）