寻求适用于TCP套接字的C++流式JSON解析器

我太懂你遇到的这个头疼问题了！TCP是字节流特性，大JSON会被拆成碎块分批传输，要是接一点数据就急着解析，肯定会触发畸形JSON的错误，必须得有个能「攒数据、续着解析」的工具才行。下面给你推荐几个主流语言的靠谱方案，以及通用的实现思路：

主流语言工具推荐 #

Python：ijson #

这是专门做流式JSON解析的库，完美适配你的需求。它能从字节流里逐步读取数据，维护解析状态，你只需要维护一个缓冲区，每次新数据进来就追加进去，然后用ijson尝试解析：

• 当缓冲区里的内容不够组成完整JSON时，它会暂停解析，等你追加新数据后继续
• 一旦解析出完整的JSON对象，你就能拿到结果，然后把缓冲区里已经解析完成的部分移除，剩下的内容留着等下一批数据

简单示例代码思路：

import ijson
import socket
import json

buffer = b''
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('your-server', 1234))

while True:
    data = sock.recv(4096)
    if not data:
        break
    buffer += data
    # 尝试解析缓冲区里的JSON对象
    parser = ijson.parse(buffer)
    try:
        for prefix, event, value in parser:
            if event == 'end_map':  # 捕获JSON对象的结尾标识
                # 截取完整JSON内容并处理
                end_idx = buffer.rfind(b'}') + 1
                full_json = buffer[:end_idx]
                obj = json.loads(full_json)
                print("解析到完整对象:", obj)
                # 更新缓冲区，保留未解析的剩余部分
                buffer = buffer[end_idx:]
                break
    except Exception:
        # 解析失败说明数据还不完整，继续等待下一批数据
        pass

JavaScript/Node.js：JSONStream #

Node.js里的JSONStream可以直接和TCP流对接，它会自动处理分片数据，监听流的data事件时增量解析，一旦找到完整的JSON就触发回调，完全不用手动管理缓冲区：

const net = require('net');
const JSONStream = require('JSONStream');

const client = net.connect({ port: 1234 }, () => {
  console.log('已连接到服务器');
});

// 将TCP流直接导入JSONStream解析器
client.pipe(JSONStream.parse('*')).on('data', (obj) => {
  console.log('解析到完整对象:', obj);
});

Go语言：标准库encoding/json的Decoder #

Go的标准库其实自带了增量解析能力，json.Decoder类型会从io.Reader（比如TCP连接）里自动读取数据并维护内部缓冲区，你只需要循环调用Decode()即可：

package main

import (
	"encoding/json"
	"net"
)

// 定义你需要反序列化的结构体
type YourTargetStruct struct {
	// 填充你的字段定义
	Name string `json:"name"`
	Age  int    `json:"age"`
}

func main() {
	conn, err := net.Dial("tcp", "your-server:1234")
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	decoder := json.NewDecoder(conn)
	for {
		var obj YourTargetStruct
		err := decoder.Decode(&obj)
		if err != nil {
			// 连接关闭或解析出错时退出循环
			break
		}
		println("解析到完整对象:", obj.Name, obj.Age)
	}
}

Decoder会自动处理TCP分片，直到凑出完整的JSON才会返回结果，省心又靠谱。

通用实现思路（无现成工具时） #

如果你的语言没有合适的第三方库，自己实现核心逻辑也不难：

• 维护一个字节缓冲区，每次收到新数据就追加到缓冲区末尾
• 尝试从缓冲区开头解析JSON：
  • 若解析成功，取出完整JSON内容，将缓冲区更新为「剩余未解析的部分」
  • 若解析报错为「JSON未完成」（比如缺少闭合的}/]、字符串未结束），则停止解析，等待下一批数据
• 注意处理多个连续JSON对象的场景，解析完一个后要继续检查缓冲区剩余内容，判断是否存在下一个完整JSON

其实很多语言的JSON解析库都内置了流式/增量解析能力，就像你提到的Java Streaming API，其他语言基本都有对应实现，优先选择官方或成熟第三方库，比自己造轮子高效得多。

内容的提问来源于stack exchange，提问作者Flashito