F#中TCP监听器取消无效问题排查求助

核心问题 #

取消操作不生效的关键原因是：server.AcceptTcpClientAsync()调用未关联取消令牌，当你触发TokenSource.Cancel()时，这个异步方法会一直阻塞等待新连接，不会触发取消逻辑，导致connectLoop循环无法退出，server.Stop()也无法执行。

另外，connectLoop中获取的Async.CancellationToken虽能关联到传入的portToken，但由于AcceptTcpClientAsync不响应取消，循环里的ct.IsCancellationRequested检查永远没有执行机会。

修复步骤 #

1. 给AcceptTcpClientAsync传入取消令牌 #

修改客户端接收代码，使用带取消令牌的重载，这样当令牌取消时，该方法会抛出OperationCanceledException，触发异步任务的取消流程：

let! client = server.AcceptTcpClientAsync(portToken) |> Async.AwaitTask

2. 简化connectLoop循环逻辑 #

直接使用构造函数传入的portToken，无需反复获取Async.CancellationToken，同时捕获取消异常以退出循环：

let rec connectLoop () = 
    async { 
        while not portToken.IsCancellationRequested do
            try
                let! client = server.AcceptTcpClientAsync(portToken) |> Async.AwaitTask
                this.processMessage client portToken |> Async.Start
            with :? OperationCanceledException ->
                return ()
        return ()
    }

3. 确保processMessage响应取消令牌 #

在processMessage方法的关键步骤（如读取网络流）中，检查portToken.IsCancellationRequested，或使用带取消令牌的异步方法重载，保证正在处理的连接能及时终止。

4. 验证令牌引用的正确性 #

确认ScannerInstances中保存的TokenSource是对应TCP实例的正确引用，调用Cancel()时确实触发的是目标实例的令牌。

修改后的ScannerController关键代码片段 #

type ScannerController (portToken : CancellationToken) = 
    let mutable server : TcpListener = null
    let mutable portId = 0
    let mutable errorMessage = String.Empty
    
    member this.StartListeningOnPort portNumber =
        try
            server <- new TcpListener (new IPEndPoint (IPAddress.Any, portNumber))
            portId <- portNumber
            server.Start ()
            portToken.ThrowIfCancellationRequested ()
            
            let rec connectLoop () = 
                async { 
                    while not portToken.IsCancellationRequested do
                        try
                            let! client = server.AcceptTcpClientAsync(portToken) |> Async.AwaitTask
                            this.processMessage client portToken |> Async.Start
                        with :? OperationCanceledException ->
                            return ()
                    return ()
                }
            let worker = Async.TryCancelled (connectLoop (), fun _ -> 
                if server <> null then
                    server.Stop ()
                    server <- null
            )
            Async.Start (worker, portToken)
            
        with | :? SocketException as ex -> 
                if  ex.SocketErrorCode = SocketError.AddressAlreadyInUse then
                    errorMessage <- $"TCP/IP port number {portId} is already in use."
                else
                    errorMessage <- $"Error {ex.Message} trying to listen on TCP port: {portId}"
             | _ as ex -> 
                 errorMessage <- $"StartListening on port: {portId} encountered a fatal exception.{FormatExceptionMessage ex}"

内容的提问来源于stack exchange，提问作者Maui_Ed