Développement Workerman : Comment implémenter le transfert de fichiers basé sur le protocole TCP

Développement Workerman : Comment implémenter le transfert de fichiers basé sur le protocole TCP, des exemples de code spécifiques sont nécessaires

Introduction :
À l'ère Internet d'aujourd'hui, le transfert de fichiers est devenu un élément indispensable du travail et de la vie quotidienne. Le transfert de fichiers basé sur le protocole TCP est une méthode à haute efficacité de transmission et à forte fiabilité. Dans cet article, nous présenterons comment utiliser le framework Workerman pour développer un service de transfert de fichiers basé sur le protocole TCP et fournirons des exemples de code spécifiques.

1. Qu’est-ce que Workerman ?
Workerman est un framework PHP Socket hautes performances développé en PHP pur, utilisé pour créer rapidement des applications multi-processus/multi-thread. Il prend en charge les protocoles TCP/UDP, les protocoles personnalisés et d'autres fonctionnalités. Workerman présente de nombreux avantages, tels que des capacités de traitement simultané élevées et une bonne stabilité. Par conséquent, il est approprié de choisir Workerman comme cadre pour les services de transfert de fichiers.

2. Préparatifs pour le transfert de fichiers basé sur le protocole TCP
Avant de commencer le développement, vous devez vous assurer que l'environnement PHP a été installé sur le système et que le framework Workerman a été installé. Workerman peut être installé via la commande suivante :

composer require workerman/workerman

Une fois l'installation terminée, vous pouvez créer un nouveau fichier transfer.php pour le service de transfert de fichiers et introduire le framework Workerman au début du fichier :

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

3. Écrivez le code du service de transfert de fichiers

1. Le code pour démarrer le service de transfert de fichiers est le suivant :

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

   Copier après la connexion

   Le code ci-dessus crée une instance Worker en appelant le constructeur de la classe Worker et spécifie le port d'écoute comme 600. Définissez ensuite le nombre de processus en cours d'exécution sur 1 et définissez la logique de traitement de la logique de transfert de fichiers. Enfin, démarrez le Worker en appelant la méthode statique runAll() de la classe Worker.

2. Ensuite, nous devons écrire la logique spécifique du transfert de fichiers. Dans la fonction de rappel onMessage, vous pouvez utiliser la fonction de traitement de fichiers de PHP pour réaliser le transfert de fichiers.

   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('文件传输完成'); } } };

   Copier après la connexion

   Dans le code ci-dessus, l'attribut d'instance de la classe TcpConnection est utilisé pour enregistrer les informations relatives au fichier. Lors de la réception du message de démarrage du transfert de fichier (le message commence par "start:"), analysez d'abord le nom et la taille du fichier à partir du message, puis créez un nouveau fichier via la fonction fopen et utilisez les propriétés de la classe TcpConnection. instance pour enregistrer le handle du fichier, la taille du fichier et la taille actuellement reçue. Lorsque les données du fichier sont reçues, utilisez la fonction fwrite pour écrire les données dans le fichier et mettre à jour la taille actuellement reçue. Lorsque la taille reçue est égale à la taille du fichier, cela indique que le transfert de fichier est terminé, que le descripteur de fichier est fermé et qu'un message de fin de transfert est envoyé au client via la méthode d'envoi de l'instance TcpConnection.

4. Testez le service de transfert de fichiers
Afin de tester le service de transfert de fichiers, vous pouvez utiliser telnet ou un programme client personnalisé pour vous connecter au serveur et envoyer des données de fichiers.

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();

Dans le code ci-dessus, créez d'abord une instance AsyncTcpConnection et spécifiez l'adresse et le port de connexion. Une fois la connexion établie, utilisez la méthode d'envoi pour envoyer le message indiquant que le transfert de fichier a commencé, lisez les données du fichier et envoyez-les. Après l'envoi, fermez la connexion via la méthode close.

5. Résumé
Grâce au framework Workerman, nous pouvons facilement implémenter des services de transfert de fichiers basés sur le protocole TCP. Cet article fournit un exemple de code de service de transfert de fichiers spécifique pour aider les développeurs à maîtriser et à utiliser plus rapidement Workerman pour le développement lié au transfert de fichiers. J'espère que cet article pourra vous être utile, bienvenue pour communiquer et discuter.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!