欧美主播一区二区三区美女久久精品人,久久久午夜视频,国产亚洲成人一区

grpc-go與actor模式

grpc-go與actor模式

(金慶的專欄 2018.6)

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

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

   ...
}

// Run 運行房間協程.
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 將一個動作投遞到內部協程中執行.
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 金慶閱讀(842) 評論(0) 編輯收藏引用所屬分類: 9. 其它、3. Golang

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

相關文章: 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

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜