在EventSource中使用System.Exception对象

using System;
using System.Text.Json;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;

public class EventSourceHandler
{
    public async Task GetEventSource(HttpContext context)
    {
        context.Response.ContentType = "text/event-stream";
        context.Response.Headers.Add("Cache-Control", "no-cache");
        context.Response.Headers.Add("Connection", "keep-alive");

        while (true)
        {
            try
            {
                // 模拟一些操作，可能会抛出异常
                throw new Exception("这是一个测试异常");

                // 如果没有异常，发送正常数据
                var data = new { Message = "正常数据" };
                await context.Response.WriteAsync($"data: {JsonSerializer.Serialize(data)}\n\n");
            }
            catch (Exception ex)
            {
                // 捕获异常并序列化
                var errorData = new { Error = ex.Message };
                await context.Response.WriteAsync($"data: {JsonSerializer.Serialize(errorData)}\n\n");
            }

            await Task.Delay(1000); // 每秒发送一次
        }
    }
}