XML流解析不能用DOM，因其需将整个文档加载至内存构建树，大文件或持续流易致OOM；必须用SAX或StAX等事件驱动模型实现边读边转。
XML流解析为什么不能用DOM
DOM会把整个XML加载进内存再构建树，遇到大文件或持续输入的流（比如HTTP chunked响应、Kafka消息、日志管道）直接OOM。实时映射的前提是「边读边转」，必须用SAX或StAX这类事件驱动模型。
常见错误现象：OutOfMemoryError、解析卡在DocumentBuilder.parse()、延迟突增且不可预测。
- SAX是只读、单向、无状态的，适合纯转换（如XML→JSON、XML→数据库INSERT）
- StAX（
XMLStreamReader）支持双向游标和部分回退，更适合需要条件跳过或局部重读的场景 - 不要在SAX
startElement()里缓存全部characters()——文本可能被分多次回调，需用StringBuilder累积
用StAX做字段级实时映射（Java示例）
StAX的XMLStreamReader能精确控制读取节奏，配合switch状态机可实现字段到目标结构的即时投射，比如映射到Map或自定义DTO。
关键点：不是“解析完再映射”，而是「每读到一个START_ELEMENT，立刻提取属性+下一段文本，构造中间对象并触发下游处理」。
- 用
hasNext()+next()而非nextEvent()，避免跳过事件 -
getElementText()会自动消费后续CHARACTERS和END_ELEMENT，但无法处理混合内容（如abcdefghi
next() - 属性值用
getAttributeValue(null, "attrName")，第一个参数为null表示忽略命名空间
XMLInputFactory factory = XMLInputFactory.newInstance();
XMLStreamReader reader = factory.createXMLStreamReader(inputStream);
while (reader.hasNext()) {
int event = reader.next();
if (event == XMLStreamConstants.START_ELEMENT) {
String localName = reader.getLocalName();
if ("user".equals(localName)) {
String id = reader.getAttributeValue(null, "id");
String name = reader.getElementText(); // 读取紧随其后的文本
Map mapped = Map.of("id", id, "name", name);
processRealtime(mapped); // 实时投递，不等待文档结束
}
}
}
Python中用xml.sax处理流式映射
Python标准库xml.sax是纯事件回调，没有游标控制，但轻量、稳定，适合嵌入式或低资源环境。难点在于状态维护——你得自己记住当前路径、是否在目标元素内、文本归属哪个字段。
容易踩的坑：characters()回调可能在任意startElement()/endElement()之间触发，且内容可能为空白或换行；不清理self._buffer会导致字段值错位。
- 用栈（
self._path）记录元素嵌套路径，比硬编码if tag == "name"更健壮 -
startElement()中清空self._buffer，characters()中追加，endElement()中根据路径提取并重置 - 不要在
characters()里直接处理数据——它可能被多次调用，必须等endElement()确认闭合才提交
import xml.sax
class StreamingMapper(xml.sax.ContentHandler):
def __init__(self, callback):
self._callback = callback
self._path = []
self._buffer = []
def startElement(self, name, attrs):
self._path.append(name)
self._buffer = []
def characters(self, content):
if self._path and self._path[-1] in ("id", "email"):
self._buffer.append(content.strip())
def endElement(self, name):
if name in ("id", "email") and self._buffer:
value = "".join(self._buffer)
if name == "id":
self._current_id = value
elif name == "email":
self._callback({"id": getattr(self, "_current_id", ""), "email": value})
self._path.pop()
映射过程中如何处理错误与中断
流式解析一旦出错（如格式错误、编码不匹配、网络断连），无法像DOM那样“重试整个文档”。必须设计可恢复的边界——通常以END_ELEMENT对应顶层元素为单位，失败则丢弃当前记录，继续下一个。
典型错误：XMLStreamException（StAX）、SAXParseException（Python/Java SAX）、UnicodeDecodeError（输入流编码非UTF-8但未声明）。
- StAX中捕获
XMLStreamException后，调用reader.close()并重建新XMLStreamReader，从原始流当前位置继续（需流支持mark/reset） - Python
xml.sax无法从中断点恢复，建议用io.BytesIO包裹分块数据，每块独立解析 - 所有映射逻辑必须幂等——下游系统要能接受重复或乱序到达的记录
最易被忽略的是编码声明与实际字节流不一致，比如XML声明但HTTP头返回Content-Type: text/xml; charset=ISO-8859-1，这时StAX会按UTF-8解码导致MalformedByteSequenceException——务必用InputStreamReader显式指定编码，别依赖自动探测。
