Workerman 開発: TCP プロトコルに基づいたファイル転送を実装する方法

ワーカーマン開発: TCP プロトコルに基づいてファイル転送を実装する方法、具体的なコード例が必要です

はじめに:
今日のインターネット時代では、ファイル転送は次のようになりました。日常生活 仕事と生活の不可欠な部分。 TCPプロトコルに基づくファイル転送は、伝送効率が高く信頼性の高い方式です。この記事では、Workerman フレームワークを使用して TCP プロトコルに基づくファイル転送サービスを開発する方法を紹介し、具体的なコード例を示します。

1. ワーカーマンとは何ですか?
Workerman は、純粋な PHP を使用して開発された高性能 PHP ソケット フレームワークで、マルチプロセス/マルチスレッド アプリケーションを迅速に構築するために使用されます。 TCP/UDP プロトコル、カスタム プロトコル、その他の機能をサポートします。 Workerman には、高い同時処理能力や優れた安定性など、多くの利点があります。したがって、ファイル転送サービスのフレームワークとして Workerman を選択するのは適切です。

2. TCP プロトコルに基づくファイル転送の準備
開発を開始する前に、システムに PHP 環境と Workerman フレームワークがインストールされていることを確認する必要があります。次のコマンドを使用して Workerman をインストールできます:

composer require workerman/workerman

インストールが完了したら、ファイル転送サービス用の新しいファイル transfer.php を作成し、ファイルの先頭に Workerman フレームワークを導入できます。 ##

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

3. ファイルを書き込みます 転送サービスのコード

1. ファイル転送サービスを開始するコードは次のとおりです。

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

   上記コードは Worker クラスのコンストラクターを呼び出して Worker インスタンスを作成し、リスナーを指定します。ポートは 600 です。次に、実行プロセス数を 1 に設定し、ファイル転送ロジックの処理ロジックを定義します。最後に、Worker クラスの静的メソッド runAll() を呼び出して Worker を開始します。

2. 次に、ファイル転送の具体的なロジックを記述する必要があります。 onMessageのコールバック関数では、PHPのファイル処理機能を利用してファイル転送を実現できます。

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

   上記のコードでは、TcpConnection クラスのインスタンス属性を使用して、ファイル関連の情報を保存します。ファイル転送の開始メッセージ (メッセージは "start:" で始まります) を受信すると、まずメッセージからファイル名とファイル サイズを解析し、次に fopen 関数を通じて新しいファイルを作成し、TcpConnection クラスのプロパティを使用します。ファイルハンドル、ファイルサイズ、現在受信しているサイズを保存するインスタンス。ファイルデータを受信したら、fwrite 関数を使用してデータをファイルに書き込み、現在受信しているサイズを更新します。受信したサイズがファイル サイズと等しい場合、ファイル転送が完了したことを示し、ファイル ハンドルが閉じられ、TcpConnection インスタンスの send メソッドを通じて転送完了メッセージがクライアントに送信されます。

4. ファイル転送サービスをテストする

ファイル転送サービスをテストするには、Telnet またはカスタム クライアント プログラムを使用してサーバーに接続し、ファイル データを送信します。

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

上記のコードでは、まず AsyncTcpConnection インスタンスを作成し、接続アドレスとポートを指定します。接続確立後、sendメソッドでファイル転送を開始した旨のメッセージを送信し、ファイルデータを読み出して送信します。送信後、close メソッドで接続を閉じます。

5. 概要

Workerman フレームワークを通じて、TCP プロトコルに基づいたファイル転送サービスを簡単に実装できます。この記事では、開発者がファイル転送関連の開発で Workerman をより迅速に習得して使用できるように、具体的なファイル転送サービスのコード例を示します。この記事があなたのお役に立てば幸いです。コミュニケーションやディスカッションを歓迎します。

以上がWorkerman 開発: TCP プロトコルに基づいたファイル転送を実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。