Go - goroutines之间的高性能通信？

Question

我正在尝试用 Go 编写一个小型游戏服务器。我基本上从 WebSocket 库 (https://github.com/gorilla/websocket) 中复制了示例。

服务器每秒执行函数s.tick()，将当前时间发送给用户。当用户不执行任何操作时，这可以正常工作。

当用户加入、离开或发送消息时，信息将通过三个通道之一发送（每个操作一个通道）并执行相应的操作，但 s.tick() 要么跳过，要么延迟。我注意到，如果用户一直执行操作，s.tick() 将永远不会被调用。

这是输出：

Mon, 05 Dec 2016 20:19:11 CET
Mon, 05 Dec 2016 20:19:12 CET
Mon, 05 Dec 2016 20:19:13 CET
Mon, 05 Dec 2016 20:19:15 CET
Mon, 05 Dec 2016 20:19:16 CET
Mon, 05 Dec 2016 20:19:17 CET

-- users joining and leaving

Mon, 05 Dec 2016 20:19:25 CET
Mon, 05 Dec 2016 20:19:26 CET
Mon, 05 Dec 2016 20:19:27 CET
Mon, 05 Dec 2016 20:19:28 CET
Mon, 05 Dec 2016 20:19:29 CET

我试图检查是什么导致了操作之间的如此多的延迟（这些操作都不会花费很长时间），我唯一的想法是：

• 我的代码很糟糕（很可能）
• Go 的频道很慢

我检查了循环开始和 case 子句开始的时间，甚至从通道接收数据通常需要超过 200 毫秒。话虽如此，我该如何提高此解决方案的性能？我似乎无法让服务器以每秒 1 个滴答的速度正常工作，更不用说 60 次了。

下面是我的代码的sn-p：

type GameServer struct {
    players map[*Player]bool

    register   chan *Player
    unregister chan *Player

    broadcast chan []byte
}

func (s *GameServer) broadcastMessage(msg []byte) {
    for player := range s.players {
        player.messages <- msg
    }
}

func (s *GameServer) tick() {
    s.broadcastMessage([]byte(time.Now().Format(time.RFC1123)))
}

// question is mostly related to this function
func (s *GameServer) run() {
    for {
        select {
        case _ = <-time.NewTicker(time.Second).C:
            s.tick()
        case client := <-s.register:
            s.players[client] = true
        case client := <-s.unregister:
            delete(s.players, client)
        case msg := <-s.broadcast:
            s.broadcastMessage(msg)
        }
    }
}

Answer 1

试试这个：

type GameServer struct {
    players map[*Player]bool

    register   chan *Player
    unregister chan *Player

    broadcast chan []byte

    ticker *time.Ticker //use a single "global" *time.Ticker

}

func (s *GameServer) broadcastMessage(msg []byte) {
    for player := range s.players {
        player.messages <- msg
    }
}

func (s *GameServer) tick() {
    s.broadcastMessage([]byte(time.Now().Format(time.RFC1123)))
}

// question is mostly related to this function
func (s *GameServer) run() {
    for {
        select {
        case _ = <- s.Ticker.C: //use the "global" *time.Ticker instead of creating a new one every time
            s.tick()
        case client := <-s.register:
            s.players[client] = true
        case client := <-s.unregister:
            delete(s.players, client)
        case msg := <-s.broadcast:
            s.broadcastMessage(msg)
        }
    }
}

我不认为你想创造一个新的时间。每次调用 run 时都记下。以上应该可以解决您的问题。