golang-gin-mgo高并發(fā)服務(wù)器搭建教程

更新時間：2020年12月17日 15:46:20 作者：wayne_魚蛋

這篇文章主要介紹了golang-gin-mgo高并發(fā)服務(wù)器搭建教程，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

gin-mgo服務(wù)器搭建

該服務(wù)器實現(xiàn)簡單接收請求并將請求參數(shù)封裝存儲在mongodb數(shù)據(jù)庫中,本文將講述gin－mgo的使用方法。

項目完整代碼地址： https://github.com/wayne-yhp/golang-gin-mgo

gin web框架使用介紹

首先獲取gin框架依賴

go get gopkg.in/gin-gonic/gin.v1

func main() {
  server = gin.Default()
  app.server.GET("/do", IndexRouter)//創(chuàng)造一個GET請求的路由地址，并指定處理函數(shù)為IndexRouter函數(shù)
  app.server.Run(":8080")
}
func IndexRouter(c *gin.Context) {
  if c.Request.Form == nil {   //獲取所有請求參數(shù)名和值的預(yù)處理
    c.Request.ParseMultipartForm(32 << 20)
  }
  params = c.Request.Form   //獲取所有參數(shù)列表
  fmt.Println(params)     //打印輸出參數(shù)
  c.String(http.StatusOK,"hello gin")//返回給頁面hello gin字符串
  //c.HTML(http.StatusOK, "index.html", nil)   //頁面跳轉(zhuǎn)
}

mgo 持久層框架使用介紹

前提條件mongodb環(huán)境已經(jīng)搭建好了，首先安裝mgo框架依賴

go get labix.org/v2/mgo

type User struct{
  username string
  pwd string
}
func main() {
  mgo_session, err = mgo.Dial("127.0.0.1") //獲取連接對象session
  if err != nil {
    panic(err)
  }
  defer session.Close()    //方法執(zhí)行完后關(guān)閉連接
  mgo_db = oper.mgo_session.DB("test")  //獲取數(shù)據(jù)庫對象，數(shù)據(jù)庫名為test
  //如果沒有mongodb沒有開啟權(quán)限認(rèn)證，則跳過這一步
  mgo_db.Login("test1", "test1")  //用戶認(rèn)證，用戶名賬戶和密碼都是test1
  mgo_c = oper.mgo_db.C("coll")  //獲取數(shù)據(jù)庫某個集合對象
  //插入操作
  mgo_c.insert(&User{
    username: "xxx",
    pwd: "xxx",
  })
}

提高服務(wù)器高并發(fā)性能講解(針對文章開頭地址中的項目)

該項目主要實現(xiàn)接收請求，解析封裝參數(shù)，插入數(shù)據(jù)庫的簡單操作，這里只涉及插入操作，故不涉及數(shù)據(jù)緩存的知識，整個服務(wù)處于單機下，故不涉及分布式服務(wù)架構(gòu)，集群的知識。

注意以下

1、開啟一個協(xié)程獨自監(jiān)聽訪問數(shù)量，進行插入操作

2、實現(xiàn)批量插入

3、實現(xiàn)定時插入

4、加鎖解決并發(fā)資源競爭

開啟一個協(xié)程獨自監(jiān)聽訪問數(shù)量，進行插入操作

如果將插入操作放在主線程，那么接收http請求和邏輯處理，數(shù)據(jù)庫插入操作都必須要順序執(zhí)行，大大降低了插入效率，因此要開啟一個協(xié)程，獨自監(jiān)聽訪問數(shù)量，進行數(shù)據(jù)庫插入。

實現(xiàn)批量插入

假想一下如果每次有人訪問你的數(shù)據(jù)庫你就進行一次插入操作，那么你的數(shù)據(jù)庫將會是一個什么樣的情況？我們都知道數(shù)據(jù)庫操作相對服務(wù)器其他操作是一件相對很耗時的事情，所以每次訪問就操作一次數(shù)據(jù)庫，會大大降低服務(wù)器性能，更別說有幾千上萬的人同時訪問你的服務(wù)器了。

實現(xiàn)定時插入

在實現(xiàn)了批量插入的基礎(chǔ)上，如果沒有達到一定的訪問量，那么就不會執(zhí)行插入操作，剛好在兩個訪問請求中間隔了很長時間，那么前面的請求就會等待很久才會更新到數(shù)據(jù)庫中，為了防止這種情況，我們必須要設(shè)定一個時間，定時插入。

加鎖解決并發(fā)資源競爭

在并發(fā)量幾千上萬的情況下，可能一秒可以執(zhí)行很多次數(shù)據(jù)庫的插入操作，這個時候很有可能上一個插入還沒執(zhí)行完，第二個就已經(jīng)執(zhí)行了，這時候可能出現(xiàn)數(shù)據(jù)冗余，服務(wù)器癱瘓等問題，因此要給批量插入操作加上一個讀寫鎖。

具體實現(xiàn)細節(jié)可以去上述地址中查看。

補充：Golang號稱高并發(fā)，但高并發(fā)時性能不高

1.管道chan吞吐極限10,000,000，單次Put,Get耗時大約100ns/op，無論是采用單Go程，還是多Go程并發(fā)(并發(fā)數(shù):100, 10000, 100000)，耗時均沒有變化，Go內(nèi)核這對chan進行優(yōu)化。

解決之道：

在系統(tǒng)設(shè)計時，避免使用管道chan傳遞主業(yè)務(wù)數(shù)據(jù)，避免將業(yè)務(wù)流程處理流程分割到對個Go程中執(zhí)行，這樣做減少chan傳輸耗時，和Go程調(diào)度耗時，性能會有很大的提升。

案例分析：nsq和nats都是實時消息隊列，nsq在客戶端端和服務(wù)端大量使用chan轉(zhuǎn)發(fā)消息，導(dǎo)致性能不佳，只有100,000／s；而nats服務(wù)端在分發(fā)消息流程中，沒有使用chan，只在客戶端接收時使用chan，性能可達到1,000,000／s。

2.互斥鎖Mutex在單Go程時Lock,Unlock耗時大約20ns/op，但是采用多Go程時，性能急劇下降，并發(fā)越大耗時越長，在Go1.5并發(fā)數(shù)達到1024耗時900ns/op，Go1.6優(yōu)化到300ns/op，究其原因，是構(gòu)建在CPU的原子操作之上，搶占過于頻繁將導(dǎo)致，消耗大量CPU時鐘，進而CPU多核無法并行。

解決之道：

采用分區(qū)，將需要互斥保護的數(shù)據(jù)，分成多個固定分區(qū)(建議是2的整數(shù)倍，如256)，訪問時先定位分區(qū)(不互斥)，這樣就可降低多個Go程競爭1個數(shù)據(jù)分區(qū)的概率。

案例分析：Golang的Go程調(diào)度模塊，在管理大量的Go程，使用的就是數(shù)據(jù)分區(qū)。

3.select異步操作在單管道時耗時120ns/op，但是隨著管道數(shù)增加，性能線性下降，每增加1個管道增加100ns/op，究其原因，slelect時當(dāng)chan數(shù)超過1后，Go內(nèi)部是創(chuàng)建一個Go程，有它每1ms輪訓(xùn)的方式檢查每個chan是否可用，而不是采用事件觸發(fā)。