当前位置：首页 > article >正文

C# .NetCore 使用 Flurl.Http 与 HttpClient 请求处理流式响应

article 2025/1/17 9:40:05

AI对话接口采用流式返回：

1、使用Flurl处理返回的数据流

using Flurl;
using Flurl.Http;

[HttpPost]
public async Task<string> GetLiushiChatLaw()
{
//1、请求参数，根据实际情况
YourModel request = new YourModel();string allStr = "";　　 string chatLawApiUrl = "http://请求地址";
//2、请求。接收类型流Stream,处理请求响应
using (var stream = await chatLawApiUrl.WithHeader("Content-Type", "application/json")
.SetQueryParams(new { access_token = "token" })
.PostJsonAsync(request)
.ReceiveStream())
{
// 逐块读取并处理响应内容
var buffer = new byte[102];
int bytesRead;

while ((bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length)) > 0)
{
// 3、结果转换为字符串
string content = System.Text.Encoding.UTF8.GetString(buffer, 0, bytesRead);
allStr += content;
_logger.LogInformation(content);
}
}

return allStr;
}

2、HttpClient方式
public async Task<string> TestStream()
{
string url = "http://localhost:9291/api/Duix/GetStream";
string allStr = "";
DuixRequest duixRequest = new DuixRequest()
{
sid = "1234567890",
dh_question = "你好",
dh_conversation_id = "1234567890",

};
var client = new HttpClient();
using HttpRequestMessage httpRequestMessage = new HttpRequestMessage(HttpMethod.Post, url);
var response = await client.SendAsync(httpRequestMessage, HttpCompletionOption.ResponseHeadersRead);
await using var stream = await response.Content.ReadAsStreamAsync();
var bytes = new byte[20];
int writeLength = 0;
string result = "";
while ((writeLength = stream.Read(bytes, 0, bytes.Length)) > 0)
{
string content = Encoding.UTF8.GetString(bytes, 0, writeLength);
result = result + content;
Console.Write(Encoding.UTF8.GetString(bytes, 0, writeLength));
}
Console.WriteLine();
Console.WriteLine("END");
return result;
}