当前位置：首页 > 文章列表 > Golang > Go问答 > 在 goroutine 中关闭连接

在 goroutine 中关闭连接

来源：stackoverflow 2024-02-24 15:09:27 0浏览收藏

Golang小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《在 goroutine 中关闭连接》带大家来了解一下##content_title##，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

问题内容

我正在编写一个与套接字服务器连接的简单 go 程序。我正在使用 goroutine 不断查找传入的消息。但在 goroutine 内部连接被关闭。有人可以告诉我发生了什么吗？

下面是我的测试客户端

package main

import (
    "fmt"
    "net"
    "os"
    "encoding/json"
    "bufio"
)

type test_user struct {
    ID string
    Conn net.Conn
    Messages chan interface{}
}

func CreateTestUser(id string) test_user {
    return test_user{id, nil, nil}
}

/* 
1. Try connecting
2. Wait for connected packet
3. Send first packet (Init packet)
*/
func (user *test_user) Connect() {
    conn, err := net.Dial(CONN_TYPE, CONN_HOST+":"+CONN_PORT)
    if err != nil {
        fmt.Println("Could not connect", err.Error())
        os.Exit(1)
    }
    user.Conn = conn
    user.Messages = make(chan interface{})
    reader := bufio.NewReader(conn)
    message, _ := reader.ReadBytes(DELIMITER)
    user.SendMessage(InitPacket{TYPE_USER,user.ID})
    //message, _ = reader.ReadBytes(DELIMITER)
    //message, _ = reader.ReadBytes(DELIMITER)  // If I uncomment these lines it will wait for new messages
    //message, _ = reader.ReadBytes(DELIMITER)
    go func() {
        for {
            var readErr error
            message, readErr = reader.ReadBytes(DELIMITER) // this always returns error "Error on read read tcp 127.0.0.1:54694->127.0.0.1:3333: use of closed network connection"/

            if readErr == nil {
                var packet interface{}
                error := json.Unmarshal(message, &packet)
                if error != nil {
                    fmt.Println("Unable to parse message", string(message), error.Error())
                }
                user.Messages <- packet
            } else {
                fmt.Println("Error on read", readErr.Error())
            }       
        }
    }()
}

有人可以帮我解决这个问题吗？另外，我是 golang 新手，也请提出改进建议。