Workerman-Entwicklungsmodell: Best Practices für die Implementierung von Echtzeit-Daten-Push-Funktionen-Workerman-php.cn

Workerman-Entwicklungsmodell: Best Practices für die Implementierung von Echtzeit-Daten-Push-Funktionen

PHPz

Freigeben： 2023-08-05 08:13:13

Original

1127 Leute haben es durchsucht

Workerman-Entwicklungsmodell: Best Practices für die Implementierung von Echtzeit-Daten-Push-Funktionen

Einführung:
Mit der rasanten Entwicklung des Internets ist Echtzeit-Daten-Push zu einer notwendigen Funktion für viele Anwendungen geworden. Im Bereich PHP ist Workerman zweifellos eines der leistungsfähigsten Echtzeit-Daten-Push-Frameworks. In diesem Artikel wird beschrieben, wie Sie mit Workerman Echtzeit-Daten-Push-Funktionen entwickeln und einige Best-Practice-Codebeispiele bereitstellen.

1. Was ist Workerman?
Workerman ist ein leistungsstarkes PHP-Framework für die asynchrone Netzwerkkommunikation im PHP-Bereich. Es basiert auf reinem PHP ohne Abhängigkeiten und kann unabhängig ausgeführt werden. Workerman verwendet ein nicht blockierendes E/A-Modell und kann eine große Anzahl gleichzeitiger Verbindungen verarbeiten. Gleichzeitig bietet es eine praktische und benutzerfreundliche Oberfläche, die es Entwicklern ermöglicht, schnell leistungsstarke Echtzeitanwendungen zu entwickeln.

2. Erstellen Sie eine einfache Echtzeit-Daten-Push-Anwendung. Zuerst müssen wir Composer verwenden, um Workerman zu installieren:

composer require workerman/workerman

Nach dem Login kopieren

. Dann erstellen wir eine server.php-Datei und geben den folgenden Code ein:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;

// 创建一个Worker监听8080端口，使用websocket协议通讯
$ws_worker = new Worker('websocket://0.0.0.0:8080');

// 启动4个进程对外提供服务
$ws_worker->count = 4;

// 当客户端与服务端建立连接时触发
$ws_worker->onConnect = function ($connection) {
    echo "New connection
";
};

// 当客户端给服务端发送消息时触发
$ws_worker->onMessage = function ($connection, $data) use ($ws_worker) {
    // 将消息广播给所有客户端
    foreach ($ws_worker->connections as $client_connection) {
        $client_connection->send($data);
    }
};

// 当客户端与服务端断开连接时触发
$ws_worker->onClose = function ($connection) {
    echo "Connection closed
";
};

// 运行worker
Worker::runAll();

Nach dem Login kopieren

. Dieser Code wird einfach erstellt Ein Websocket-Server löst entsprechende Ereignisse aus, wenn ein neuer Client eine Verbindung herstellt, eine Nachricht sendet oder die Verbindung trennt. Die spezifische Ereignisverarbeitungslogik kann entsprechend den tatsächlichen Anforderungen geändert werden.

3. Client-Codebeispiel

Um unsere Echtzeit-Daten-Push-Funktion zu testen, können wir eine einfache HTML-Datei erstellen, um den Client zu simulieren. In dieser HTML-Datei verwenden wir Javascript, um eine WebSocket-Verbindung zu implementieren und Nachrichten zu senden und zu empfangen.

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>实时数据推送</title>
    <script>
        var ws = new WebSocket('ws://127.0.0.1:8080');

        ws.onopen = function () {
            console.log('已连接服务器');
        };

        ws.onmessage = function (event) {
            console.log('收到消息：' + event.data);
        };

        function send() {
            var message = document.getElementById('message').value;
            ws.send(message);
            console.log('发送消息：' + message);
        }
    </script>
</head>
<body>
    <input type="text" id="message" placeholder="请输入要发送的消息">
    <button onclick="send()">发送</button>
</body>
</html>

Nach dem Login kopieren

Dieser Javascript-Code erstellt eine Websocket-Verbindung und definiert Ereignisse im Zusammenhang mit dem Herstellen einer Verbindung mit dem Server, dem Empfangen von Nachrichten und dem Senden von Nachrichten. Durch Eingabe der zu versendenden Nachricht in das Eingabefeld und Klicken auf die Schaltfläche „Senden“ kann die Nachricht an den Server gesendet werden und die empfangene Nachricht wird auf der Konsole angezeigt.

4. Best Practices

Bei der tatsächlichen Entwicklung müssen viele Faktoren berücksichtigt werden, z. B. Berechtigungskontrolle, Gruppenverwaltung, Nachrichtenüberprüfung usw. Hier ist ein Beispielcode für Best Practices:

Überprüfung der Benutzeranmeldung:

// 在onConnect事件中验证用户登录
$ws_worker->onConnect = function ($connection) {
    // 获取用户token
    $token = $connection->getRequestHeader('token');
    // 验证token
    if (!verifyToken($token)) {
        $connection->close();
    }
};

Nach dem Login kopieren

// 创建分组、加入分组和发送给指定分组的示例代码
$group = new WorkermanConnectionConnections();
$group->add($client_connection);
$ws_worker->group['group_name'] = $group;
...

// 发送消息给指定分组
$ws_worker->group['group_name']->send($data);

Nach dem Login kopieren

// 在onMessage事件中判断要发送的客户端id
$id = $data['recipient_id'];
if ($connection = $ws_worker->uidConnections[$id] ?? null) {
    // 找到对应的客户端连接并发送消息
    $connection->send($data);
}

Nach dem Login kopieren

Schlussfolgerung:

Das obige ist der detaillierte Inhalt vonWorkerman-Entwicklungsmodell: Best Practices für die Implementierung von Echtzeit-Daten-Push-Funktionen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!