处理程序中的无限 for 循环的处理

在处理程序中创建无限 `for` 循环时，当通道操作（写入或读取）被阻塞时，循环可能会停止运行。本文探讨了这一问题，重点关注 `s.broadcaster <- payload.Username` 行。通过从通道获取值，此行会导致阻塞，阻止无限循环正常运行。

我很难理解我使用博客所做的事情的实现

我正在创建一个新的 websocket 连接，其中我正在运行无限循环

据我了解

• 无论 websocket 收到什么消息，无限循环都应该无限期地运行

但事实并非如此，只有当从前端 ws 连接发送“新的负载/消息”时才会触发其中的逻辑：

func (s *SocketHandlers) NewConnectionHandler(w http.ResponseWriter, r *http.Request) {
    // upgrade the http request to a ws request
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer ws.Close()
    for { // infinite loop
        log.Println("Checking to see if this repeats") // <=== PRINTS ONLY ONCE!
        var payload core.NewSessionPayload
        if err := ws.ReadJSON(&payload); err != nil {
            log.Println("Cannot read socket conection payload")
            log.Fatal(err)
        }
        s.clientsMap[ws] = core.ClientNode{
            Active:   true,
            Username: payload.Username,
        }
        // broadcast the latest users list to all the users
        s.broadcaster <- payload.Username
    }
}

正确答案

重点在这里s.broadcaster <-payload.Username 它试图从通道获取值。

您可以在此处阅读有关频道的更多信息 https://gobyexample.com/channels。

通道操作（即写入或读取）本质上是阻塞的。

这意味着：

• 当我们使用 GoRoutine 向通道发送数据时，它会被阻塞，直到数据被另一个 GoRoutine 消耗为止。
• 当我们使用 GoRoutine 从通道接收数据时，它将被阻塞，直到通道中的数据可用为止。

到这里，我们也就讲完了《处理程序中的无限 for 循环的处理》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！