Tokio WebSocket回声服务器改造报错：Error未实现Clone trait

你的编译错误根源在于：repeat(Ok(Message::Text(txt))) 要求元素类型 Result<Message, tungstenite::Error> 实现 Clone trait，但tungstenite::Error并没有提供这个实现。此外，原代码中直接用unwrap_or处理错误的方式也不符合Rust的错误处理习惯，容易隐藏问题。

下面是符合Rust惯用写法的修正方案：

修正后的代码 #

use tokio_stream::{StreamExt, iter};
use tokio_tungstenite::tungstenite::Message;
use futures::future;

// 假设你的数字提取函数，示例实现提取字符串中的首个数字
fn extract(s: &str) -> usize {
    s.chars()
        .filter(|c| c.is_ascii_digit())
        .collect::<String>()
        .parse()
        .unwrap_or(0)
}

// ... 省略WebSocket连接建立代码 ...

let (write, read) = ws_stream.split();

read.try_filter(|msg| future::ready(msg.is_text() || msg.is_binary()))
    // 将消息转换为文本，错误会沿流传递
    .and_then(|msg| msg.into_text())
    .flat_map(|text| {
        // 提取数字并确保次数非负
        let times = extract(&text).max(0);
        // 使用repeat_with生成重复消息，避免依赖Result的Clone实现
        iter(std::iter::repeat_with(move || {
            Ok(Message::Text(text.clone()))
        }).take(times))
    })
    .forward(write)
    .await
    .expect("Failed to forward messages");

关键改动说明 #

1. 错误处理优化：用and_then替代直接unwrap，让消息转换的错误自然沿流传递，避免隐藏潜在问题。
2. 避免Clone依赖：用std::iter::repeat_with替代repeat，每次通过闭包生成新的Ok(Message::Text(...))实例，不需要整个Result类型实现Clone，只需要String（消息文本）实现Clone即可（这是Rust标准库自带的）。
3. 边界处理：用max(0)确保提取的次数不会是负数，避免take方法出现异常。

如果需要在解析数字失败时给客户端返回提示消息，可以修改extract的逻辑，或者在flat_map中添加分支处理：

.flat_map(|text| {
    let times = match extract(&text) {
        Ok(n) => n.max(0),
        Err(_) => {
            // 数字解析失败，返回一条提示消息
            return iter(vec![Ok(Message::Text("Invalid number format".into()))]);
        }
    };
    iter(std::iter::repeat_with(move || {
        Ok(Message::Text(text.clone()))
    }).take(times))
})

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