如何在PHP中使用WebSockets API實現即時通訊-php教程-PHP中文網

如何在PHP中使用WebSockets API實現即時通訊

PHPz

發布： 2023-06-17 14:46:01

原創

2071 人瀏覽過

WebSockets API是一種在網頁上進行即時互動的新型協議，其最大的優點就是能夠實現雙向通信，使伺服器和客戶端之間可以進行即時通訊。在PHP中，我們可以使用Ratchet函式庫來實作WebSockets的功能。本文將詳細介紹如何在PHP中使用WebSockets API實現即時通訊。

一、安裝Ratchet函式庫

在開始實作WebSockets功能之前，我們需要先安裝Ratchet函式庫。 Ratchet函式庫是一個PHP實作的WebSockets伺服器，可以幫助我們快速實現WebSockets的功能。透過Composer來安裝Ratchet庫很方便，我們只需要在專案目錄下執行以下命令：

composer require cboden/ratchet

登入後複製

二、建立WebSockets伺服器

安裝完Ratchet庫之後，我們就可以建立WebSockets伺服器了。在PHP中，透過建立一個繼承自RatchetServerIoServer的類別來實作WebSockets伺服器。我們首先需要引入Ratchet庫，然後建立一個名為WebSocketServer的類，並產生一個WebSocket伺服器實例。

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

class WebSocketServer {
    public function __construct() {
        $server = IoServer::factory(
            new HttpServer(
                new WsServer(
                    new Chat()
                )
            ),
            8080
        );
        $server->run();
    }
}

登入後複製

在上面的程式碼中，我們建立了一個WebSocket伺服器實例，並在8080連接埠上運行。在WebSockets伺服器運作之前，我們需要先建立一個名為Chat的類，用於實作伺服器的業務邏輯。 Chat類別將用於處理客戶端連線、斷開連線和接收訊息等操作。

三、處理客戶端連線和斷開連線

接下來，我們需要在Chat類別中實作客戶端連線、斷開連線和接收訊息等操作。在客戶端連線時，我們需要將其記錄下來，並且向其發送歡迎訊息。在客戶端斷開連線時，我們需要將其從記錄中移除。以下是處理客戶端連線和斷開連線的程式碼：

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New client connected: {$conn->resourceId}
";
        $conn->send("Welcome!
");
    }

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

登入後複製

上述程式碼中，在Chat類別的建構函式中，我們建立一個名為clients的SplObjectStorage對象，用於儲存所有客戶端連線。在onOpen方法中，當有客戶端連線時，我們將其儲存到clients中，並向客戶端發送歡迎訊息。在onClose方法中，當有客戶端斷開連線時，我們會將其從clients中移除。

四、處理訊息發送和廣播

在客戶端連接和斷開連接的邏輯處理完成之後，我們需要實現接收訊息、發送訊息和廣播訊息等邏輯。在Chat類別中，我們需要實作onMessage方法來處理收到的訊息，並且向發送者和其他客戶端發送不同的訊息。

public function onMessage(ConnectionInterface $from, $msg) {
    $data = json_decode($msg);
    $numRecv = count($this->clients) - 1;
    if ($data->type === 'message') {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                // The sender is not the receiver, send to each client connected
                $client->send(json_encode([
                    'type' => 'message',
                    'user' => $data->user,
                    'message' => $data->message
                ]));
            } else {
                $from->send(json_encode([
                    'type' => 'message',
                    'user' => 'You',
                    'message' => $data->message
                ]));
            }
        }
    }
}

登入後複製

在上述程式碼中，我們首先解析收到的訊息，並根據不同類型的訊息進行不同的處理。在訊息類型為message時，我們需要向所有客戶端廣播一個訊息。如果發送者不是接收者，則向接收者和發送者分別發送不同的訊息。

最後，我們需要在WebSocketServer類中實例化Chat類，並啟動WebSockets伺服器：