러스트의 mpsc 🤔

use tokio::sync::mpsc;

#[tokio::main]
async fn main() {
    // 채널 생성 (버퍼 크기: 32)
    let (tx, mut rx) = mpsc::channel(32);

    // 생산자 (Producer)
    tokio::spawn(async move {
        for i in 1..=5 {
            // tx.send()로 채널에 메세지를 보낸다.
            if let Err(_) = tx.send(format!("Message {}", i)).await {
                println!("Receiver dropped");
                return;
            }
            println!("Sent: Message {}", i);
        }
    });

    // 소비자 (Consumer) : rx.recv()로 수신한 메세지를 처리한다.
    while let Some(message) = rx.recv().await {
        println!("Received: {}", message);
    }
}

Sent: Message 1
Received: Message 1
Sent: Message 2
Received: Message 2
...

use tokio::sync::mpsc;

#[tokio::main]
async fn main() {
    let (tx, mut rx) = mpsc::channel(32);

    // Sender를 복제
    let tx1 = tx.clone();
    let tx2 = tx.clone();

    // 첫 번째 생산자
    tokio::spawn(async move {
        tx1.send("From Producer 1").await.unwrap();
    });

    // 두 번째 생산자
    tokio::spawn(async move {
        tx2.send("From Producer 2").await.unwrap();
    });

    // 소비자
    while let Some(message) = rx.recv().await {
        println!("Received: {}", message);
    }
}

Received: From Producer 1
Received: From Producer 2

let (client_tx, mut client_rx) = tokio::sync::mpsc::channel::<RedisEvent>(32);
let (replication_tx, mut replication_rx) = tokio::sync::mpsc::channel::<RedisEvent>(32);

tokio::spawn(async move {
    while let Some(event) = client_rx.recv().await {
        // 클라이언트 요청 처리
    }
});

tokio::spawn(async move {
    while let Some(event) = replication_rx.recv().await {
        // 레플리케이션 작업 처리
    }
});