Go语言实现FastDFS分布式存储系统WebAPI网关
前言
工作需要,第一次使用 Go 來實(shí)戰(zhàn)項(xiàng)目。
需求:采用 golang 實(shí)現(xiàn)一個 webapi 的中轉(zhuǎn)網(wǎng)關(guān),將一些資源文件通過 http 協(xié)議上傳至 FastDFS 分布式文件存儲系統(tǒng)。
?
一、FastDFS 與 golang 對接的代碼
github:https://github.com/weilaihui/fdfs_client
源代碼可以 clone 下來看看,go 語法很簡單
基本使用:(client_test.go 中有 test 案例代碼)
package mainimport ("fmt""io/ioutil""github.com/weilaihui/fdfs_client" )func main() {ff, _ := ioutil.ReadFile("1.jpg")fmt.Println("image len:", len(ff))/*hosts := []string{"10.0.1.32"}port := 22122minConns := 10maxConns := 150connPool,_ := fdfs_client.NewConnectionPool(hosts, port, minConns, maxConns)*/path := "client.conf"fds, error := fdfs_client.NewFdfsClient(path)if fds == nil {fmt.Println("conn error: %s", error)var test stringfmt.Scanln(&test)return}uploadResponse, err := fds.UploadByBuffer(ff, "jpg")if uploadResponse == nil {fmt.Println("upload error: %s", err)var test stringfmt.Scanln(&test)return}fmt.Println("group name:", uploadResponse.GroupName)fmt.Println("remote file id:", uploadResponse.RemoteFileId)var test stringfmt.Scanln(&test) }?
二、簡單的 WebAPI 網(wǎng)關(guān)
beego 框架 go 圈很有名氣,國內(nèi)大學(xué)著作,考慮到這次工程較小,暫未使用起來。
go 實(shí)現(xiàn)一個 api 網(wǎng)關(guān)也是相當(dāng)?shù)暮唵?#xff1a;
package mainimport ("fmt""net/http" "io/ioutil" )func main() {http.HandleFunc("/", func(rw http.ResponseWriter, req *http.Request) {rw.Write([]byte("Hello go web"))})http.HandleFunc("/upload", upload)http.ListenAndServe("localhost:8888", nil)fmt.Println("End.") }func upload(rw http.ResponseWriter, req *http.Request) { fmt.Println("Header", req.Header)fmt.Println("Content-Type", req.Header.Get("Content-Type"))fmt.Println("Body", req.Body)// 獲取 body 的全部內(nèi)容
/*
len := req.ContentLength body := make([]byte, len) req.Body.Read(body) rw.Write([]byte("Response Body ....")) */
data, _ := ioutil.ReadAll(req.Body) }
?
PS:以上代碼只是自己筆記使用,因?yàn)閯側(cè)胧?go 不熟,僅供學(xué)習(xí)。
文件上傳中轉(zhuǎn),如果是較大的文件,則采用將數(shù)據(jù)分片傳輸?shù)姆绞竭M(jìn)行。
轉(zhuǎn)載于:https://www.cnblogs.com/loongsoft/p/9323235.html
總結(jié)
以上是生活随笔為你收集整理的Go语言实现FastDFS分布式存储系统WebAPI网关的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 周口治疗输卵管伞端粘连最好的医院推荐
- 下一篇: Kettle7.1在window启动报错