實(shí)戰(zhàn) swoole【聊天室】

andycall 發(fā)布于2019-07-01 11:06 / 2373人閱讀

摘要：是一個(gè)請(qǐng)求對(duì)象，包含了客戶端發(fā)來(lái)的握手請(qǐng)求信息事件函數(shù)中可以調(diào)用向客戶端發(fā)送數(shù)據(jù)或者調(diào)用關(guān)閉連接事件回調(diào)是可選的當(dāng)服務(wù)器收到來(lái)自客戶端的數(shù)據(jù)幀時(shí)會(huì)回調(diào)此函數(shù)。

前言：了解概念之后就應(yīng)該練練手啦，不然就是巨嬰

有收獲的話請(qǐng)加顆小星星，沒有收獲的話可以 反對(duì) 沒有幫助 舉報(bào)三連

代碼倉(cāng)庫(kù)

實(shí)戰(zhàn)swoole【聊天室】

在線體驗(yàn)

準(zhǔn)備工作

需要先看初識(shí)swoole【上】，了解基本的服務(wù)端WebSocket使用

js WebSocket客戶端簡(jiǎn)單使用

使用

# 命令行1
php src/websocket/run.php
# 命令行2
cd public && php -S localhost:8000
# 客戶端，多開幾個(gè)查看效果
訪問http://localhost:8000/

WebSocket

官方示例

$server = new swoole_websocket_server("0.0.0.0", 9501);
$server->on("open", function (swoole_websocket_server $server, $request) {
        echo "server: handshake success with fd{$request->fd}
";
    });
$server->on("message", function (swoole_websocket_server $server, $frame) {
        echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
        $server->push($frame->fd, "this is server");
    });
$server->on("close", function ($ser, $fd) {
        echo "client {$fd} closed
";
    });
$server->on("request", function (swoole_http_request $request, swoole_http_response $response) {
        global $server;//調(diào)用外部的server
        // $server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送
        foreach ($server->connections as $fd) {
            $server->push($fd, $request->get["message"]);
        }
    });
$server->start();

詳解：

swoole_websocket_server 繼承自 swoole_http_server

設(shè)置了onRequest回調(diào)，websocket服務(wù)器也可以同時(shí)作為http服務(wù)器

未設(shè)置onRequest回調(diào)，websocket服務(wù)器收到http請(qǐng)求后會(huì)返回http 400錯(cuò)誤頁(yè)面

如果想通過(guò)接收http觸發(fā)所有websocket的推送，需要注意作用域的問題，面向過(guò)程請(qǐng)使用global對(duì)swoole_websocket_server進(jìn)行引用，面向?qū)ο罂梢园裺woole_websocket_server設(shè)置成一個(gè)成員屬性

function onOpen(swoole_websocket_server $svr, swoole_http_request $req);

當(dāng)WebSocket客戶端與服務(wù)器建立連接并完成握手后會(huì)回調(diào)此函數(shù)。

$req 是一個(gè)Http請(qǐng)求對(duì)象，包含了客戶端發(fā)來(lái)的握手請(qǐng)求信息

onOpen事件函數(shù)中可以調(diào)用push向客戶端發(fā)送數(shù)據(jù)或者調(diào)用close關(guān)閉連接

onOpen事件回調(diào)是可選的

function onMessage(swoole_websocket_server $server, swoole_websocket_frame $frame)

當(dāng)服務(wù)器收到來(lái)自客戶端的數(shù)據(jù)幀時(shí)會(huì)回調(diào)此函數(shù)。

$frame 是swoole_websocket_frame對(duì)象，包含了客戶端發(fā)來(lái)的數(shù)據(jù)幀信息

onMessage回調(diào)必須被設(shè)置，未設(shè)置服務(wù)器將無(wú)法啟動(dòng)

客戶端發(fā)送的ping幀不會(huì)觸發(fā)onMessage，底層會(huì)自動(dòng)回復(fù)pong包

swoole_websocket_frame 屬性

$frame->fd，客戶端的socket id，使用$server->push推送數(shù)據(jù)時(shí)需要用到

$frame->data，數(shù)據(jù)內(nèi)容，可以是文本內(nèi)容也可以是二進(jìn)制數(shù)據(jù)，可以通過(guò)opcode的值來(lái)判斷

$frame->opcode，WebSocket的OpCode類型，可以參考WebSocket協(xié)議標(biāo)準(zhǔn)文檔

$frame->finish，表示數(shù)據(jù)幀是否完整，一個(gè)WebSocket請(qǐng)求可能會(huì)分成多個(gè)數(shù)據(jù)幀進(jìn)行發(fā)送（底層已經(jīng)實(shí)現(xiàn)了自動(dòng)合并數(shù)據(jù)幀，現(xiàn)在不用擔(dān)心接收到的數(shù)據(jù)幀不完整）

聊天室服務(wù)端示例

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

config

socket.php

src

websocket

Config.php

run.php

WebSocketServer.php 內(nèi)存表版本

WsRedisServer.php redis版本

WebSocketServer.php 內(nèi)存表版本

createTable();
        // 實(shí)例化配置
        $this->config = Config::getInstance();
    }

    public function run()
    {
        $this->server = new swoole_websocket_server(
            $this->config["socket"]["host"],
            $this->config["socket"]["port"]
        );

        $this->server->on("open", [$this, "open"]);
        $this->server->on("message", [$this, "message"]);
        $this->server->on("close", [$this, "close"]);

        $this->server->start();
    }

    public function open(swoole_websocket_server $server, swoole_http_request $request)
    {
        $user = [
            "fd" => $request->fd,
            "name" => $this->config["socket"]["name"][array_rand($this->config["socket"]["name"])] . $request->fd,
            "avatar" => $this->config["socket"]["avatar"][array_rand($this->config["socket"]["avatar"])]
        ];
        // 放入內(nèi)存表
        $this->table->set($request->fd, $user);

        $server->push($request->fd, json_encode(
                array_merge(["user" => $user], ["all" => $this->allUser()], ["type" => "openSuccess"])
            )
        );
    }

    private function allUser()
    {
        $users = [];
        foreach ($this->table as $row) {
            $users[] = $row;
        }
        return $users;
    }

    public function message(swoole_websocket_server $server, swoole_websocket_frame $frame)
    {
        $this->pushMessage($server, $frame->data, "message", $frame->fd);
    }

    /**
     * 推送消息
     *
     * @param swoole_websocket_server $server
     * @param string $message
     * @param string $type
     * @param int $fd
     */
    private function pushMessage(swoole_websocket_server $server, string $message, string $type, int $fd)
    {
        $message = htmlspecialchars($message);
        $datetime = date("Y-m-d H:i:s", time());
        $user = $this->table->get($fd);

        foreach ($this->table as $item) {
            // 自己不用發(fā)送
            if ($item["fd"] == $fd) {
                continue;
            }

            $server->push($item["fd"], json_encode([
                "type" => $type,
                "message" => $message,
                "datetime" => $datetime,
                "user" => $user
            ]));
        }
    }

    /**
     * 客戶端關(guān)閉的時(shí)候
     *
     * @param swoole_websocket_server $server
     * @param int $fd
     */
    public function close(swoole_websocket_server $server, int $fd)
    {
        $user = $this->table->get($fd);
        $this->pushMessage($server, "{$user["name"]}離開聊天室", "close", $fd);
        $this->table->del($fd);
    }

    /**
     * 創(chuàng)建內(nèi)存表
     */
    private function createTable()
    {
        $this->table = new swoole_table(1024);
        $this->table->column("fd", swoole_table::TYPE_INT);
        $this->table->column("name", swoole_table::TYPE_STRING, 255);
        $this->table->column("avatar", swoole_table::TYPE_STRING, 255);
        $this->table->create();
    }
}

WsRedisServer.php redis版本

config = Config::getInstance();
        // redis
        $this->initRedis();
        // 初始化，主要是服務(wù)端自己關(guān)閉不會(huì)清空redis
        foreach ($this->allUser() as $item) {
            $this->client->hdel("{$this->key}:{$item["fd"]}", ["fd", "name", "avatar"]);
        }
    }

    public function run()
    {
        $this->server = new swoole_websocket_server(
            $this->config["socket"]["host"],
            $this->config["socket"]["port"]
        );

        $this->server->on("open", [$this, "open"]);
        $this->server->on("message", [$this, "message"]);
        $this->server->on("close", [$this, "close"]);

        $this->server->start();
    }

    public function open(swoole_websocket_server $server, swoole_http_request $request)
    {
        $user = [
            "fd" => $request->fd,
            "name" => $this->config["socket"]["name"][array_rand($this->config["socket"]["name"])] . $request->fd,
            "avatar" => $this->config["socket"]["avatar"][array_rand($this->config["socket"]["avatar"])]
        ];
        // 放入redis
        $this->client->hmset("{$this->key}:{$user["fd"]}", $user);

        // 給每個(gè)人推送，包括自己
        foreach ($this->allUser() as $item) {
            $server->push($item["fd"], json_encode([
                "user" => $user,
                "all" => $this->allUser(),
                "type" => "openSuccess"
            ]));
        }
    }

    private function allUser()
    {
        $users = [];
        $keys = $this->client->keys("{$this->key}:*");
        // 所有的key
        foreach ($keys as $k => $item) {
            $users[$k]["fd"] = $this->client->hget($item, "fd");
            $users[$k]["name"] = $this->client->hget($item, "name");
            $users[$k]["avatar"] = $this->client->hget($item, "avatar");
        }
        return $users;
    }

    public function message(swoole_websocket_server $server, swoole_websocket_frame $frame)
    {
        $this->pushMessage($server, $frame->data, "message", $frame->fd);
    }

    /**
     * 推送消息
     *
     * @param swoole_websocket_server $server
     * @param string $message
     * @param string $type
     * @param int $fd
     */
    private function pushMessage(swoole_websocket_server $server, string $message, string $type, int $fd)
    {
        $message = htmlspecialchars($message);
        $datetime = date("Y-m-d H:i:s", time());
        $user["fd"] = $this->client->hget("{$this->key}:{$fd}", "fd");
        $user["name"] = $this->client->hget("{$this->key}:{$fd}", "name");
        $user["avatar"] = $this->client->hget("{$this->key}:{$fd}", "avatar");

        foreach ($this->allUser() as $item) {
            // 自己不用發(fā)送
            if ($item["fd"] == $fd) {
                continue;
            }

            $is_push = $server->push($item["fd"], json_encode([
                "type" => $type,
                "message" => $message,
                "datetime" => $datetime,
                "user" => $user
            ]));
            // 刪除失敗的推送
            if (!$is_push) {
                $this->client->hdel("{$this->key}:{$item["fd"]}", ["fd", "name", "avatar"]);
            }
        }
    }

    /**
     * 客戶端關(guān)閉的時(shí)候
     *
     * @param swoole_websocket_server $server
     * @param int $fd
     */
    public function close(swoole_websocket_server $server, int $fd)
    {
        $user["fd"] = $this->client->hget("{$this->key}:{$fd}", "fd");
        $user["name"] = $this->client->hget("{$this->key}:{$fd}", "name");
        $user["avatar"] = $this->client->hget("{$this->key}:{$fd}", "avatar");
        $this->pushMessage($server, "{$user["name"]}離開聊天室", "close", $fd);
        $this->client->hdel("{$this->key}:{$fd}", ["fd", "name", "avatar"]);
    }

    /**
     * 初始化redis
     */
    private function initRedis()
    {
        $this->client = new Client([
            "scheme" => $this->config["socket"]["redis"]["scheme"],
            "host" => $this->config["socket"]["redis"]["host"],
            "port" => $this->config["socket"]["redis"]["port"],
        ]);
    }
}

config.php

path = __DIR__ . "/../../config/";
    }

    // 單例模式
    public static function getInstance()
    {
        if (!self::$instance) {
            self::$instance = new self();
        }
        return self::$instance;
    }

    public function offsetSet($offset, $value)
    {
        // 閹割
    }

    public function offsetGet($offset)
    {
        if (empty($this->config)) {
            $this->config[$offset] = require $this->path . $offset . ".php";
        }
        return $this->config[$offset];
    }

    public function offsetExists($offset)
    {
        return isset($this->config[$offset]);
    }

    public function offsetUnset($offset)
    {
        // 閹割
    }

    // 禁止克隆
    final private function __clone(){}
}

config/socket.php

 "0.0.0.0",
    "port" => 9501,

    "redis" => [
        "scheme" => "tcp",
        "host" => "0.0.0.0",
        "port" => 6380
    ],

    "avatar" => [
        "./images/avatar/1.jpg",
        "./images/avatar/2.jpg",
        "./images/avatar/3.jpg",
        "./images/avatar/4.jpg",
        "./images/avatar/5.jpg",
        "./images/avatar/6.jpg"
    ],

    "name" => [
        "科比",
        "庫(kù)里",
        "KD",
        "KG",
        "喬丹",
        "鄧肯",
        "格林",
        "湯普森",
        "伊戈達(dá)拉",
        "麥迪",
        "艾弗森",
        "卡哇伊",
        "保羅"
    ]
];

run.php

run();

總結(jié)

完整示例：聊天室

學(xué)完后發(fā)現(xiàn)生活中所謂的聊天室其實(shí)也不過(guò)如此，當(dāng)然這只是簡(jiǎn)單的demo，很多功能都沒有實(shí)現(xiàn)，想進(jìn)一步學(xué)習(xí)的話可以去github上找完整的項(xiàng)目進(jìn)行深入學(xué)習(xí)

參考

swoole

PHP + Swoole 實(shí)現(xiàn)的簡(jiǎn)單聊天室

云服務(wù)器 GPU云服務(wù)器 swoole聊天室demo php_swoole聊天 Swoole swoole+websocket

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

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

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

andycall

男|高級(jí)講師

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

TA的文章

通配符證書有什么好處?常用通配符SSL證書有哪些?

閱讀 1223·2021-09-03 10:44
我所知道的flex布局 —— 上篇

閱讀 618·2019-08-30 13:13
如何造一個(gè)移動(dòng)端的聯(lián)動(dòng)選擇器（一）

閱讀 2813·2019-08-30 13:11
CSS魔法堂：你真的理解z-index嗎？

閱讀 1977·2019-08-30 12:59
前端每日實(shí)戰(zhàn)：32# 視頻演示如何用純 CSS 創(chuàng)作六邊形按鈕特效

閱讀 1049·2019-08-29 15:32
CSS3 border-radius妙用

閱讀 1611·2019-08-29 15:25
Vue 實(shí)用分頁(yè)組件paging（頁(yè)數(shù)太多時(shí)顯示省略號(hào)）

閱讀 1006·2019-08-29 12:24
Go 語(yǔ)言 Excel 類庫(kù) Excelize 2.0.0 版本發(fā)布

閱讀 1294·2019-08-27 10:58

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

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

實(shí)戰(zhàn) swoole【聊天室】

相關(guān)文章

swoole 超簡(jiǎn)單構(gòu)建聊天室.資辭群聊,組聊,單聊.

swoole 服務(wù)端120行代碼構(gòu)建一個(gè)websocket 聊天室.

swoole簡(jiǎn)單的聊天室demo（修正版）

發(fā)表評(píng)論

0條評(píng)論

andycall

男|高級(jí)講師

TA的文章

通配符證書有什么好處?常用通配符SSL證書有哪些?

我所知道的flex布局 —— 上篇

如何造一個(gè)移動(dòng)端的聯(lián)動(dòng)選擇器（一）

CSS魔法堂：你真的理解z-index嗎？

前端每日實(shí)戰(zhàn)：32# 視頻演示如何用純 CSS 創(chuàng)作六邊形按鈕特效

CSS3 border-radius妙用

Vue 實(shí)用分頁(yè)組件paging（頁(yè)數(shù)太多時(shí)顯示省略號(hào)）

Go 語(yǔ)言 Excel 類庫(kù) Excelize 2.0.0 版本發(fā)布

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

實(shí)戰(zhàn) swoole【聊天室】

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！