WebSocket之GatewayWorker使用說明

WilsonLiu95 發(fā)布于2019-07-01 14:21 / 2911人閱讀

摘要：無法接收客戶端發(fā)來的數(shù)據(jù)。如果和在同一臺服務器上運行，則不用做任何更改，直接按照示例使用即可。

首發(fā)于個人博客 https://www.axie.cc/article/51

參考文檔：

http://www.workerman.net/gate...

1.下載：

界面如下圖：

根據(jù)自己的運行環(huán)境下載相應的版本：兩者除了啟動方式不一樣，其它文件都一樣

windows版本啟動方式：運行下載下來的GatewayWorker-for-winstart_for_win.bat批處理文件

Linux版本啟動方式：運行GatewayWorkerstart.php文件， // 全局啟動腳本，此腳本會依次加載Applications/項目/start_*.php啟動腳本

2.目錄結(jié)構(gòu)：

├── Applications // 這里是所有開發(fā)者應用項目
│   └── YourApp  // 其中一個項目目錄，目錄名可以自定義
│       ├── Events.php // 開發(fā)者只需要關(guān)注這個文件
│       ├── start_gateway.php // gateway進程啟動腳本，包括端口號等設置
│       ├── start_businessworker.php // businessWorker進程啟動腳本
│       └── start_register.php // 注冊服務啟動腳本
│
├── start.php // 全局啟動腳本，此腳本會依次加載Applications/項目/start_*.php啟動腳本
│
└── vendor    // GatewayWorker框架和Workerman框架源碼目錄，此目錄開發(fā)者不用關(guān)心

提示：
1.客戶端的事件及數(shù)據(jù)全部由Gateway轉(zhuǎn)發(fā)給BusinessWorker處理，BusinessWorker默認調(diào)用Events.php中的onConnect onMessage onClose處理業(yè)務邏輯。
本地連接，類似邏輯代碼:




    
    
    溝通中

2.通過GatewayClient發(fā)送的數(shù)據(jù)不會經(jīng)過Event.php，而是直接經(jīng)由Gateway進程轉(zhuǎn)發(fā)給客戶端。GatewayClient無法接收客戶端發(fā)來的數(shù)據(jù)。
示例代碼：

Gateway::$registerAddress = "127.0.0.1:1238";
$message = [
            "type" => 4002,
            "clientId" => $clientId,
            "publish_time" => date("Y-m-d h:i:s", time())
        ];
Gateway::bindUid($clientId,$uid);
//在這里發(fā)送的信息是不走Event.php文件的，直接廣播出去了
Gateway::sendToClient($clientId,json_encode($message));

如果GatewayClient和GatewayWorker不是在同一臺服務器上，則需要先將start_gateway.php中的lanIp改成當前服務器的內(nèi)網(wǎng)ip（如果不在一個內(nèi)網(wǎng)可改成公網(wǎng)ip）。
如果GatewayClient和GatewayWorker在同一臺服務器上運行，則不用做任何更改，直接按照示例使用GatewayClient即可。

3.運行測試：

1.運行g(shù)ateway.php
2.start_gateway.php文件，這個文件是默認的文件，默認協(xié)議是text協(xié)議：

// gateway 進程，這里使用Text協(xié)議，可以用telnet測試
$gateway = new Gateway("Text://0.0.0.0:8282");
//想用js連接情況下：
$gateway = new Gateway("ws://0.0.0.0:8282");

3.本地測試text協(xié)議是否正常命令，cmd運行：

telnet 127.0.0.1 8282

界面顯示：

4.重新打開一個窗口：window測試結(jié)果：

5.Linux 測試結(jié)構(gòu)：

6.測試成功！

開始實戰(zhàn)：

我們只要對這四個文件進行了解：

├── Applications // 這里是所有開發(fā)者應用項目
│   └── YourApp  // 其中一個項目目錄，目錄名可以自定義
│       ├── Events.php // 開發(fā)者只需要關(guān)注這個文件
│       ├── start_gateway.php // gateway進程啟動腳本，包括端口號等設置
│       ├── start_businessworker.php // businessWorker進程啟動腳本
│       └── start_register.php // 注冊服務啟動腳本

1.修改start_gateway.php文件的這句配置，換成自己喜歡的協(xié)議與接口

// gateway 進程，這里使用Text協(xié)議，可以用telnet測試
$gateway = new Gateway("Websocket://0.0.0.0:7272");

2.修改Events.php 響應數(shù)據(jù)

//部分代碼
class Events
{
    static  $num = 0;

    /**
     * 當客戶端連接時觸發(fā)的事件。
     * @param $client_id
     */
    public static function onConnect($client_id)
    {
        global $num;
        Gateway::sendToClient($client_id, json_encode(array(
            "type"      => "init",
            "msg" => $client_id
        )));

    }

   /**
    * 有消息時
    * @param int $client_id
    * @param mixed $message
    */
   public static function onMessage($client_id, $message)
   {
       // 客戶端傳遞的是json數(shù)據(jù)
       $message_data = json_decode($message, true);
       if(!$message_data)
        {
           return ;
        }
       switch($message_data["type"]){
           case "bind":
               $fromid = $message_data["fromid"];
               Gateway::bindUid($client_id, $fromid);
               Gateway::sendToUid($message_data["fromid"],json_encode(["type"=>"bind","msg"=>"綁定成功"])); //返回給發(fā)送者
               return;
        }
        //其它case 情況
    }
    /**
    * 當用戶斷開連接時觸發(fā)
    * @param int $client_id 連接id
    */
   public static function onClose($client_id)
   {
       // 向所有人發(fā)送 
       GateWay::sendToAll("$client_id logout
");
   }
}

3. 在html中調(diào)用，觀察console的數(shù)據(jù)




    
    
    溝通中

注意：注冊端口
文件：ApplicationsYourAppstart_register.php ApplicationsYourAppstart_gateway.php ApplicationsYourAppstart_businessworker.php
中的注冊地址要一樣

//start_register.php
// 服務注冊地址
$gateway->registerAddress = "127.0.0.1:1238";

//start_businessworker.php
// 服務注冊地址
$worker->registerAddress = "127.0.0.1:1238";

//start_register.php
// register 必須是text協(xié)議
$register = new Register("text://0.0.0.0:1238");

云服務器 GPU云服務器源碼中文說明之 GatewayWorker 云服務器多人獨之使用 WebSocket

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/31991.html

發(fā)表評論

登陸后可評論

0條評論

WilsonLiu95

男|高級講師

我要關(guān)注我要私信

TA的文章

tensorflow

閱讀 3360·2023-04-26 01:40
實現(xiàn)初階掃雷

閱讀 3062·2021-11-24 09:39
#萬圣節(jié)#friendhosting，9個數(shù)據(jù)中心的VPS 5折促銷，可自定義ISO，不限流量，支持

閱讀 1350·2021-10-27 14:19
90后的軟件測試工程師，現(xiàn)在都怎樣了？

閱讀 2623·2021-10-12 10:11
無線測溫傳感器、無線測溫裝置在項目上的應用—安科瑞孫斌

閱讀 1282·2021-09-26 09:47
云主機怎么裝網(wǎng)站-怎么在云主機上搭建網(wǎng)站？

閱讀 1823·2021-09-22 15:21
cubemx配置stm32(三)__GPIO的輸入輸出

閱讀 2622·2021-09-06 15:00
ShineServers：全線產(chǎn)品優(yōu)惠15%/美國服務器/荷蘭服務器月付$ 69.40/月起

閱讀 852·2021-08-10 09:44

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

WebSocket之GatewayWorker使用說明

首發(fā)于個人博客 https://www.axie.cc/article/51

相關(guān)文章

**通過GatewayWorker/Workerman搭建Websocket微服務**

**使用Websocket框架之GatewayWorker開發(fā)電商平臺買家與賣家實時通訊**

**使用Websocket框架之GatewayWorker開發(fā)電商平臺買家與賣家實時通訊**

**使用Websocket框架之GatewayWorker開發(fā)電商平臺買家與賣家實時通訊**

**使用Websocket框架之GatewayWorker開發(fā)電商平臺買家與賣家實時通訊**

發(fā)表評論

0條評論

WilsonLiu95

男|高級講師

TA的文章

tensorflow

實現(xiàn)初階掃雷

#萬圣節(jié)#friendhosting，9個數(shù)據(jù)中心的VPS 5折促銷，可自定義ISO，不限流量，支持

90后的軟件測試工程師，現(xiàn)在都怎樣了？

無線測溫傳感器、無線測溫裝置在項目上的應用—安科瑞孫斌

云主機怎么裝網(wǎng)站-怎么在云主機上搭建網(wǎng)站？

cubemx配置stm32(三)__GPIO的輸入輸出

ShineServers：全線產(chǎn)品優(yōu)惠15%/美國服務器/荷蘭服務器月付$ 69.40/月起

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

WebSocket之GatewayWorker使用說明

首發(fā)于個人博客 https://www.axie.cc/article/51

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！