使用php開發Websocket，打造即時訊息推播系統-php教程-PHP中文網

使用php開發Websocket，打造即時訊息推播系統

PHPz

發布： 2023-12-02 09:20:01

原創

715 人瀏覽過

使用php開發Websocket，打造即時訊息推播系統

使用PHP開發WebSocket，打造即時訊息推播系統

引言
隨著即時通訊需求的增加，基於WebSocket的即時訊息推播系統在Web開發中越來越受歡迎。本文將介紹如何使用PHP開發簡單的WebSocket應用，實現即時訊息推播功能。
什麼是WebSocket？
WebSocket是一種在單一TCP連線上進行全雙工、雙向通訊的協定。與傳統的HTTP協定相比，WebSocket能夠提供更快的、即時的資料傳輸，適用於需要即時訊息推播的場景。
開發環境準備
在開始之前，我們需要準備以下幾個工具和環境：
PHP 7.0 ：本文以PHP作為伺服器端語言，並且需要使用PHP的WebSocket擴展。
Apache或Nginx：作為Web伺服器，用於在客戶端與伺服器之間建立WebSocket連線。
WebSocket客戶端：可以是任意支援WebSocket的瀏覽器或偵錯工具。
伺服器端程式碼範例
首先，我們需要在伺服器端建立一個WebSocket伺服器實例，並監聽指定的連接埠。

// 创建WebSocket服务器实例，监听指定端口
$server = new SwooleWebSocketServer('0.0.0.0', 9501);

// 监听WebSocket连接打开事件
$server->on('open', function (SwooleWebSocketServer $server, SwooleHttpRequest $request) {
    echo "WebSocket连接打开
";
});

// 监听WebSocket消息事件
$server->on('message', function (SwooleWebSocketServer $server, SwooleWebSocketFrame $frame) {
    echo "收到消息：{$frame->data}
";
    // 推送消息给所有连接的客户端
    $server->push($frame->fd, "服务器收到消息：{$frame->data}");
});

// 监听WebSocket连接关闭事件
$server->on('close', function (SwooleWebSocketServer $server, int $fd) {
    echo "WebSocket连接关闭
";
});

// 启动WebSocket服务器
$server->start();

登入後複製

上述程式碼使用Swoole擴充功能建立WebSocket伺服器實例，監聽9501埠。每當有客戶端連線、傳送訊息或關閉連線時，都會觸發對應的事件處理函數。

客戶端程式碼範例
接下來，我們需要在客戶端建立WebSocket連接，以便與伺服器實現即時通訊。

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket示例</title>
</head>
<body>
    <script type="text/javascript">
        // 创建WebSocket对象，与服务器建立连接
        var ws = new WebSocket('ws://localhost:9501');

        // 监听WebSocket连接打开事件
        ws.onopen = function () {
            console.log('WebSocket连接已打开');
        };

        // 监听WebSocket消息事件
        ws.onmessage = function (event) {
            console.log('收到消息：' + event.data);
        };

        // 监听WebSocket连接关闭事件
        ws.onclose = function () {
            console.log('WebSocket连接已关闭');
        };

        // 发送消息
        function sendMessage() {
            var message = document.getElementById('message').value;
            ws.send(message);
        }
    </script>

    <input type="text" id="message" placeholder="输入消息" />
    <button onclick="sendMessage()">发送消息</button>
</body>
</html>

登入後複製

上述程式碼在瀏覽器端使用JavaScript建立WebSocket對象，與伺服器建立連線。透過監聽WebSocket事件，可以實現接收訊息、發送訊息和捕獲連接關閉等功能。