#networking #target #async #check #icmp #availability #tcp

reachable

检查目标(ICMP、TCP、自定义)是否可到达

3 个版本

0.2.2 2022 年 1 月 11 日
0.2.1 2021 年 10 月 19 日
0.2.0 2021 年 10 月 17 日

#2#可用性

Download history 831/week @ 2024-04-16 469/week @ 2024-04-23 444/week @ 2024-04-30 412/week @ 2024-05-07 400/week @ 2024-05-14 354/week @ 2024-05-21 407/week @ 2024-05-28 559/week @ 2024-06-04 433/week @ 2024-06-11 501/week @ 2024-06-18 612/week @ 2024-06-25 282/week @ 2024-07-02 454/week @ 2024-07-09 395/week @ 2024-07-16 384/week @ 2024-07-23 229/week @ 2024-07-30

每月 1,554 次下载
用于 bodo_connect

MPL-2.0 许可证

58KB
943

reachable

reachable 是一个 Rust 包,用于检查 "目标" 是否可用。该包包含 "Target" 特性的定义及其基于 ICMP/TCP 的实现。此外,该包还提供异步任务执行器,以便定期执行 "目标" 的可用性检查。

使用方法

使用此包,您可以轻松地检查计算机当前是否可以通过网络访问。由于所有目标都是 "Target" 特性的实现,因此可用性检查的行为可以自定义。例如,可以轻松实现一个自定义目标来检查进程是否正在运行。

示例(来自 examples/usage/src/main.rs)

use std::str::FromStr;

use reachable::*;

fn main() {
    // Construct ICMP Target check if the target is availabile
    let icmp_target = IcmpTarget::from_str("www.google.de").unwrap();
    match icmp_target.check_availability() {
        Ok(status) => println!("{} is {}", icmp_target.get_id(), status),
        Err(error) => println!("Check failed for {} reason {}", icmp_target.get_id(), error),
    }
}

异步示例(来自 examples/async_usage/src/main.rs)

use std::str::FromStr;
use std::thread::sleep;
use std::time::Duration;

use reachable::*;

fn main() {
    // Setup AsyncTargets
    let icmp_target = IcmpTarget::from_str("www.google.de").unwrap();
    let tcp_target = TcpTarget::from_str("www.google.de:80").unwrap();

    let handler = |target: &dyn Target, status, old_status, error| {
        print!("Target \"{}\"", target.get_id());
        print!(", old status \"{}\"", old_status);
        print!(", new status \"{}\"", status);
        match error {
            None => println!(""),
            Some(err) => println!(", Error: \"{}\"", err),
        }
    };

    // Spawn Async execution
    let mut exec = AsyncTargetExecutor::new();
    exec.start(vec![
        AsyncTarget::from((icmp_target, handler, Duration::from_secs(1))),
        AsyncTarget::from((tcp_target, handler, Duration::from_secs(1))),
    ]);
    sleep(Duration::from_secs(3));
    exec.stop();
}

依赖项

~0.3–1.9MB
~31K SLoC