Получение ошибки (gob: неизвестный идентификатор типа или поврежденные данные) при попытке декодировать большой двоичный объект с помощью gob.Decoder ()

Question

Я пытаюсь отправить закодированный большой двоичный объект в список локальных одноранговых узлов (код клиента, прослушивающий несколько портов на локальном компьютере), в одноранговых узлах, когда я декодирую большой двоичный объект для некоторых одноранговых узлов, он работает, а для некоторых -не появляется и отображает ошибку (gob: неизвестный идентификатор типа или поврежденные данные), как я могу решить эту проблему?

//My blob struct
type packet struct {
    Nodes []a1.Node
    Ledger *a1.Block
    ActionType string
}


//Encoding Part
    for i:=1; i<len(ConnectedNodes);i++{
        var blob packet
        blob.Ledger = Ledger
        blob.ActionType = "AddBlock"
        blob.Nodes = []a1.Node{}
        conn, err := net.Dial("tcp", "localhost"+":"+ConnectedNodes[i].Port)
        if err != nil {
            // handle error
            fmt.Println("Error At Client In Making A Connection (sending New Block to client "+ ConnectedNodes[i].Name +")")
        }
        //sending request type to client
        _, _ = conn.Write([]byte("newblock add "))
        //sending data to the client node
        //gob.Register(blob)
        encoder := gob.NewEncoder(conn)
        error := encoder.Encode(blob)
        if error != nil {
            log.Fatal(error)
        }
    }

//Decoding Part running on another peer
//adds new block to the Ledger

//Recieving incoming data
    recvdSlice := make([]byte, 256)
    conn.Read(recvdSlice)
    RecievedData := string(recvdSlice)
    finalData := strings.Split(RecievedData, " ")

    if finalData[0] == "newblock"{
        var blob packet
        decoder := gob.NewDecoder(conn)
        err := decoder.Decode(&blob)
        if err != nil {
            fmt.Println("error at decoding New Block on client!")
            fmt.Println(err)
        }
        fmt.Println(Ledger.Hash)
        fmt.Println(blob.Ledger.Hash)
        if(bytes.Compare(Ledger.Hash, blob.Ledger.Hash)) == 0 {
            fmt.Println("Ledger is already updated !")
        }else{
            fmt.Println("New Block Added !")
            Ledger = blob.Ledger
        }
        a1.ListBlocks(Ledger)
        //SendingNewBlockToConnectedNodes()
    }

Answer 1

Отправитель записывает 13 байтов перед кодированием gob ("newblock add ").

Если получатель не считывает эти 13 байтов до декодирования гоба, то декодер будет не синхронизирован с потоком данных и сообщит об ошибке.

Метод чтения соединения возвращается, когда данныедоступно, фрагмент заполнен или произошла ошибка при чтении соединения. Игнорируя ошибки, вызов Read в соединении будет читать от 1 до len (recvdSlice) байтов соединения. Нет гарантии, что 13 байтов данных прочитаны, но на практике это часто происходит из-за хронометража.

Исправьте, прочитав только префикс перед декодированием гоба. Один из способов - разделить префикс новой строкой.

Измените код отправителя на:

 _, _ = conn.Write([]byte("newblock add \n"))

Измените код получателя на:

 br := bufio.NewReader(conn)
 receivedData, err := br.ReadString('\n')
 if err != nil {
     // handle error
 }
 finalData := strings.Split(receivedData, " ")

 if finalData[0] == "newblock"{
    var blob packet
    decoder := gob.NewDecoder(br) // <-- decode from the buffered reader
    err := decoder.Decode(&blob)

Другое исправлениеиспользовать кодек gob для префикса. Измените отправителя на:

    encoder := gob.NewEncoder(conn)
    if err := encoder.Encode("newblock add "); err != nil {
        // handle error
    }
    if err := encoder.Encode(blob); err != nil {
        // handle error
    }

Измените получателя на:

decoder := gob.NewDecoder(conn)
var receivedData string
if err := decoder.Decode(&receivedData); err != nil {
     // handle error
}
finalData := strings.Split(receivedData, " ")

if finalData[0] == "newblock"{
    var blob packet
    err := decoder.Decode(&blob)