web::Payload::next()在WebSocket连接中断时挂起

问题主要出现在使用actix-web框架的WebSocket连接中。当连接中断时，调用web::Payload::next()会导致程序挂起，从而无法继续接收数据。这可能会导致程序崩溃或无法正常工作。

解决方案是在调用web::Payload::next()之前，需要先检查连接是否仍然有效。这可以通过WebSocket的close_reason()方法来实现。如果连接已经关闭，则需要手动停止Payload的数据流。以下示例代码展示了如何在actix-web框架下解决此问题：

use actix_web::{web, App, HttpResponse, HttpRequest, HttpServer, Error};

async fn handle_ws(req: HttpRequest, stream: web::Payload) -> Result<HttpResponse, Error> {
    // create a new websocket
    let ws = web::WebSocket::new(stream);
    
    // get the close reason of the websocket
    let close_reason = ws.close_reason().await;
    if close_reason.is_some() {
        // websocket is closed, so abort the connection
        return Ok(HttpResponse::InternalServerError().finish());
    }
    
    // start processing websocket data
    let (tx, rx) = ws.split();
    let rx = rx.fold((), |_, message| {
        // process the websocket message
        future::ready(())
    });

    // wait for the websocket to close
    rx.await;

    Ok(HttpResponse::Ok().finish())
}

fn main() {
    HttpServer::new(|| {
        App::new()
            .route("/ws/", web::get().to(handle_ws))
    })
    .bind("127.0.0.1:8080")
    .unwrap()
    .run()
    .unwrap();
}

在这个示例代码中，我们首先获取了连接的关闭原因，如果发现连接已经关闭，则中止WebSocket连接。然后我们使用rx.fold()方法来处理WebSocket的数据流。这种处理方式可以自动停止Payload的数据流，从而避免了程序挂起的问题