C# 实现 AI SSE （Server-Sent Events）接口方式输出（对接AI模型API）

以下是一个使用 C# 实现接收 SSE（Server-Sent Events）接口数据、进行数据修改解析，然后再以 SSE 方式输出给前端的示例代码。

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(){// 设置响应头以支持 SSEResponse.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}";}
}    

代码说明

1. 设置响应头：在 Get 方法中，设置了必要的响应头，以确保响应是 SSE 格式。
2. 模拟 SSE 数据源：使用 HttpWebRequest 从模拟的 SSE 数据源获取数据。
3. 数据修改解析：在 ModifyData 方法中，可以添加具体的数据修改逻辑。这里只是简单地在原始数据前添加了 Modified: 。
4. 以 SSE 格式发送数据：将修改后的数据以 SSE 格式发送到前端。

注意事项

• 请将 sseSourceUrl 替换为实际的 SSE 数据源 URL。
• 此示例是一个简单的控制台应用程序，在实际应用中，你可能需要将其集成到 ASP.NET Core 项目中。