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

// 建立一个 RPC 服务
type FileUploadServer struct {}

// 注册 FileUploadServer 服务
func RegisterFileUploadServer(s *rpc.Server) {
    s.Register(new(FileUploadServer))
}

// 定义 UploadFile 方法
func (s *FileUploadServer) UploadFile(file *File, reply *FileResponse) error {

    // TODO: 实际的文件上传逻辑

}

// 导入所需包
import (
    "net/rpc"
    "os"
)

// 定义 FileUploadClient 客户端
type FileUploadClient struct {
    conn   *rpc.Client
    path   string
    file   *os.File
}

// 创建 FileUploadClient 客户端
func NewFileUploadClient(path string) (*FileUploadClient, error) {

    // 连接到 RPC 服务器
    conn, err := rpc.Dial("tcp", "localhost:8080")

    // 返回 FileUploadClient 客户端
    return &FileUploadClient{
        conn:   conn,
        path:   path,
    }, err
}

// 上传文件
func (c *FileUploadClient) UploadFile() error {

   // 打开文件
   file, err := os.Open(c.path)

   // 序列化文件并通过 RPC 调用发送
   return c.conn.Call("FileUploadServer.UploadFile", &File{Data: file}, &FileResponse{})
}

// 服务端代码
package main

import (
    "net"
    "net/rpc"
    os"
)

type FileUploadServer struct {}

func RegisterFileUploadServer(s *rpc.Server) {
    s.Register(new(FileUploadServer))
}

func (s *FileUploadServer) UploadFile(file *File, reply *FileResponse) error {
    
    // 将文件保存到本地
    f, err := os.Create("./" + file.Name)

    if err != nil {
        return err
    }
    
    _, err = f.Write(file.Data)

    return err
}

func main() {
    // 创建 RPC 服务器并注册服务
    rpc.RegisterName("FileUploadServer", new(FileUploadServer))

    // 监听指定端口
    listener, err := net.Listen("tcp", ":8080")

    if err != nil {
        log.Fatal(err)
    }
    
    // 接受 RPC 连接并处理请求
    rpc.Accept(listener)
}

// 客户端代码
package main

import (
    "log"
    "net/rpc"
    "os"
)

type File struct {
    Name string
    Data []byte
}

type FileResponse struct {}

func main() {
    // 创建 RPC 客户端
    client, err := rpc.Dial("tcp", "localhost:8080")

    if err != nil {
        log.Fatal(err)
    }

   // 打开要上传的文件
   file, err := os.Open("./test.txt")

   if err != nil {
        log.Fatal(err)
    }
    
    // 序列化文件并通过 RPC 调用发送
   if err = client.Call("FileUploadServer.UploadFile", &File{Name: "test.txt", Data: file}, &FileResponse{}); err != nil {
        log.Fatal(err)
   }
   
   log.Println("文件上传成功")
}