So verwenden Sie Workerman zur Implementierung eines WebSocket-Servers

Mit der zunehmenden Beliebtheit der WebRTC-Technologie, Echtzeitkommunikation von Spielen, Online-Chat und anderen Anwendungen wird die WebSocket-Technologie immer wichtiger. Workerman ist ein leistungsstarkes asynchrones TCP-, UDP- und Unix-Socket-Netzwerk-Framework, das in einer PHP-Umgebung ausgeführt wird. Es unterstützt von Natur aus eine hohe Parallelit?t und eignet sich sehr gut für die Entwicklung von WebSocket-Servern.

In diesem Artikel wird detailliert beschrieben, wie Sie mit Workerman einen WebSocket-Server implementieren, einschlie?lich der Handhabung von WebSocket-Verbindungen, des Sendens und Empfangens von WebSocket-Nachrichten und der Integration des Frameworks in andere Bibliotheken. Am Ende des Artikels finden Sie au?erdem einen vollst?ndigen Beispielcode.

1. Workerman installieren

Bevor Sie Workerman verwenden, müssen Sie es zuerst installieren. Es kann über Composer installiert werden, oder Sie k?nnen den Quellcode direkt von GitHub herunterladen und manuell installieren. Hier nehmen wir die Composer-Installation als Beispiel:

composer require workerman/workerman

2. WebSocket-Servercode schreiben

Bevor Sie Workerman zum Implementieren des WebSocket-Servers verwenden, müssen Sie zun?chst verstehen, wie das WebSocket-Protokoll funktioniert. WebSocket ist ein Vollduplex-Protokoll für lange Verbindungen. Der Client und der Server stellen durch einen Handshake eine Verbindung her und k?nnen sich dann gegenseitig Nachrichten senden. WebSocket-Nachrichten k?nnen beliebige Daten wie Text, Bin?rdaten oder sogar Dateien sein und der Server kann sie je nach Nachrichtentyp unterschiedlich verarbeiten.

Die Implementierung eines WebSocket-Servers mit Workerman ist sehr einfach und erfordert nur wenige Codezeilen. Hier ist ein Beispiel:

require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;

// 創(chuàng)建一個(gè)Worker監(jiān)聽(tīng)8090端口，使用websocket協(xié)議通訊
$wsWorker = new Worker("websocket://0.0.0.0:8090");

// 啟動(dòng)4個(gè)進(jìn)程對(duì)外提供服務(wù)
$wsWorker->count = 4;

// 處理WebSocket連接的回調(diào)函數(shù)
$wsWorker->onConnect = function($connection) {
    echo "New connection
";
};

// 處理WebSocket消息的回調(diào)函數(shù)
$wsWorker->onMessage = function($connection, $data) {
    // 處理消息...
};

// 啟動(dòng)Worker
Worker::runAll();

Zuerst erstellen wir eine Worker-Instanz und geben sie an, um Port 8090 abzuh?ren und über das Websocket-Protokoll zu kommunizieren. Richten Sie dann vier Prozesse ein, um eine gro?e Anzahl gleichzeitiger Verbindungen zu verarbeiten. Worker unterstützt mehrere übertragungsprotokolle wie TCP, UDP und Unix Socket, daher müssen wir das WebSocket-Protokoll angeben.

In diesem Beispiel definieren wir nur zwei Rückruffunktionen:

1. Wenn eine neue WebSocket-Verbindung hergestellt wird, wird die onConnect-Rückruffunktion aufgerufen. Hier k?nnen wir Protokolle aufzeichnen, Online-Benutzer z?hlen und andere Vorg?nge ausführen.
2. Wenn eine WebSocket-Nachricht empfangen wird, wird die Rückruffunktion onMessage aufgerufen. Wir müssen die Nachricht hier verarbeiten, z. B. einfache Berechnungen durchführen, Antworten senden usw.
3. Der letzte Schritt besteht darin, den Worker zu starten, der beginnt, den angegebenen Port abzuh?ren und WebSocket-Verbindungen und -Nachrichten zu verarbeiten.
4. WebSocket-Nachrichtenverarbeitung

über die onMessage-Rückruffunktion k?nnen wir die vom Client gesendete WebSocket-Nachricht empfangen. Das Datenformat kann Text oder Bin?r sein. Die Art und Weise, wie WebSocket-Nachrichten verarbeitet werden, h?ngt vom Anwendungsszenario ab. Beispielsweise müssen Online-Chat-Anwendungen m?glicherweise Funktionen wie Broadcasting und Punkt-zu-Punkt-Chat implementieren, w?hrend Spieleanwendungen Echtzeitkommunikation auf Mikrosekundenebene implementieren müssen.

Hier ist ein einfaches Beispiel, das die empfangene Nachricht ausdruckt und dem Client antwortet:

$wsWorker->onMessage = function($connection, $data) {
    echo "Received message: {$data}
";
    $connection->send("Received: {$data}");
};

Status der WebSocket-Verbindung

Nachdem die WebSocket-Verbindung hergestellt wurde, bleibt die Verbindung zwischen dem Client und dem Server offen. Durch die Rückruffunktion onClose k?nnen wir den Fall einer Verbindungsunterbrechung bew?ltigen:

$wsWorker->onClose = function($connection) {
    echo "Connection closed
";
};

4. Integrationsframework

Workerman kann problemlos in andere Frameworks integriert werden. Hier nehmen wir das Laravel-Framework als Beispiel, um vorzustellen, wie Workerman zum Implementieren eines WebSocket-Servers in Laravel verwendet wird.

Zuerst müssen wir Workerman in unserem Laravel-Projekt installieren:

composer require workerman/workerman

Als n?chstes k?nnen wir einen benutzerdefinierten Artisan-Befehl erstellen, um den WebSocket-Server zu starten:

php artisan make:command WebSocketServer

Dann schreiben Sie den Code in app/Console/Commands/WebSocketServer.php Datei:

<?php

namespace AppConsoleCommands;

use IlluminateConsoleCommand;
use WorkermanWorker;

class WebSocketServer extends Command {
    // 命令名稱
    protected $name = 'websocket:server';

    // 命令描述
    protected $description = 'Start WebSocket server';

    // 執(zhí)行命令
    public function handle() {
        // 創(chuàng)建Worker實(shí)例，監(jiān)聽(tīng)8080端口
        $wsWorker = new Worker("websocket://0.0.0.0:8080");

        // 進(jìn)程數(shù)量
        $wsWorker->count = 4;

        // 處理連接事件
        $wsWorker->onConnect = function($connection) {
            echo "New connection
";
        };

        // 處理消息事件
        $wsWorker->onMessage = function($connection, $data) {
            // 處理消息
        };

        // 運(yùn)行Worker
        Worker::runAll();
    }
}

Abschlie?end k?nnen wir den WebSocket-Server mit dem folgenden Befehl starten:

php artisan websocket:server

Wie Sie sehen, ist die Implementierung eines WebSocket-Servers mithilfe von Workerman sehr einfach und l?sst sich problemlos in andere Frameworks integrieren.

5. Vollst?ndiges Codebeispiel

Das Folgende ist ein vollst?ndiges WebSocket-Serverbeispiel, das vom Client gesendete Nachrichten empfangen, eine einfache Verarbeitung durchführen und die Verarbeitungsergebnisse an den Client antworten kann:

count = 4;

// 處理WebSocket連接的回調(diào)函數(shù)
$wsWorker->onConnect = function($connection) {
    echo "New connection
";
};

// 處理WebSocket消息的回調(diào)函數(shù)
$wsWorker->onMessage = function($connection, $data) {
    echo "Received message: {$data}
";
    $result = "Received: {$data}";
    $connection->send($result);
};

// 處理連接斷開(kāi)事件的回調(diào)函數(shù)
$wsWorker->onClose = function($connection) {
    echo "Connection closed
";
};

// 啟動(dòng)Worker
Worker::runAll();

Das Obige wird mit Workerman Through implementiert Als ich diesen Artikel einleitete, glaube ich, dass die Leser das relevante technische Wissen über den gesamten Inhalt des WebSocket-Servers beherrschen und diese Techniken auch für die Entwicklung in tats?chlichen Projekten verwenden k?nnen.

Das obige ist der detaillierte Inhalt vonWorkerman-Entwicklung: So implementieren Sie einen WebSocket-Server. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!