欧美日本视频在线,在线观看视频日韩,亚洲欧美在线播放

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

只有注冊用戶登錄后才能發表評論。


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

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜