tourniquet

轻松地在提供相同服务的服务器之间进行轮询，发生错误时自动重新连接到下一个服务器。

此库通过以轮询方式连接到列表中的第一个可用的服务，使多个服务提供者（例如，服务器）具有弹性。如果由于某种原因任何提供者宕机，任何与其交互的尝试将自动重新连接到下一个提供者。

免责声明：此库不用于一组提供者之间的负载均衡！它将连接到 一个 提供者，并且只要该提供者处于活动状态，它将只使用该提供者。Tourniquet旨在提供弹性，而不是用于负载均衡。

示例

use async_trait::async_trait;
use std::{io::Error, net::IpAddr};
use tokio::{io::AsyncReadExt, net::TcpStream, sync::Mutex};
use tourniquet::{Connector, RoundRobin};

struct Conn(u16);

#[async_trait]
impl Connector<IpAddr, Mutex<TcpStream>, Error> for Conn {
    async fn connect(&self, src: &IpAddr) -> Result<Mutex<TcpStream>, Error> {
        let Conn(ref port) = self;
        TcpStream::connect((*src, *port)).await.map(Mutex::new)
    }
}

#[tokio::main]
async fn main() {
    let rr = RoundRobin::new(
        vec!["46.16.175.175".parse().unwrap(), "51.161.82.214".parse().unwrap()],
        Conn(6667),
    );

    let hello = rr.run(|sock| async move {
        let mut sock = sock.lock().await;
        let mut buf = [0; 50];
        sock.read_exact(&mut buf).await.map(|_| String::from_utf8(buf.to_vec()).unwrap())
    }).await.unwrap();

    assert!(hello.contains("libera.chat"));
}

许可证：MIT