gRPC を使用してファイルをアップロードするにはどうすればよいですか?リクエストおよびレスポンスメッセージを含むサポートサービス定義を作成します。クライアントでは、アップロードされるファイルが開かれてチャンクに分割され、gRPC ストリーム経由でサーバーにストリーミングされます。サーバー側(cè)では、ファイル チャンクが受信され、ファイルに保存されます。ファイルのアップロードが完了すると、サーバーはアップロードが成功したかどうかを示す応答を送信します。

gRPC を使用して Golang でファイルのアップロードを?qū)g裝する方法

gRPC (Google リモート プロシージャ コール) は、あらゆる環(huán)境で実行できる汎用の高パフォーマンスのオープンソース リモート プロシージャ コール フレームワークです。これは、異なるマシン間でデータを転送する効率的な方法を提供し、分散システムで大きなファイルを転送する必要がある狀況に最適です。

サポート サービス

始める前に、ファイルのアップロードを処理するサポート サービスを作成する必要があります。以下はサービス定義のサンプルです:

// 文件上傳服務(wù)接口
syntax = "proto3";

package file_upload;

service FileUploadService {
  rpc Upload(stream FileChunk) returns (FileUploadResponse);
}

// 文件塊信息
message FileChunk {
  bytes data = 1;
}

// 文件上傳響應(yīng)
message FileUploadResponse {
  bool success = 1;
}

gRPC クライアント実裝

gRPC のクライアント実裝は、次のようにファイル アップロード プロセスを使用します:

package main

import (
    "context"
    "io"
    "log"

    file_upload "github.com/example/file-upload"
    "google.golang.org/grpc"
)

func main() {
    // 建立與服務(wù)的連接
    conn, err := grpc.Dial("127.0.0.1:50051", grpc.WithInsecure())
    if err != nil {
        log.Fatalf("連接服務(wù)失敗: %v", err)
    }
    defer conn.Close()

    // 創(chuàng)建文件上傳客戶端
    client := file_upload.NewFileUploadServiceClient(conn)

    // 打開要上傳的文件
    file, err := os.Open("example.txt")
    if err != nil {
        log.Fatalf("打開文件失敗: %v", err)
    }
    defer file.Close()

    // 將文件分成塊進(jìn)行流式傳輸
    stream, err := client.Upload(context.Background())
    if err != nil {
        log.Fatalf("創(chuàng)建流式傳輸失敗: %v", err)
    }

    // 循環(huán)讀取文件并發(fā)送塊
    buf := make([]byte, 1024)
    for {
        n, err := file.Read(buf)
        if err == io.EOF {
            break
        }
        if err != nil {
            log.Fatalf("讀取文件失敗: %v", err)
        }

        // 發(fā)送塊
        if err := stream.Send(&file_upload.FileChunk{Data: buf[:n]}); err != nil {
            log.Fatalf("發(fā)送塊失敗: %v", err)
        }
    }

    stream.CloseSend()

    // 接收上傳響應(yīng)
    resp, err := stream.Recv()
    if err != nil {
        log.Fatalf("接收上傳響應(yīng)失敗: %v", err)
    }

    log.Printf("上傳成功: %v", resp.Success)
}

サポート サービス実裝

サーバーは受信と処理のロジックを?qū)g裝します。アップロードされたファイル:

package main

import (
    "context"
    "io"
    "log"

    file_upload "github.com/example/file-upload"
)

func main() {
    // 創(chuàng)建文件上傳服務(wù)
    server := &FileUploadService{}

    // 創(chuàng)建 gRPC 服務(wù)器并注冊服務(wù)
    s := grpc.NewServer()
    file_upload.RegisterFileUploadServiceServer(s, server)

    lis, err := net.Listen("tcp", "127.0.0.1:50051")
    if err != nil {
        log.Fatalf("監(jiān)聽端口失敗: %v", err)
    }

    // 啟動 gRPC 服務(wù)器
    if err := s.Serve(lis); err != nil {
        log.Fatalf("啟動 gRPC 服務(wù)器失敗: %v", err)
    }
}

// FileUploadService 服務(wù)的具體實現(xiàn)
type FileUploadService struct{}

func (s *FileUploadService) Upload(stream file_upload.FileUploadService_UploadServer) error {
    file, err := os.Create("received.txt")
    if err != nil {
        return err
    }

    for {
        chunk, err := stream.Recv()
        if err == io.EOF {
            break
        }
        if err != nil {
            return err
        }

        if _, err := file.Write(chunk.GetData()); err != nil {
            return err
        }
    }

    if err := stream.SendAndClose(&file_upload.FileUploadResponse{Success: true}); err != nil {
        return err
    }

    return nil
}

上記のコードは、gRPC を使用して Golang でファイルのアップロードを?qū)g裝する方法を示しています。クライアントはファイルをチャンクに分割し、サーバーにストリーミングします。サーバーは、アップロードされたファイルを受信して??処理します。

以上がgRPC を使用して Golang でファイルのアップロードを?qū)g裝するにはどうすればよいですか?の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。