PHP WebSocket開發實例：如何實作特定功能的實作案例-php教程-PHP中文網

PHP WebSocket开发实例：如何实现特定功能的实践案例

PHP WebSocket開發實例：如何實現特定功能的實踐案例

近年來，隨著Web應用的日益複雜化，傳統的HTTP協定在即時通訊方面表現出了一些不足之處。為了滿足即時通訊的需求，WebSocket應運而生。

WebSocket是一種在單一TCP連接上進行全雙工通訊的協議，它允許伺服器主動向客戶端推送數據，而不需要客戶端發送請求。這使得即時通訊、線上遊戲、即時監控等應用變得更加便捷和有效率。

在本文中，我們將介紹一個基於PHP的WebSocket開發實例，透過這個案例，我們將學習如何實現一個特定功能的實踐過程。

假設我們要開發一個線上聊天室的應用程式，使用者可以在網頁上傳送訊息，其他使用者可以即時收到並回覆。這個功能涉及以下幾個關鍵點：

WebSocket伺服器的搭建
客戶端與伺服器的通訊
訊息的發送與接收
使用者清單的維護

首先，我們需要建立一個WebSocket伺服器。在PHP中，我們可以使用Ratchet這個函式庫來實作WebSocket的功能。透過Composer安裝Ratchet：

1	`composer` `require` `cboden/ratchet`

登入後複製

接著，建立一個server.php文件，編寫以下程式碼：

<?php
 
require 'vendor/autoload.php';
 
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
 
class Chat 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 {$conn->resourceId} has disconnected
";
    }
     
    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}
 
$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);
 
$server->run();

登入後複製

這個程式碼創建了一個Chat類，實作了MessageComponentInterface接口，我們可以定義各種事件處理函數。接下來，我們需要將訊息發送給其他線上用戶，這裡使用了foreach循環遍歷所有連接的客戶端，並判斷是否是來源客戶端本身。

在命令列中執行php server.php，WebSocket伺服器就啟動了。

接下來，我們需要在網頁上實現與伺服器的通訊。在網頁上，我們可以使用JavaScript來建立一個WebSocket對象，與後端進行通訊。

<script>
var conn = new WebSocket('ws://localhost:8080');
 
conn.onopen = function() {
    console.log('Connected!');
}
 
conn.onmessage = function(e) {
    console.log('Received: ' + e.data);
}
 
function sendMessage() {
    var message = document.getElementById('input').value;
    conn.send(message);
}
</script>

登入後複製

上面的程式碼建立了一個WebSocket對象，並定義了onopen和onmessage事件的處理函數。在輸入框內輸入訊息後，點選傳送按鈕呼叫sendMessage函數，將訊息傳送給伺服器。

最後，我們需要維護一個使用者列表，來顯示線上使用者並更新使用者列表。我們可以在伺服器端的onOpen和onClose事件中加入對應的邏輯：

public function onOpen(ConnectionInterface $conn) {
    $this->clients->attach($conn);
    echo "New connection! ({$conn->resourceId})
";
     
    // 将新用户加入用户列表，并广播给其他在线用户
    foreach ($this->clients as $client) {
        $client->send('New user has joined');
    }
}
 
public function onClose(ConnectionInterface $conn) {
    $this->clients->detach($conn);
    echo "Connection {$conn->resourceId} has disconnected
";
     
    // 将离线用户从用户列表中删除，并广播给其他在线用户
    foreach ($this->clients as $client) {
        $client->send('A user has left');
    }
}