不立即响应 GET 请求，它会在代码完成时响应答案

【问题标题】：Go not responding to GET request instantly, it response when ticker is done不立即响应 GET 请求，它会在代码完成时响应
【发布时间】：2018-05-11 10:40:54
【问题描述】：

我是 Go 编程新手，我尝试为多人游戏构建 API。如果我向 http://localhost:8080/create_game/gameName 发出 GET 请求。自动收报机完成时服务器对请求的响应。我需要立即从服务器获得响应，但是当代码结束并且游戏超时并被删除时我得到了它。

这是我的代码：

var clients = make(map[*websocket.Conn]bool)
var broadcast = make(chan Game)

//GAME_TIMEOUT in seconds
const GAME_TIMEOUT = 20

//ID generating
var genID = 0

var games = []Game{}

var msg json.RawMessage

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
    CheckOrigin: func(r *http.Request) bool {
        return true
    },
}

type GameToSend struct {
    Type string `json:"type"`
    ID   int    `json:"id"`
    Name string `json:"name"`
}
type Game struct {
    ID    int              `json:"id"`
    Name  string           `json:"name"`
    Timer <-chan time.Time `json:"timestamp"`
}

func main() {
    router := mux.NewRouter()
    router.HandleFunc("/create_game/{name}", createGame)
    router.HandleFunc("/game_events", handleConnections)
    http.ListenAndServe(":8080", router)
}

func handleConnections(w http.ResponseWriter, r *http.Request) {

    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()
    clients[conn] = true
    for _, game := range games {
        conn.WriteJSON(GameToSend{"game.created", game.ID, game.Name})
    }
    for {
        err := conn.ReadJSON(&msg)
        if err != nil {
            fmt.Println(err)
        } else {
            fmt.Println(msg)
        }
    }
}

func broadcastGame(game GameToSend) {
    for conn := range clients {
        conn.WriteJSON(game)
    }
}

func createGame(w http.ResponseWriter, r *http.Request) {
    params := mux.Vars(r)
    genID++
    game := Game{genID, params["name"], time.NewTimer(GAME_TIMEOUT * time.Second).C}
    games = append(games, game)
    broadcastGame(GameToSend{"game.created", game.ID, game.Name})
    w.Write([]byte("response"))
    checkTimeout(genID)
}

func deleteGame(actionType string, i int) {
    for index, game := range games {
        if game.ID == i {
            broadcastGame(GameToSend{actionType, games[index].ID, games[index].Name})
            games = games[:index+copy(games[index:], games[index+1:])]
        }
    }
}

func checkTimeout(id int) {
    for _, game := range games {
        if game.ID == id {
            <-game.Timer
            deleteGame("game.timeout", id)
        }
    }
}

知道怎么解决吗？

【问题讨论】：

1) 不要混淆 Timer 和 Ticker。 2) 您明确地等待所有计时器以<-game.Timer 到期。如果你不想那样做，好吧，不要那样做。不过，目前尚不清楚您的意图是什么，因此很难推荐具体的更改。
我的问题是，无论定时器是否过期，如何立即从服务器获得响应，当定时器结束时执行该功能而不等待它的另一种写法是什么？跨度>
做到这一点的方法不止一种。如果您不需要在其他任何地方访问计时器，time.AfterFunc 是一个明显的选择。您也可以在自己的goroutine 中运行 checkTimeout。

标签： api go ticker

【解决方案1】：

您可以更改许多内容，但其中之一是通常不要在响应客户端的代码中运行可能长时间运行的任务。想象一下，您有数百万个游戏，数量之多以至于每次调用checkTimeout 都需要一秒钟来遍历所有游戏。每个请求都会有一秒钟的延迟才能获得完整的响应，这不是很好。最好通知另一个 goroutine 遍历游戏并清理过期的游戏，这样您就可以在后台进行清理时立即返回客户端。

原来我误读了你在做什么，但建议仍然有效。在这种情况下，尽管“长时间运行的函数”实际上会等到计时器到期后再返回。这可能比一秒长得多！你的意思是在 goroutine 中运行它吗？ go checkTimeout(genID)

【讨论】：