从网络接收XML流数据时，常会遇到连接中断、数据格式错误或服务暂时不可用等问题。C#中可通过结合 XmlReader、HttpClient 和重试逻辑来实现稳定的数据解析与容错处理。
实时解析XML流并处理异常
使用 HttpClient 获取网络流，并通过 XmlReader 逐节点读取，避免一次性加载全部内容，适合大体积或持续传输的XML流。
关键点是将网络流直接传给 XmlReader，同时捕获可能发生的异常，如网络超时、XML格式错误等。
using var client = new HttpClient();
try
{
using var stream = await client.GetStreamAsync("https://example.com/data.xml");
using var xmlReader = XmlReader.Create(stream);
while (xmlReader.Read())
{
if (xmlReader.NodeType == XmlNodeType.Element)
{
// 处理元素逻辑
Console.WriteLine($"读取节点: {xmlReader.Name}");
}
}
}
catch (HttpRequestException httpEx)
{
Console.WriteLine($"网络请求失败: {httpEx.Message}");
}
catch (XmlException xmlEx)
{
Console.WriteLine($"XML格式错误: {xmlEx.Message}");
}
catch (TaskCanceledException timeoutEx)
{
Console.WriteLine($"请求超时: {timeoutEx.Message}");
}
加入重试机制提升稳定性
网络环境不稳定时，简单的异常捕获不足以保障连续性。应引入重试策略，在发生可恢复错误时自动尝试重新连接。
可用 Polly 库实现灵活的重试控制，例如指数退避策略。
var retryPolicy = Policy
.Handle<HttpRequestException>()
.Or<TaskCanceledException>()
.WaitAndRetryAsync(3, attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)));
await retryPolicy.ExecuteAsync(async () =>
{
using var stream = await client.GetStreamAsync("https://example.com/data.xml");
using var xmlReader = XmlReader.Create(stream);
while (xmlReader.Read())
{
if (xmlReader.NodeType == XmlNodeType.Element)
{
Console.WriteLine($"节点: {xmlReader.Name}");
}
}
});
流中断后的恢复建议
若XML流是持续推送型（如服务器发送事件），单次重连可能导致数据丢失。此时可记录已处理的标识（如ID或时间戳），并在重连时传递参数请求增量数据。
部分服务支持断点续传，可在HTTP头中使用 If-Modified-Since 或自定义查询参数实现。
var requestUri = "https://example.com/stream.xml?since=1720000000"; // 结合上次成功处理的时间或序列号基本上就这些。配合良好的日志记录，能进一步帮助定位问题。不复杂但容易忽略细节。
