Workerman-Entwicklung: So implementieren Sie eine Dateiübertragung basierend auf dem TCP-Protokoll

Workerman-Entwicklung: Für die Implementierung einer Dateiübertragung auf Basis des TCP-Protokolls sind spezifische Codebeispiele erforderlich

Einführung:
Im heutigen Internetzeitalter ist die Dateiübertragung zu einem unverzichtbaren Bestandteil der täglichen Arbeit und des Lebens geworden. Die auf dem TCP-Protokoll basierende Dateiübertragung ist eine Methode mit hoher Übertragungseffizienz und hoher Zuverlässigkeit. In diesem Artikel stellen wir vor, wie Sie mit dem Workerman-Framework einen Dateiübertragungsdienst basierend auf dem TCP-Protokoll entwickeln, und stellen spezifische Codebeispiele bereit.

1. Was ist Workerman?
Workerman ist ein leistungsstarkes PHP-Socket-Framework, das mit reinem PHP entwickelt wurde und zum schnellen Erstellen von Multiprozess-/Multithread-Anwendungen verwendet wird. Es unterstützt TCP/UDP-Protokolle, benutzerdefinierte Protokolle und andere Funktionen. Workerman bietet viele Vorteile, wie z. B. hohe Fähigkeiten zur gleichzeitigen Verarbeitung und gute Stabilität. Daher ist es angemessen, Workerman als Framework für Dateiübertragungsdienste zu wählen.

2. Vorbereitungen für die Dateiübertragung basierend auf dem TCP-Protokoll
Bevor Sie mit der Entwicklung beginnen, müssen Sie sicherstellen, dass das System die PHP-Umgebung und das Workerman-Framework installiert hat. Workerman kann über den folgenden Befehl installiert werden:

composer require workerman/workerman

Nach Abschluss der Installation können Sie eine neue Datei transfer.php für den Dateiübertragungsdienst erstellen und das Workerman-Framework am Anfang der Datei einführen:

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

3. Schreiben Sie den Code für den Dateiübertragungsdienst

1. Der Code zum Starten des Dateiübertragungsdienstes lautet wie folgt:

   use WorkermanWorker;
   
   // 创建一个Worker监听指定端口
   $worker = new Worker('tcp://0.0.0.0:600');
   
   // 设置运行的进程数，这里设置为1
   $worker->count = 1;
   
   // 定义文件传输相关的处理逻辑
   $worker->onMessage = function($connection, $data) {
    // 处理文件传输逻辑
    // ...
   };
   
   // 启动Worker
   Worker::runAll();

   Der obige Code erstellt eine Worker-Instanz, indem er den Konstruktor der Worker-Klasse aufruft und den Überwachungsport als 600 angibt. Setzen Sie dann die Anzahl der laufenden Prozesse auf 1 und definieren Sie die Verarbeitungslogik der Dateiübertragungslogik. Starten Sie abschließend den Worker, indem Sie die statische Methode runAll() der Worker-Klasse aufrufen.

2. Als nächstes müssen wir die spezifische Logik der Dateiübertragung schreiben. In der Rückruffunktion onMessage können Sie die Dateiverarbeitungsfunktion von PHP verwenden, um die Dateiübertragung zu realisieren.

   use WorkermanConnectionTcpConnection;
   
   // ...
   
   $worker->onMessage = function(TcpConnection $connection, $data) {
    if (strpos($data, 'start:') === 0) {
        // 获取文件名和文件大小
        $fileInfo = explode(':', $data);
        $fileName = $fileInfo[1];
        $fileSize = intval($fileInfo[2]);
   
        // 创建新的文件，并准备接收文件数据
        $file = fopen($fileName, 'w');
        $connection->file = $file;
        $connection->fileSize = $fileSize;
        $connection->currentSize = 0;
   
    } elseif ($connection->file && strlen($data) === 1024) {
        // 写入文件数据
        fwrite($connection->file, $data);
        $connection->currentSize += strlen($data);
   
        // 文件传输完成
        if ($connection->currentSize === $connection->fileSize) {
            fclose($connection->file);
            $connection->file = null;
            // 响应文件传输完成消息
            $connection->send('文件传输完成');
        }
    }
   };

   Im obigen Code wird das Instanzattribut der TcpConnection-Klasse zum Speichern dateibezogener Informationen verwendet. Wenn Sie die Startnachricht der Dateiübertragung erhalten (die Nachricht beginnt mit „start:“), analysieren Sie zunächst den Dateinamen und die Dateigröße aus der Nachricht, erstellen Sie dann über die Funktion fopen eine neue Datei und verwenden Sie die Eigenschaften der TcpConnection-Klasse Instanz zum Speichern der Datei Handle, Dateigröße und aktuell empfangene Größe. Wenn Dateidaten empfangen werden, verwenden Sie die Funktion fwrite, um die Daten in die Datei zu schreiben und die aktuell empfangene Größe zu aktualisieren. Wenn die empfangene Größe der Dateigröße entspricht, bedeutet dies, dass die Dateiübertragung abgeschlossen ist, das Dateihandle geschlossen ist und über die Sendemethode der TcpConnection-Instanz eine Nachricht zum Abschluss der Übertragung an den Client gesendet wird.

4. Testen Sie den Dateiübertragungsdienst
Um den Dateiübertragungsdienst zu testen, können Sie Telnet oder ein benutzerdefiniertes Clientprogramm verwenden, um eine Verbindung zum Server herzustellen und Dateidaten zu senden.

use WorkermanConnectionAsyncTcpConnection;

$connection = new AsyncTcpConnection('tcp://127.0.0.1:600');

$connection->onConnect = function() use($connection) {
    // 发送文件传输开始消息
    $connection->send('start:/path/to/file.txt:1024');
    
    // 读取文件数据并发送
    $file = fopen('/path/to/file.txt', 'r');
    while (!feof($file)) {
        $connection->send(fread($file, 1024));
    }

    // 关闭连接
    $connection->close();
};

$connection->connect();

Erstellen Sie im obigen Code zunächst eine AsyncTcpConnection-Instanz und geben Sie die Verbindungsadresse und den Port an. Nachdem die Verbindung hergestellt wurde, verwenden Sie die Sendemethode, um die Nachricht zu senden, dass die Dateiübertragung begonnen hat, lesen Sie die Dateidaten und senden Sie sie. Schließen Sie nach dem Senden die Verbindung über die Close-Methode.

5. Zusammenfassung
Über das Workerman-Framework können wir problemlos Dateiübertragungsdienste basierend auf dem TCP-Protokoll implementieren. Dieser Artikel enthält ein spezifisches Codebeispiel für einen Dateiübertragungsdienst, um Entwicklern dabei zu helfen, Workerman schneller für die Entwicklung im Zusammenhang mit der Dateiübertragung zu beherrschen und zu verwenden. Ich hoffe, dass dieser Artikel für Sie hilfreich sein kann. Gerne können Sie mit ihm kommunizieren und diskutieren.

Das obige ist der detaillierte Inhalt vonWorkerman-Entwicklung: So implementieren Sie eine Dateiübertragung basierend auf dem TCP-Protokoll. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!