Bagaimana untuk mendapatkan data json dari sambungan golang

Kandungan soalan

Saya menggunakan sambungan tcp yang ditulis dalam golang untuk menghantar permintaan curl daripada konsol. Jadi pada asasnya ia adalah aliran data. Saya berjaya menerima data dan menyimpannya dalam penimbal menggunakan kod berikut

func PushDataToBuffer(bufferedChannel chan []byte, conn net.Conn) {
    defer conn.Close()
    fmt.Println("pushing messages into buffer...")

    buffer := make([]byte, 2048) // 2048 = assumption for reasonable event byte size

    for {
        n, err := conn.Read(buffer)
        if err != nil {
            fmt.Println("read error: ", err)
            continue // to continue listening for connections
        }
        bufferedChannel <- buffer[:n]
    }
}

Tetapi apabila saya cuba membaca data ini menggunakan kod ini:

for data := range bufferedChannel {
    fmt.Println("The len of buffer is: ", len(bufferedChannel))
    dataObject := models.Event{}
    err := json.Unmarshal(data, &dataObject)
}

Saya mendapat ralat berikut

Invalid character 'P' looking for beginning of value
2024/01/29 09:40:31 syntax error at byte offset 1

Apabila saya mencetak data itu sendiri, saya melihat ini

POST / HTTP/1.1
Host: localhost:8952
User-Agent: curl/7.77.0
Accept: */*
Content-Type: application/json
Content-Length: 232

{\"customer\":\"Ada\",\"eventtype\":\"BuyingApples\",\"time\":\"0001-01-01T00:00:00Z\",\"specifics\":[{\"Key\":\"Shop\",\"Value\":\"Bakery\"},{\"Key\":\"Location\",\"Value\":\"Downtown\"},{\"Key\":\"recommends\",\"Value\":\"yes\"}]}

Daripada perkara di atas anda dapat melihat dengan jelas di mana masalahnya. Ia menambah pengepala pada data, jadi POST 中的 P itulah yang golang mengadu. Itulah sebabnya saya tidak boleh membongkarnya. Jadi soalan saya ialah ini: Bagaimanakah saya boleh menghantar data ke pelayan atau memangkasnya apabila ia tiba, semua yang saya akan gunakan ialah bahagian json:

{\"customer\":\"Ada\",\"eventtype\":\"BuyingApples\",\"time\":\"0001-01-01T00:00:00Z\",\"specifics\":[{\"Key\":\"Shop\",\"Value\":\"Bakery\"},{\"Key\":\"Location\",\"Value\":\"Downtown\"},{\"Key\":\"recommends\",\"Value\":\"yes\"}]}

P.S - Saya menggunakan sambungan tcp untuk mendapatkan data dan bukannya http

Saya mencari dalam talian untuk pelbagai penyelesaian tetapi tidak menemui satu yang sesuai dengan kes penggunaan saya

Jawapan betul

cURL bukan klien TCP. Ia adalah klien HTTP dan secara semula jadi menjana beberapa pengepala asli kepada protokol (seperti kaedah permintaan dan laluan). Inilah yang akhirnya dihantar melalui sambungan TCP. Oleh itu, terdapat ketidakpadanan antara apa yang pelayan jangkakan (TCP biasa) dan apa yang dihantar oleh pelanggan (HTTP).

Anda harus mengemas kini kod pelayan anda untuk menghuraikan data mentah ke dalam permintaan HTTP, seperti http .ReadRequest, atau hanya menggunakan klien yang menghantar muatan yang dijangkakan melalui rangkaian - iaitu TCP tulen. Netcat akan memudahkan ini. Tanpa mengetahui banyak tentang masalah yang anda cuba selesaikan, saya akan secara lalai mengesyorkan pendekatan yang terakhir (kerana mengapa menghantar HTTP apabila anda memerlukan TCP di tempat pertama?).

Atas ialah kandungan terperinci Bagaimana untuk mendapatkan data json dari sambungan golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!