golang отправляет json на многоадресный ip

Я пишу кусок Go для отправки данных json по многоадресному UDP:

func send(a string, messages chan interface{}) {
    addr, err := net.ResolveUDPAddr("udp", a)
    CheckError(err)
    c, err := net.DialUDP("udp", nil, addr)
    CheckError(err)
    for {
        msg := <-messages
        myjson, err := json.Marshal(msg)
        if err != nil {
            fmt.Println("Error encoding JSON")
        return
        }
        //Write to bytes to multicast UDP
        c.Write([]byte(myjson))

        time.Sleep(2 * time.Second)
    }
}

Итак, мой json преобразуется в массив байтов, чтобы он работал. Вот моя функция "приемника":

func serveMulticastUDP(a string, messages chan interface{}) {

    addr, err := net.ResolveUDPAddr("udp", a)
    CheckError(err)
    l, err := net.ListenMulticastUDP("udp", nil, addr)
    l.SetReadBuffer(maxDatagramSize)
    for {
        b := make([]byte, maxDatagramSize)
        n, src, err := l.ReadFromUDP(b)
        if err != nil {
            log.Fatal("ReadFromUDP failed:", err)
        }
        s := string(b[:n])//here is my problem, I want s to be map[string]interface before sending in my channel
        messages<-s
        log.Println(s)
        log.Println(src)
        log.Println(n)
        //h(src, n, b)
    }
}

Как преобразовать массив байтов в интерфейс map [string] (json)?


go arrays json multicast gorilla
person r3dlight    schedule 02.12.2015    source источник

Ответы (1)


arrow_upward
5
arrow_downward

В своем коде вы использовали json.Marshal() для преобразования вашего значения в текст JSON ([]byte).

Другое направление ([]byte -> значение) может быть выполнено с помощью json.Unmarshal(). json.Unmarshal() ожидает []byte, поэтому вам даже не нужно преобразовывать его в string.

См. Этот пример:

data := []byte(`{"key1":"value1","key2":123}`)

var m map[string]interface{}
if err := json.Unmarshal(data, &m); err != nil {
    panic(err)
}

fmt.Printf("%+v", m)

Вывод (попробуйте на Go Playground):

map[key1:value1 key2:123]

Примечания:

Результатом маршалинга (json.Marshal()) является значение типа []byte, поэтому здесь явное преобразование не требуется:

c.Write([]byte(myjson))

Вы можете просто написать:

c.Write(myjson)

Также при демаршалинге убедитесь, что вы передали b[:n] в json.Unmarshal(), так как остальная часть фрагмента содержит 0 (что предлагает ваша вторая ошибка), но они не являются частью текста json!

person icza    schedule 02.12.2015
comment
Спасибо icza, теперь у меня есть другая проблема, она вызывает панику при демаршалинге моего байтового массива: неожиданный конец ввода json. Следует ли мне открыть новый вопрос с более подробной информацией? - person r3dlight; 02.12.2015
comment
Это означает, что []byte, который вы передаете json.Unmarshal(), не является полным текстом в кодировке JSON. Он мог быть даже пустым. Убедитесь, что он содержит весь текст json (проверьте его содержимое). - person icza; 02.12.2015
comment
Я понимаю (мой json довольно большой по сравнению с UDP), не могли бы вы предложить мне способ правильно проверить контент? - person r3dlight; 02.12.2015
comment
@ r3dlight Просто распечатайте его, например fmt.Println(n, string(b[:n]), b[:n]). - person icza; 02.12.2015
comment
Хорошо, сначала я увеличил свой maxDatagramSize до 18000. Затем я напечатал, как вы предложили: 16115 {...} [...] Кажется, он готов, но теперь я паникую с паникой: недопустимый символ '\ x00' после вершины -уровневое значение - person r3dlight; 02.12.2015
comment
@ r3dlight Убедитесь, что вы передали b[:n] в json.Unmarshal(), так как остальная часть фрагмента содержит 0s (что предлагает ваша ошибка), но они не являются частью текста json! - person icza; 02.12.2015