Соединение закрывается внутри программы

Question

Я пишу простую go программу, которая соединяется с сервером сокетов. Я использую 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, чтобы предложить также улучшения.

Answer 1

Было бы полезно увидеть немного больше вашего кода за пределами Connect.

Connect запускает новую программу, но она не ждет ее - она ​​немедленно возвращается. Может ли соединение быть закрыто после возврата Connect?

Как правило, когда вы запускаете программу для обработки соединения, ваша «основная» программа будет продолжать ждать других вещей - новых соединений и / или некоторого рукопожатия с -подключение Я подозреваю, что это не то, что здесь происходит.