rust 版本 libp2p 的长相不太行

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

// 创建传输层(QUIC 和 TCP)
fn create_transport(keypair: &identity::Keypair) -> Result<libp2p::core::transport::Boxed<(PeerId, libp2p::core::muxing::StreamMuxerBox)>, Box<dyn Error>> {
    // 配置 QUIC 传输
    let quic_transport = quic::async_std::Transport::new(quic::Config::new(keypair))
        .map(|(peer_id, conn), _| (peer_id, libp2p::core::muxing::StreamMuxerBox::new(conn)));

    // 配置 TCP 传输(带 Noise 加密和 Yamux 多路复用)
    let tcp_transport = tcp::async_io::Transport::new(tcp::Config::default().nodelay(true))
        .upgrade(libp2p::core::upgrade::Version::V1)
        .authenticate(noise::Config::new(keypair)?)
        .multiplex(libp2p::yamux::Config::default())
        .map(|(peer_id, conn), _| (peer_id, libp2p::core::muxing::StreamMuxerBox::new(conn)));

    // 组合两种传输方式(QUIC 优先，TCP 作为备选)
    Ok(libp2p::core::transport::OrTransport::new(quic_transport, tcp_transport)
        .map(|either, _| match either {
            libp2p::futures::future::Either::Left((peer_id, conn)) => (peer_id, conn),
            libp2p::futures::future::Either::Right((peer_id, conn)) => (peer_id, conn),
        })
        .boxed())
}

Rust

libp2p

transport

4 条回复 • 2025-04-03 09:41:56 +08:00