最近我們項(xiàng)目里遇到了一個(gè)很奇怪的問題，就是在使用go語言處理json stream流數(shù)據(jù)時(shí)，程序經(jīng)常出現(xiàn)崩潰的情況。經(jīng)過排查，最終發(fā)現(xiàn)了程序內(nèi)部的bug是導(dǎo)致這個(gè)問題的根源。

我們的程序會(huì)從一個(gè)數(shù)據(jù)源獲取json stream流數(shù)據(jù)，然后對(duì)每一個(gè)json object進(jìn)行處理。由于采用了go語言處理，因此我們選擇了標(biāo)準(zhǔn)庫里的json.Decoder來進(jìn)行流式數(shù)據(jù)的讀取。具體代碼如下：

dec := json.NewDecoder(inputStream)
for {
var obj map[string]interface{}
err := dec.Decode(&obj)
if err == io.EOF {
break
}
// 對(duì)obj進(jìn)行進(jìn)一步的處理
}

看起來這段代碼沒有什么問題，但是在數(shù)據(jù)量比較大的時(shí)候，程序會(huì)經(jīng)常出現(xiàn)崩潰的情況。經(jīng)過排查，我們發(fā)現(xiàn)了問題所在，就是在處理json object時(shí)，有些json object的值不是map[string]interface{}類型，而是其他類型，例如string或者int。

這時(shí)候，json.Decoder在讀取這些不合法的json object時(shí)，會(huì)出現(xiàn)panic。具體代碼如下：

err := dec.Decode(&obj)
if err != nil {
panic(err)
}

為了解決這個(gè)問題，我們需要在處理json object之前，進(jìn)行類型判斷。具體代碼如下：

dec := json.NewDecoder(inputStream)
for {
var obj interface{}
err := dec.Decode(&obj)
if err == io.EOF {
break
}
objMap, ok := obj.(map[string]interface{})
if !ok {
continue
}
// 對(duì)objMap進(jìn)行進(jìn)一步的處理
}

通過這樣的處理方式，我們可以過濾掉不合法的json object，避免了程序崩潰的問題。

總之，在使用go語言進(jìn)行json stream流數(shù)據(jù)處理時(shí)，我們需要格外小心，要時(shí)刻注意數(shù)據(jù)的格式和類型，避免不合法的數(shù)據(jù)導(dǎo)致程序崩潰。