[WebApi]浏览器断开后, 服务端的 callContext.Token.IsCancellationRequested 没有收到反馈仍在工作

### 组件

WebApi

### 版本号

4.0

### .NET SDK

.NET8

### 项目类型

Console

### 操作系统

Windows 10

### 运行环境

测试环境 (单元测试/集成测试)

### 这个问题是否已经存在？

- [x] 我已经搜索过现有的问题 (https://gitee.com/RRQM_Home/TouchSocket/issues)

### 如何复现

这是一个模拟 SSE服务的代码. 
当 浏览器断开后, 服务端的 callContext.Token.IsCancellationRequested  没有收到反馈仍在工作
完整代码如下:

``
using Consul;
using Newtonsoft.Json;
using System.Collections.Concurrent;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading.Tasks;
using TouchSocket.Core;
using TouchSocket.Http;
using TouchSocket.Http.WebSockets;
using TouchSocket.Rpc;
using TouchSocket.Sockets;
using TouchSocket.WebApi;
using TouchSocket.WebApi.Swagger;

namespace MainWebService
{

internal class Program
    {

static async Task Main(string[] args)
        {

var service = new HttpService();

var config = new TouchSocketConfig()
                    .SetListenIPHosts(7789)
                    .ConfigureContainer(a =>
                    {
                        a.AddConsoleLogger();
                        a.AddRpcStore(store =>
                        {
                            store.RegisterServer<HttpServer>();//注册服务     
                        });

})
                    .ConfigurePlugins(a =>
                    {
                        a.UseSwagger(options =>
                        { // 添加 Swagger 支持
                            options.UseLaunchBrowser(); // 启动时自动打开浏览器
                        });
                        a.UseTcpSessionCheckClear();

a.UseWebApi();

//此插件是http的兜底插件，应该最后添加。作用是当所有路由不匹配时返回404.且内部也会处理Option请求。可以更好的处理来自浏览器的跨域探测。
                        a.UseDefaultHttpServicePlugin();
                    });

await service.SetupAsync(config); //加载配置
            await service.StartAsync();

Console.WriteLine("以下连接用于测试webApi");
            Console.WriteLine($"使用：http://127.0.0.1:7789/api/v1/sse");

await Task.Delay(-1);

}

/// <summary>
        /// HttpServer 用于处理常规的 post 和 get 请求
        /// </summary>
        //[Router("/api/v1/[api]/[action]")]
        [Router("/api/v1/[action]")]
        public class HttpServer : ScopedRpcServer
        {

public HttpServer()
            {

}

[WebApi(Method = HttpMethodType.Get)]
            public async Task SSE(IWebApiCallContext callContext, string dataType = "", string dataKey = "", string dataValue = "")
            {
                var response = callContext.HttpContext.Response;

// 设置 SSE 响应头
                response.ContentType = "text/event-stream; charset=utf-8";
                response.AddHeader("Cache-Control", "no-cache, no-store, must-revalidate");
                response.AddHeader("Connection", "keep-alive");
                response.AddHeader("X-Accel-Buffering", "no");
                response.StatusCode = 200;
                response.IsChunk = true;

const int totalCount = 60;
                for (int i = 0; i <= totalCount; i++)
                {

if (callContext.Token.IsCancellationRequested == true)
                    {
                        break; // 客户端已断开
                    }

string message = $"data: 第{i}/{totalCount}次循环\n\n";
                    byte[] buffer = Encoding.UTF8.GetBytes(message);

await response.WriteAsync(buffer);
                    await Task.Delay(1000);

}
            }

}

``

### 预期结果

正常情况下,浏览浏览器断开后,服务端就不再发送数据了.

### 实际结果

服务端还在继续发送数据.

### 异常信息

服务端还在继续发送数据.

### Demo 地址（仅限Git地址）

https://gitee.com/RRQM_Home/TouchSocket.git

### 承诺支持

- [x] 我确定我已经对TouchSocket项目进行了“Star”操作。

### 承诺规范

- [x] 我确定已完整阅读[Issue提问规范](https://touchsocket.net/docs/current/troubleshootissue)，并按照要求填写。

### 承诺友好

- [x] 我承诺将本着相互尊重、理解和友善的态度进行交流，共同维护好 TouchSocket 来之不易的良好的社区氛围。

GVP 若汝棋茗/TouchSocket

内容风险标识

评论 (1)

GVP若汝棋茗/TouchSocket

内容风险标识