Think-Swoole之WebSocket事件訂閱的示例

小編給大家分享一下Think-Swoole之WebSocket事件訂閱的示例，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

通過前面的實例中，如果按照之前的事件監(jiān)聽方式，客戶端的每個場景事件，服務端都需要創(chuàng)建每個對應的事件，如果事件太多， app/listener 目錄下將會有很多的文件（其實也不算什么壞現(xiàn)象），事件訂閱就是為了解決這一問題，把所有的事件都寫在一個文件中。

下面用事件訂閱的方式處理事件

首先需要把之前在 app/event.php 監(jiān)聽的事件給注釋掉，然后創(chuàng)建一個監(jiān)聽事件：php think make:listener SubTest 。

然后在 config/swoole.php 配置中的 websocket => subscribe 配置剛創(chuàng)建的監(jiān)聽文件：

'websocket'  => [
        .
        .
        .
        'listen'        => [],
        'subscribe'     => [
           \app\listener\SubTest::class
        ],
],

在 app/listener/SubTest.php 中定義需要監(jiān)聽的事件：

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

監(jiān)聽事件的方法命名規(guī)范：on+事件場景標識（駝峰命名）

用之前的前端頁面進行測試，一切正常。

以上是“Think-Swoole之WebSocket事件訂閱的示例”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業(yè)資訊頻道！