如何让包含tokio::sync::broadcast::Receiver的结构体Foo实现Clone？

要让包含Tokio Broadcast通道的Foo结构体支持克隆，且每个克隆实例都能独立接收消息，核心思路是利用Broadcast通道Sender可克隆的特性，在克隆Foo时生成新的Receiver订阅者。具体步骤如下：

1. 修改结构体定义 #

将原来的watch::Receiver替换为Broadcast的Sender和Receiver组合（每个Foo实例需要自身的Receiver来跟踪接收进度）：

struct Foo<T> {
    // 其他需要克隆的状态字段
    some_state: String,
    sender: tokio::sync::broadcast::Sender<T>,
    receiver: tokio::sync::broadcast::Receiver<T>,
}

2. 手动实现Clone trait #

因为Broadcast的Receiver未实现Clone，所以需要手动为Foo实现Clone：

impl<T: Clone> Clone for Foo<T> {
    fn clone(&self) -> Self {
        // 通过Sender创建新的Receiver订阅者
        let new_receiver = self.sender.subscribe();
        Foo {
            // 克隆其他状态字段（确保这些字段已实现Clone）
            some_state: self.some_state.clone(),
            // Broadcast的Sender支持Clone，克隆后与原Sender共享同一通道
            sender: self.sender.clone(),
            receiver: new_receiver,
        }
    }
}

3. 初始化Foo实例 #

创建Broadcast通道时，会得到初始的Sender和Receiver，用它们初始化第一个Foo：

// 创建Broadcast通道，缓冲区大小根据需求调整
let (sender, receiver) = tokio::sync::broadcast::channel(10);
let foo = Foo {
    some_state: "initial state".to_string(),
    sender,
    receiver,
};

原理说明 #

• Broadcast的Sender克隆后，所有克隆的Sender都指向同一个通道，发送的消息会被所有订阅的Receiver接收。
• 每次克隆Foo时调用sender.subscribe()，会生成一个新的Receiver，该Receiver会接收后续发送的所有消息，与原Foo的Receiver相互独立，不会干扰彼此的接收进度。

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