国产精品午夜久久,国产精品一区二区久久精品,开心久久婷婷综合中文字幕

grpc-go與actor模式

grpc-go與actor模式

(金慶的專欄 2018.6)

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

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

   ...
}

// Run 運行房間協(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{} {
   // 結果從ch返回
   ch := make(chan interface{}, 1)
   r.actC <- func() {
       ch <- f()
   }
   // 等待直到返回結果
   return <-ch
}

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

grpc服務方法如：

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) 評論(0) 編輯收藏引用所屬分類: 9. 其它、3. Golang

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

相關文章: 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)站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜