用PHP+swoole做簡單的聊天室

最近自學了swoole，想做點東西試試看，剛好看到可以簡單做個聊天室，于是自己研究研究搞了一個。

websocket是不同于http的另外一種網絡通信協議，能夠進行雙向通信，基于此，可開發出各種實時通信產品，我簡單做了個聊天室demo，順便分享一下。

這里我簡單把websocket服務器分配的fd（文件描述,可以理解為用戶id）在文本（user.txt）,
然后進行遍歷群發送消息，不啰嗦，核心代碼如下：

websocket.php

<?php
class Websocket
{
    public $server;
    public $userFile = __DIR__ . '/user.txt';
    public function __construct()
    {
        //設置成0.0.0.0代表監聽所有地址來源的連接，所以可以進行連接。
        $this->server = new swoole_websocket_server("0.0.0.0", 9502);

        //監聽WebSocket連接打開事件
        $this->server->on('open', function (swoole_websocket_server $server, $request) {
            echo "server: handshake success with fd{$request->fd}\n";
            $array = [];
            if (file_exists($this->userFile)) {
                $array = array_filter(explode(',', file_get_contents($this->userFile)));
            }
            array_push($array, $request->fd);
            file_put_contents($this->userFile, join(',', $array), LOCK_EX);
        });

        //監聽WebSocket消息事件
        $this->server->on('message', function (swoole_websocket_server $server, $frame) {
            echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
            //獲取聊天用戶數組
            $array = explode(',', file_get_contents($this->userFile));
            foreach ($array as $key => $val) {
                $array[$key] = intval($val);
            }
            //組裝消息數據
            $msg = json_encode([
                'fd' => $frame->fd,//客戶id
                'msg' => $frame->data,//發送數據
                'total_num' => count($array)//聊天總人數
            ], JSON_UNESCAPED_UNICODE);
            //發送消息
            foreach ($array as $fdId) {
                $server->push($fdId, $msg);
            }
        });

        //監聽WebSocket連接關閉事件
        $this->server->on('close', function ($server, $fd) {
            //獲取聊天用戶數組
            $array = explode(',', file_get_contents($this->userFile));
            foreach ($array as $key => $val) {
                $array[$key] = intval($val);
            }
            ///組裝消息數據
            $msg = json_encode(
                [
                    'fd' => $fd,
                    'msg' => '離開聊天室!',
                    'total_num' => count($array) - 1
                ],
                JSON_UNESCAPED_UNICODE);
            //發送消息
            foreach ($array as $key => $fdId) {
                if ($fdId == $fd) {
                    unset($array[$key]);
                } else {
                    $server->push($fdId, $msg);
                }
            }
            //更新聊天用戶數組
            file_put_contents($this->userFile, join(',', $array), LOCK_EX);
            echo "client {$fd} closed\n";
        });

        //監聽Http請求事件
        $this->server->on('request', function ($request, $response) {
            // 接收http請求從get獲取message參數的值，給用戶推送
            // $this->server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送
            foreach ($this->server->connections as $fd) {
                $this->server->push($fd, $request->get['message']);
            }
        });
        $this->server->start();
    }
}

new Websocket();

使用方法

安裝完php 和swoole擴展之后，直接執行：

php websocket.php

并可以觀察下輸出，看看websocket服務器是否正常。

效果如下：

開發遇到的問題

1代碼中不要用,exit()/die(),socket會報   ERROR   zm_deactivate_swoole (ERROR 9003): worker process is terminated by exit()/die()，因為子進程沒有處理就退出了,主進程又會重新拉起。這樣就造成死循環了。
2.進程隔離也是很多新手經常遇到的問題。修改了全局變量的值，為什么不生效，原因就是全局變量在不同的進程，內存空間是隔離的，所以無效。
3.因為我的代碼都是在虛擬機上跑，想讓其他PC訪問，需要做NAT端口映射。

其中,192.168.1.119是我本地ip，192.168.33.10是我虛擬機的ip,socket服務是在虛擬機的9520端口跑的，最后前端代碼的socket端口也相應改下就可以了。

前后端代碼在我的git有,有興趣的同學自行下載~

git地址：https://github.com/onebig32/swoole
歡迎star！

參考:
https://segmentfault.com/a/1190000003057118
NAT端口映射:http://blog.csdn.net/hitabc141592/article/details/31778923
swoole手冊：https://wiki.swoole.com/wiki/page/397.html