C#实现AI SSE(Server-Sent Events)接口方式输出过程(对接AI模型API)

using System;
using System.IO;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;

// 模拟一个控制器，在实际应用中可以根据具体需求调整
[ApiController]
[Route("[controller]")]
public class SseController : ControllerBase
{
    [HttpGet]
    public async Task Get()
    {
        // 设置响应头以支持 SSE
        Response.Headers.Add("Content-Type", "text/event-stream");
        Response.Headers.Add("Cache-Control", "no-cache");
        Response.Headers.Add("Connection", "keep-alive");

        // 模拟一个 SSE 数据源
        var sseSourceUrl = "https://example.com/sse-source";
        var request = (HttpWebRequest)WebRequest.Create(sseSourceUrl);

        using (var response = (HttpWebResponse)await request.GetResponseAsync())
        using (var stream = response.GetResponseStream())
        using (var reader = new StreamReader(stream))
        {
            string line;
            while ((line = await reader.ReadLineAsync()) != null)
            {
                // 这里可以对数据进行修改解析
                var modifiedData = ModifyData(line);

                // 以 SSE 格式发送数据到前端
                var sseData = $"data: {modifiedData}\n\n";
                var buffer = Encoding.UTF8.GetBytes(sseData);
                await Response.Body.WriteAsync(buffer, 0, buffer.Length);
                await Response.Body.FlushAsync();
            }
        }
    }

    // 模拟数据修改解析的方法
    private string ModifyData(string input)
    {
        // 这里可以添加具体的数据修改逻辑
        return $"Modified: {input}";
    }
}