Golang melaksanakan cakera rangkaian

Dalam persekitaran Internet hari ini, orang ramai semakin memerlukan perkhidmatan storan awan seperti cakera rangkaian. Pada masa ini terdapat perkhidmatan storan awan yang popular di pasaran seperti Baidu Cloud, Weiyun, Dropbox, dll. Walau bagaimanapun, privasi dan keselamatan perkhidmatan ini tidak begitu dipercayai oleh orang ramai. Oleh itu, membangunkan cakera rangkaian sendiri telah menjadi pilihan yang semakin popular.

Artikel ini akan memperkenalkan cara menggunakan Golang untuk membangunkan perkhidmatan cakera rangkaian berasaskan web. Golang ialah bahasa pengaturcaraan sumber terbuka yang dibangunkan oleh Google Ia mempunyai ciri-ciri konkurensi tinggi, prestasi tinggi, kesederhanaan dan kemudahan penggunaan. Menggunakan Golang untuk membangunkan cakera rangkaian boleh membina perkhidmatan yang stabil dan cekap dengan cepat.

1. Persediaan persekitaran

Pertama, kita perlu memasang persekitaran Golang. Selepas memasang Golang, kami perlu memasang beberapa perpustakaan yang diperlukan:

• gin: rangka kerja web berprestasi tinggi untuk Golang, digunakan untuk membina API RESTful dengan cepat.
• gorm: Perpustakaan ORM Golang, digunakan untuk mengendalikan pangkalan data dengan mudah.

Selepas pemasangan selesai, kita boleh mula menulis kod dengan gembira.

2. Gunakan rangka kerja Gin untuk membina API RESTful

Dalam projek ini, kami menggunakan rangka kerja Gin untuk membina perkhidmatan Web. Rangka kerja Gin adalah ringkas dan mudah digunakan, dengan hampir tiada kos pembelajaran. Mula-mula buat fail main.go dan tulis kod berikut:

package main

import "github.com/gin-gonic/gin"

func main() {
  // 创建Gin引擎
  r := gin.Default()

  // 路由
  r.GET("/ping", func(c *gin.Context) {
    c.JSON(200, gin.H{
      "message": "pong",
    })
  })

  // 启动服务
  r.Run()
}

Kod ini mencipta enjin Gin dan mengendalikan laluan /ping. Jalankan kod: pergi jalankan main.go, kemudian masukkan http://localhost:8080/ping dalam penyemak imbas, anda boleh melihat output: {"message":"pong"}.

3. Operasi Fail

Seterusnya kita perlu memuat naik dan memuat turun fail. Memuat naik dan memuat turun fail memerlukan penyambungan ke pangkalan data terlebih dahulu, mengakses maklumat meta bagi fail yang sepadan, dan kemudian mengakses atau memuat turun fail itu sendiri.

1. Maklumat meta fail

Kami akan menggunakan pangkalan data MySQL untuk menyimpan maklumat meta fail, termasuk nama fail, saiz fail, masa muat naik, laluan penyimpanan fail pada cakera, dsb. Dalam projek ini, kami menggunakan perpustakaan Gorm untuk menyambung ke pangkalan data MySQL. Tambahkan kod berikut ke main.go:

import (
  "fmt"

  "github.com/jinzhu/gorm"
  _ "github.com/jinzhu/gorm/dialects/mysql"
)

type File struct {
  ID      uint   `gorm:"primary_key"`
  Name    string `gorm:"type:varchar(255)"`
  Size    int64
  Path    string `gorm:"type:varchar(255)"`
  CreatedAt time.Time
}

var db *gorm.DB
var err error

func init() {
  db, err = gorm.Open("mysql", "root:password@/filestore?charset=utf8&parseTime=True&loc=Local")
  if err != nil {
    fmt.Println("连接数据库失败：", err.Error())
    return
  }

  db.AutoMigrate(&File{})
}

Kod di atas mencipta struktur Fail, yang sepadan dengan jadual dalam pangkalan data. Kemudian gunakan gorm.Open untuk menyambung ke pangkalan data MySQL, dan gunakan perintah AutoMigrate untuk mencipta jadual secara automatik bernama "fail" dalam pangkalan data.

2. Muat naik fail

Dalam rangka kerja Gin, gunakan kaedah Siar untuk memuat naik fail. Kami perlu menambah kod berikut sebelum membuat penghalaan untuk mendayakan perisian tengah untuk memuat naik fail:

r.Static("/static", "./static")
r.POST("/upload", func(c *gin.Context) {
  file, header, err := c.Request.FormFile("file")
  if err != nil {
    c.JSON(http.StatusBadRequest, gin.H{
      "msg": err.Error(),
    })
    return
  }
  defer file.Close()

  // 保存文件到本地
  filename := header.Filename
  filepath := fmt.Sprintf("./static/%s", filename)
  err = c.SaveUploadedFile(header, filepath)
  if err != nil {
    c.JSON(http.StatusInternalServerError, gin.H{
      "msg": err.Error(),
    })
      return
  }

  // 将文件元信息存入数据库
  size := header.Size
  f := File{
    Name:    filename,
    Size:    size,
    Path:    filepath,
    CreatedAt: time.Now(),
  }
  _,err = f.InsertFile()
  if err !=nil{
    c.JSON(http.StatusInternalServerError, gin.H{
        "msg": err.Error(),
    })
    return
  }
  c.JSON(http.StatusOK, gin.H{
    "msg": "Upload successful",
  })
})

Dalam kod di atas, kami berjaya mendapatkan fail yang dimuat naik dari Borang Permintaan dan kemudian menyimpan fail ke pelayan kami. Selepas itu, kami menyimpan metamaklumat fail dalam pangkalan data, di mana InsertFile() ialah fungsi operasi pangkalan data yang kami buat kemudian.

3. Muat turun fail

Kami menulis fungsi muat turun mudah untuk mengeluarkan kandungan fail ke dalam respons HTTP untuk muat turun klien. Kod lengkap adalah seperti berikut:

func (file File) GetFile() (err error) {
  //打开文件并读取文件内容
  f, err := os.Open(file.Path)
  if err != nil {
      return
  }
  defer f.Close()

  w := bufio.NewWriter(file)

  b := make([]byte, 100)
  n := 0
  for {
      n, err = f.Read(b)
      if err != nil && err != io.EOF{
          return
      }
      w.Write(b[:n])
      if n == 0{
          break
      }
  }
  w.Flush()
  return
}

r.GET("/download", func(c *gin.Context) {
  fileName := c.Query("name")
  if len(fileName) == 0 {
    c.JSON(http.StatusBadRequest, gin.H{
      "msg": "invalid parameter",
    })
    return
  }

  file := File{
    Name: fileName,
  }
  err = file.GetFile()
  if err !=nil{
    c.JSON(http.StatusInternalServerError, gin.H{
      "msg": err.Error(),
    })
    return
  }
  c.Writer.Header().Add("Content-Disposition", fmt.Sprintf("attachment;filename=%s", fileName))
  c.Writer.Header().Add("Content-Type", "application/octet-stream")
  c.File(file.Path)
})

4. Pengoptimuman storan

Dalam persekitaran konkurensi tinggi, muat naik dan muat turun fail mestilah cekap. Oleh itu, kami boleh menggunakan storan teragih untuk mengoptimumkan masalah ini. Pecutan CDN, penyimpanan objek dan kaedah lain boleh digunakan.

5. Lengkapkan kod

Seterusnya, kami akan mengehoskan kod lengkap pada Git.

Buat direktori projek, dan kemudian laksanakan arahan berikut dalam terminal:

git init
gema "# fileServer" >> README.md
git add README .md
git commit -m "first commit"
git remote add origin git@github.com:username/fileServer.git
git push -u origin master

Untuk kod lengkap , sila rujuk: https: //github.com/username/fileServer.

Nota: Gantikan nama pengguna dengan nama pengguna GitHub anda.

6. Ringkasan

Artikel ini terutamanya memperkenalkan cara menggunakan Golang untuk membangunkan perkhidmatan cakera rangkaian berasaskan web. Melalui artikel ini, kita boleh memahami penggunaan asas rangka kerja Gin, perpustakaan Gorm, dan pangkalan data MySQL, serta cara melaksanakan operasi seperti muat naik dan muat turun fail. Kod lengkap yang disediakan dalam artikel ini boleh membantu pembaca lebih memahami kandungan yang diterangkan dalam artikel ini dan membantu dalam aplikasi praktikal.

Atas ialah kandungan terperinci Golang melaksanakan cakera rangkaian. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!