Thinkphp6+swoole教程（九）WebSocket事件订阅

转载请注明&＃xff1a; 藏羚骸的博客~Thinkphp6&＃43;swoole 教程&＃xff08;九&＃xff09;WebSocket 事件订阅.

通过前面的实例中&＃xff0c;如果按照之前的事件监听方式&＃xff0c;客户端的每个场景事件&＃xff0c;服务端都需要创建每个对应的事件&＃xff0c;如果事件太多&＃xff0c; app/listener 目录下将会有很多的文件&＃xff08;其实也不算什么坏现象&＃xff09;&＃xff0c;事件订阅就是为了解决这一问题&＃xff0c;把所有的事件都写在一个文件中。下面用事件订阅的方式处理事件

首先需要把之前在 app/event.php 监听的事件给注释掉&＃xff0c;然后创建一个监听事件&＃xff1a;php think make:listener SubTest 。

然后在 config/swoole.php 配置中的 websocket &＃61;> subscribe 配置刚创建的监听文件&＃xff1a;


.
.
.
&＃39;websocket&＃39; &＃61;> [...&＃39;listen&＃39; &＃61;> [],&＃39;subscribe&＃39; &＃61;> [\app\listener\SubTest::class],
],
.
.
.

在 app/listener/SubTest.php 中定义需要监听的事件&＃xff1a;

declare (strict_types &＃61; 1);namespace app\listener;class SubTest
{protected $websocket &＃61; null;public function __construct(){$this -> websocket &＃61; app(&＃39;\think\swoole\Websocket&＃39;);}//连接事件public function onConnect(){$this -> websocket -> emit(&＃39;sendfd&＃39;,$this -> websocket -> getSender());}//加入房间public function onJoin($event){$this -> websocket -> join($event[&＃39;room&＃39;]);$this -> websocket -> emit(&＃39;joincallback&＃39;,&＃39;加入房间成功&＃39;);}public function onRoomTest($event){$this -> websocket -> to($event[&＃39;room&＃39;]) -> emit(&＃39;roomtestcallback&＃39;,$event[&＃39;message&＃39;]);}
}

监听事件的方法命名规范&＃xff1a;on&＃43;事件场景标识&＃xff08;驼峰命名&＃xff09;

用之前的前端页面进行测试&＃xff0c;一切正常。

转载请注明&＃xff1a; 藏羚骸的博客~Thinkphp6&＃43;swoole 教程&＃xff08;九&＃xff09;WebSocket 事件订阅.