我使用 golang 編寫的 tcp 連線從控制台發送curl 請求。所以它基本上是一個資料流。我可以使用以下程式碼成功接收資料並將其儲存在緩衝區中
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] } }
但是,當我嘗試使用此程式碼讀取此資料時:
for data := range bufferedChannel { fmt.Println("The len of buffer is: ", len(bufferedChannel)) dataObject := models.Event{} err := json.Unmarshal(data, &dataObject) }
我收到以下錯誤
Invalid character 'P' looking for beginning of value 2024/01/29 09:40:31 syntax error at byte offset 1
當我列印出資料本身時,我看到了這個
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\"}]}
從上面你可以清楚的看出問題出在哪裡了。它將標頭加入資料中,因此 POST
中的 P
是 golang 所抱怨的。這就是為什麼我無法解組它。所以我的問題是這樣的:
我如何將資料發送到伺服器,或在資料到達時對其進行修剪,我將使用的只是 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 - 我使用 tcp 連線來獲取資料而不是 http
我在網路上找了各種解決方案,但沒有找到適合我的用例的解決方案
cURL 不是 TCP 用戶端。它是一個 HTTP 用戶端,自然會產生一些協定本機的標頭(例如請求方法和路徑)。這就是最終透過 TCP 連線發送的內容。因此,伺服器期望的內容(普通 TCP)和客戶端發送的內容(HTTP)不符。
您應該更新伺服器程式碼,將原始資料解析為 HTTP 請求,例如 http .ReadRequest,或簡單地使用透過網路發送預期負載的客戶端 - 即純 TCP。 Netcat 將使這變得容易。在不太了解您要解決的問題的情況下,我預設推薦後一種方法(因為為什麼在首先需要 TCP 時發送 HTTP?)。
以上是如何從連接golang獲取json數據的詳細內容。更多資訊請關注PHP中文網其他相關文章!