C#實(shí)現(xiàn)AI SSE(Server-Sent Events)接口方式輸出過(guò)程(對(duì)接AI模型API)

更新時(shí)間：2025年07月09日 08:42:25 作者：炫愛(ài)小七

C#代碼接收SSE數(shù)據(jù),通過(guò)HttpWebRequest獲取并修改解析,再以SSE格式發(fā)送給前端,需替換數(shù)據(jù)源URL,示例為控制臺(tái)應(yīng)用,實(shí)際應(yīng)集成到ASP.NET Core項(xiàng)目

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

// 模擬一個(gè)控制器，在實(shí)際應(yīng)用中可以根據(jù)具體需求調(diào)整
[ApiController]
[Route("[controller]")]
public class SseController : ControllerBase
{
    [HttpGet]
    public async Task Get()
    {
        // 設(shè)置響應(yīng)頭以支持 SSE
        Response.Headers.Add("Content-Type", "text/event-stream");
        Response.Headers.Add("Cache-Control", "no-cache");
        Response.Headers.Add("Connection", "keep-alive");

        // 模擬一個(gè) SSE 數(shù)據(jù)源
        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)
            {
                // 這里可以對(duì)數(shù)據(jù)進(jìn)行修改解析
                var modifiedData = ModifyData(line);

                // 以 SSE 格式發(fā)送數(shù)據(jù)到前端
                var sseData = $"data: {modifiedData}\n\n";
                var buffer = Encoding.UTF8.GetBytes(sseData);
                await Response.Body.WriteAsync(buffer, 0, buffer.Length);
                await Response.Body.FlushAsync();
            }
        }
    }

    // 模擬數(shù)據(jù)修改解析的方法
    private string ModifyData(string input)
    {
        // 這里可以添加具體的數(shù)據(jù)修改邏輯
        return $"Modified: {input}";
    }
}

代碼說(shuō)明

設(shè)置響應(yīng)頭：在 Get 方法中，設(shè)置了必要的響應(yīng)頭，以確保響應(yīng)是 SSE 格式。
模擬 SSE 數(shù)據(jù)源：使用 HttpWebRequest 從模擬的 SSE 數(shù)據(jù)源獲取數(shù)據(jù)。
數(shù)據(jù)修改解析：在 ModifyData 方法中，可以添加具體的數(shù)據(jù)修改邏輯。這里只是簡(jiǎn)單地在原始數(shù)據(jù)前添加了 Modified: 。
以 SSE 格式發(fā)送數(shù)據(jù)：將修改后的數(shù)據(jù)以 SSE 格式發(fā)送到前端。