精品国产乱码久久久久久呢,亚洲国产综合久久天堂,久久久久久久91精品免费观看

grpc-go與actor模式

grpc-go與actor模式

(金慶的專欄 2018.6)

grpc-go服務(wù)器的每個(gè)請(qǐng)求都在一個(gè)獨(dú)立的協(xié)程中執(zhí)行。
網(wǎng)游服務(wù)器中，一般請(qǐng)求會(huì)調(diào)用游戲房間的方法，而房間是一個(gè)獨(dú)立的協(xié)程。
可以將房間實(shí)現(xiàn)為actor，grpc請(qǐng)求通過(guò)Call()或Post()方法來(lái)執(zhí)行。
其中Call()會(huì)等待返回，而Post()會(huì)異步執(zhí)行無(wú)返回值。

type Room struct {
   // actC 是其他協(xié)程向Room協(xié)程發(fā)送動(dòng)作的Channel，協(xié)程中將依次執(zhí)行動(dòng)作。
   // Action 動(dòng)作, 是無(wú)參數(shù)無(wú)返回值的函數(shù).
   actC chan func()

   ...
}

// Run 運(yùn)行房間協(xié)程.
func (r *Room) Run() {
   ticker := time.NewTicker(20 * time.Millisecond)
   defer ticker.Stop()

   for r.running {
       select {
       case act := <-r.actC:
           act()
       case <-ticker.C:
           r.tick()
       }
   }
}

// Call calls a function f and returns the result.
// f runs in the Room's goroutine.
func (r *Room) Call(f func() interface{}) interface{} {
   // 結(jié)果從ch返回
   ch := make(chan interface{}, 1)
   r.actC <- func() {
       ch <- f()
   }
   // 等待直到返回結(jié)果
   return <-ch
}

// Post 將一個(gè)動(dòng)作投遞到內(nèi)部協(xié)程中執(zhí)行.
func (r *Room) Post(f func()) {
   r.actC <- f
}

grpc服務(wù)方法如：

func (m *RoomService) Test(ctx context.Context, req *pb.TestReq) (*pb.TestResp, error) {
   conn := conn_mgr.GetConn(ctx)
   if conn == nil {
       return nil, fmt.Errorf("can not find connection")
   }

   room := conn.GetRoom()
   resp := room.Call(func() interface{} {
       return room.Test(req)
   })

   return resp.(*pb.TestResp), nil
}

posted on 2018-06-12 11:15 金慶閱讀(829) 評(píng)論(0) 編輯收藏引用所屬分類: 9. 其它、3. Golang

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開(kāi)源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: TortoiseGit is OK but GitExtensions fails DeathVoteExpirationTimeout in Orleans How to delete local branches of GitExtension Clustering provider in Orleans Why Orleans' actor is virutal What comes after microservice? Rust Deref coercion example Rust Error Return Check Policy Rust visibility Why does Rust check borrow even in single thread

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜