使用php開發Websocket，實現即時推播功能-php教程-PHP中文網

首頁

後端開發

php教程

使用php開發Websocket，實現即時推播功能

王林

Dec 02, 2023 pm 12:44 PM

使用php開發Websocket，實現即時推播功能

標題：使用PHP開發Websocket，實現即時推送功能

Websocket是一種基於TCP協議的通訊協議，在Web開發中，可以使用Websocket實現即時推送功能，以實現即時通訊或即時更新資料的需求。在本文中，我們將使用PHP語言開發Websocket伺服器，並提供具體的程式碼範例。

一、概述

Websocket是全雙工的通訊協議，相對於傳統的HTTP協定來說，Websocket更適用於即時通訊場景。 Websocket協定的特點包括：

支援全雙工通信，能夠同時發送和接收資料。
與HTTP協定相容，使用類似HTTP的握手協定進行連線建立，可以透過HTTP/HTTPS連接埠進行通訊。
可以在任意時間發送數據，無需等待請求-回應循環。
支援跨域通信，可以在不同的網域下進行通信。

二、開發環境準備

在開始開發之前，需要準備一些工具和環境：

安裝PHP：確保你的系統上已經安裝了PHP解譯器。
安裝Composer：Composer是PHP的依賴管理工具，我們將使用它來安裝Websocket相關的程式庫。
選擇一個編輯器：你可以選擇任何一個你喜歡的編輯器來開發，例如VS Code、Sublime Text等。

三、安裝Websocket庫

在PHP中，有很多成熟的Websocket庫可供選擇，其中比較常用的有Ratchet、Swoole等。在本文中，我們將使用Ratchet來進行開發。

在專案根目錄下建立一個composer.json文件，並新增以下內容：

{
    "require": {
        "cboden/ratchet": "^0.4"
    }
}

登入後複製

開啟終端，切換到專案根目錄，執行以下指令安裝Ratchet庫：

composer install

登入後複製

四、寫Websocket伺服器程式碼

在建立Websocket伺服器之前，我們先來討論Websocket的工作流程。

連接建立：客戶端與伺服器建立Websocket連接，客戶端發送一個HTTP請求，伺服器傳回一個協定切換的回應，建立連線。
訊息傳輸：雙方可以透過send方法發送訊息，並透過onMessage事件接收訊息。
連線關閉：客戶端或伺服器端任意一方發送關閉訊框來關閉連線。

下面是一個使用Ratchet庫編寫Websocket伺服器的範例程式碼：

<?php

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
use RatchetServerIoServer;

require 'vendor/autoload.php';

class MyWebSocket implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage();
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection: {$conn->resourceId}
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理接收到的消息逻辑
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection closed: {$conn->resourceId}
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new MyWebSocket()
        )
    ),
    8080
);

$server->run();

登入後複製

以上程式碼定義了一個MyWebSocket類，實作了MessageComponentInterface介面中的方法，用於處理連線、訊息、關閉和錯誤事件。在onOpen事件中，我們將新建立的連線加入$clients集合中；在onMessage事件中，我們會遍歷所有連線並將訊息傳送給其他客戶端；在onClose事件中，我們從$clients集合中刪除關閉的連接；在onError事件中，我們處理異常並關閉連接。

五、執行Websocket伺服器

在終端機中切換到專案根目錄，執行下列指令啟動Websocket伺服器：

php server.php

登入後複製

如果一切正常，你將會看到類似如下的輸出：

New connection: 1
New connection: 2
Message received: Hello from client 1
Message received: Hello from client 2
Connection closed: 1

登入後複製

六、寫客戶端程式碼

最後，我們還需要寫一個客戶端來進行測試。

<!DOCTYPE html>
<html>
<head>
    <title>Websocket Client</title>
    <script>
        var socket = new WebSocket("ws://localhost:8080");

        socket.onopen = function() {
            console.log("Connected");
        };

        socket.onmessage = function(event) {
            console.log("Message received: " + event.data);
        };

        socket.onclose = function(event) {
            console.log("Connection closed");
        };

        function sendMessage() {
            var message = document.getElementById("message").value;
            socket.send(message);
        }
    </script>
</head>
<body>
    <input type="text" id="message">
    <button onclick="sendMessage()">Send</button>
</body>
</html>

登入後複製

在該範例中，我們使用JavaScript建立了一個Websocket連接，並在連接建立、接收訊息和關閉連接時列印相應的日誌。在頁面上，我們提供了一個輸入框和一個發送按鈕，用於發送訊息。

七、總結

本文介紹了使用PHP開發Websocket伺服器的方法，並提供了具體的程式碼範例，幫助讀者理解Websocket的工作原理和使用方式。 Websocket具有即時通訊能力，可用於實現即時推送、聊天室、多人遊戲等場景，希望這篇文章對你有所幫助。

以上是使用php開發Websocket，實現即時推播功能的詳細內容。更多資訊請關注PHP中文網其他相關文章！

本網站聲明

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

人工智慧驅動的應用程序，用於創建逼真的裸體照片

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

免費脫衣圖片

Clothoff.io

AI脫衣器

Video Face Swap

使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！

熱工具

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

中文版，非常好用

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學

1674

CakePHP 教程

1429

Laravel 教程

1333

PHP教程

1278

C# 教程

1257

Related knowledge

說明PHP中的安全密碼散列（例如，password_hash，password_verify）。為什麼不使用MD5或SHA1？ Apr 17, 2025 am 12:06 AM

在PHP中，應使用password_hash和password_verify函數實現安全的密碼哈希處理，不應使用MD5或SHA1。1)password_hash生成包含鹽值的哈希，增強安全性。 2)password_verify驗證密碼，通過比較哈希值確保安全。 3)MD5和SHA1易受攻擊且缺乏鹽值，不適合現代密碼安全。

PHP類型提示如何起作用，包括標量類型，返回類型，聯合類型和無效類型？ Apr 17, 2025 am 12:25 AM

PHP類型提示提升代碼質量和可讀性。 1)標量類型提示：自PHP7.0起，允許在函數參數中指定基本數據類型，如int、float等。 2)返回類型提示：確保函數返回值類型的一致性。 3)聯合類型提示：自PHP8.0起，允許在函數參數或返回值中指定多個類型。 4)可空類型提示：允許包含null值，處理可能返回空值的函數。

PHP和Python：解釋了不同的範例 Apr 18, 2025 am 12:26 AM

PHP主要是過程式編程，但也支持面向對象編程（OOP）；Python支持多種範式，包括OOP、函數式和過程式編程。 PHP適合web開發，Python適用於多種應用，如數據分析和機器學習。

您如何防止PHP中的SQL注入？（準備的陳述，PDO） Apr 15, 2025 am 12:15 AM

在PHP中使用預處理語句和PDO可以有效防範SQL注入攻擊。 1)使用PDO連接數據庫並設置錯誤模式。 2)通過prepare方法創建預處理語句，使用佔位符和execute方法傳遞數據。 3)處理查詢結果並確保代碼的安全性和性能。

PHP和Python：代碼示例和比較 Apr 15, 2025 am 12:07 AM

PHP和Python各有優劣，選擇取決於項目需求和個人偏好。 1.PHP適合快速開發和維護大型Web應用。 2.Python在數據科學和機器學習領域佔據主導地位。

PHP：處理數據庫和服務器端邏輯 Apr 15, 2025 am 12:15 AM

PHP在數據庫操作和服務器端邏輯處理中使用MySQLi和PDO擴展進行數據庫交互，並通過會話管理等功能處理服務器端邏輯。 1）使用MySQLi或PDO連接數據庫，執行SQL查詢。 2）通過會話管理等功能處理HTTP請求和用戶狀態。 3）使用事務確保數據庫操作的原子性。 4）防止SQL注入，使用異常處理和關閉連接來調試。 5）通過索引和緩存優化性能，編寫可讀性高的代碼並進行錯誤處理。