如何使用 gRPC 實作檔案上傳？建立配套服務定義，包括請求和回應訊息。在客戶端，開啟要上傳的檔案並將其分成區(qū)塊，然後透過 gRPC 串流傳輸?shù)椒斩?。在服務端，接收文件區(qū)塊並將其儲存到文件中。服務端在文件上傳完成後發(fā)送回應，指示上傳是否成功。

如何在Golang 中使用gRPC 實作檔案上傳

gRPC（Google遠端過程呼叫）是一個通用的、高效能的、開源的遠端過程呼叫框架，可以在任何環(huán)境中運作。它提供了在不同的機器之間傳輸資料的有效方式，並且非常適合需要在分散式系統(tǒng)中傳輸大型檔案的情況。

配套服務

在開始之前，你需要建立一個配套服務來處理檔案上傳。以下是一個範例服務定義：

// 文件上傳服務接口
syntax = "proto3";

package file_upload;

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

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

// 文件上傳響應
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() {
    // 建立與服務的連接
    conn, err := grpc.Dial("127.0.0.1:50051", grpc.WithInsecure())
    if err != nil {
        log.Fatalf("連接服務失敗: %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()

    // 將文件分成塊進行流式傳輸
    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()

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

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

#配套服務實作

服務端實作接收和處理上傳檔案的邏輯：

package main

import (
    "context"
    "io"
    "log"

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

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

    // 創(chuàng)建 gRPC 服務器并注冊服務
    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 服務器
    if err := s.Serve(lis); err != nil {
        log.Fatalf("啟動 gRPC 服務器失敗: %v", err)
    }
}

// FileUploadService 服務的具體實現(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
}

以上程式碼展示如何在Golang 中使用gRPC 實作檔案上傳?？蛻舳藢n案分成區(qū)塊並透過串流傳輸?shù)椒斩耍斩藙t負責接收和處理上傳的檔案。

以上是如何在 Golang 中使用 gRPC 實作檔案上傳？的詳細內容。更多資訊請關注PHP中文網(wǎng)其他相關文章！