Rust 语言和 select 库的编写程序

news2024/11/30 9:29:19

使用 Rust 语言和 select 库的下载器程序,用于下载 视频。

首先,我们需要导入 select 库。select 库是一个用于处理多个输入/输出流的 Rust 库。它提供了一个函数,可以让我们等待多个文件描述符(如网络套接字)可读或可写。

use std::net::TcpStream;
use std::io::{BufReader, BufWriter};
use std::select;

接下来,我们需要创建一个 TcpStream 对象,该对象表示一个到服务器的连接。我们还需要创建一个 BufReader 对象,该对象可以缓冲从网络读取的数据。

let proxy_host = "";
let proxy_port = ;
​
let mut proxy = TcpStream::connect(format!("{}:{}", proxy_host, proxy_port)).unwrap();
let mut proxy_reader = BufReader::new(proxy);

然后,我们需要创建一个 TcpStream 对象,该对象表示一个到目标网站的连接。我们还需要创建一个 BufWriter 对象,该对象可以缓冲向网络写入的数据。

let mut target = TcpStream::connect(format!("")).unwrap();
let mut target_writer = BufWriter::new(target);

接下来,我们需要创建一个循环,该循环会一直运行,直到我们完成下载。在每次循环中,我们都会检查服务器和目标网站的连接是否可读或可写。如果连接可读,我们就会从代理服务器读取数据,并将数据写入目标网站的连接。如果连接可写,我们就会从目标网站的连接读取数据,并将数据写入代理服务器的连接。

loop {
    let mut readable = vec![proxy_reader, target_reader];
    let mut writable = vec![proxy_writer, target_writer];
​
    let mut timeout = std::time::Duration::from_millis(100);
    let events = select::poll(&mut readable, &mut writable, &mut timeout).unwrap();
​
    for event in events {
        match event {
            select::Event::Readable(r) => {
                let mut bytes = [0; 4096];
                let bytes_read = r.read(&mut bytes).unwrap();
                target_writer.write_all(&bytes[..bytes_read]).unwrap();
            },
            select::Event::Writable(w) => {
                let mut bytes = [0; 4096];
                let bytes_read = w.read(&mut bytes).unwrap();
                proxy_writer.write_all(&bytes[..bytes_read]).unwrap();
            },
            _ => {
                break;
            },
        }
    }
}

最后,我们需要关闭所有打开的连接。

proxy_reader.close().unwrap();
proxy_writer.close().unwrap();
target_reader.close().unwrap();
target_writer.close().unwrap();
proxy.close()
    .unwrap();
target.close()
    .unwrap();

这就是使用 Rust 语言和 select 库创建下载器程序的详细代码。有啥问题欢迎随时留言提问!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1165834.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【Python 零基础入门】Numpy 常用函数 通用函数 保存加载

【Python 零基础入门】内容补充 4 Numpy 常用函数 通用函数 & 保存加载 概述通用函数np.sqrt 平方根np.log 对数np.exp 指数np.sin 正弦 点积和叉积np.dot 点积叉积 矩阵乘法np.matmul 保存 & 加载np.save 保存单个数组np.savez 保存多个数组np.savez_compressed 保存n…

Halcon计算点到直线的垂线方程

一、我们都知道,点到直线最短距离就是垂线。Halcon也有现成的算子可以计算点到直线的距离 distance_pl( : : Row, Column, Row1, Column1, Row2, Column2 : Distance)。但是此算子不会返回具体的垂点坐标。当我们希望显示垂线的时候是需要知道垂点坐标,才…

目前比较好用的护眼台灯?最好用的五款护眼台灯推荐

灯具可以说是我们日常生活中使用很频繁的工具了,我们每天都离不开它给我们带来的光亮。当然,现在灯具也有很多种类可以挑选,今天主要带来五款非常好用的护眼台灯指南。 1.书客护眼台灯Pro 使用体验分数:10分 亮点:具…

我的1024创作纪念日

文章底部有个人公众号:热爱技术的小郑。主要分享开发知识、学习资料、毕业设计指导等。有兴趣的可以关注一下。为何分享? 踩过的坑没必要让别人在再踩,自己复盘也能加深记忆。利己利人、所谓双赢。 机缘 起初我并没有写博客这个习惯&#xff…

酷开会员丨相约酷开系统追剧,看漫画IP《一人之下》究竟有何魅力?

8月份,由国产动漫《一人之下》改编的电视剧《异人之下》空降播出的第二天,突然宣布由于“介质原因”本片将延期播出。官宣当日即开播、开播次日即停播,《异人之下》的初登场看上去就像一则极具国产特色的超短篇笑话。之后,当我们几…

numpy中的log和ln函数介绍

np.log()指代的便是数学中使用的ln函数。 np.log10()指代的便是数学中使用的lg函数。 import numpy as npprint(np.log(np.e))print(np.log10(100))

python脚本,实现监控系统的各项资源

shigen坚持日更的博客写手,擅长Java、python、vue、shell等编程语言和各种应用程序、脚本的开发。坚持记录和分享从业两年以来的技术积累和思考,不断沉淀和成长。 今天的文章涉及到docker的操作和一个python脚本,实现监控网络的流量、CPU使用…

SSL证书在网购中的重要性

近年来,互联网的快速发展使得线上服务范围不断延伸,这其中网络购物更是在全球范围内都呈现上升趋势。然而病毒攻击,网络钓鱼攻击和恶意软件攻击无处不在,网上购物的安全性受到极大威胁。为了保护网络购物的安全,构建可…

cpu算力DMIPS说明

DMIPS即以dhrystone程式为测量方式标准的mips值,DMIPS即million instruction per second,每秒百万个指令,即处理器每秒能运行多少百万个指令。 D是Dhrystone的缩写,表示的是基于Dhrystone这样一种测试方法下的 MIPSQ。Dhrystone是…

HTTP 协议请求头 If-Match、If-None-Match 和 ETag

概述 在 HTTP 协议中,请求头 If-Match、If-None-Match、If-Modified-Since、If-Unmodified-Since、If-Range 主要是为了解决浏览器缓存数据而定义的请求头标准,按照协议规范正确的判断和使用这几个请求头,可以更精准的处理浏览器缓存&#x…

制造业经营效益差?业务数据管理是关键

《中国制造2025》 指出,目前中国制造业整体尚处于由工业2.0向工业3.0过渡的阶段,而欧美的制造强国已提出工业4.0概念,由“制造”迈向“智造”, 实现智能工厂、 智能生产和智能物流,建立一个高度灵活的个性化和数字化的…

.NET Core 中插件式开发实现

在 .NET Framework 中,通过AppDomain实现动态加载和卸载程序集的效果;但是.NET Core 仅支持单个默认应用域,那么在.NET Core中如何实现【插件式】开发呢? 一、.NET Core 中 AssemblyLoadContext的使用 1、AssemblyLoadContext简…

Git 删除本地和远程分支

目录 删除本地和远程分支分支删除验证验证本地分支验证远程分支 开源项目微服务商城项目前后端分离项目 删除本地和远程分支 删除 youlai-mall 的 dev 本地和远程分支 # 删除本地 dev 分支(注:一定要切换到dev之外的分支才能删除,否则报错&…

【Proteus仿真】【STM32单片机】数控稳压可调电源设计

文章目录 一、功能简介二、软件设计三、实验现象联系作者 一、功能简介 本项目使用Proteus8仿真STM32单片机控制器,使用动态数码管、按键、PCF8591 AD/DAC、LM358放大电路模块等。 主要功能: 系统运行后,系统默认输出直流5V,数码…

Linux普通用户提权(sudo)

文章目录 Linux普通用户提权(sudo)1、在sudoers文件添加普通用户2、测试 Linux普通用户提权(sudo) 1、在sudoers文件添加普通用户 正常来说,普通用户初始是不具备提权的能力的,比如执行sudo ls会出现报警告…

内置对象和方法、前端基础之BOM和DOM

内置对象和方法 RegExp对象 // 定义正则表达式两种方式 var reg1 new RegExp("^[a-zA-Z][a-zA-Z0-9]{5,11}"); var reg2 /^[a-zA-Z][a-zA-Z0-9]{5,9}$/;// 正则校验数据 reg1.test(jason666) reg2.test(jason666)/*第一个注意事项,正则表达式中不能有…

基于闪电连接过程算法的无人机航迹规划-附代码

基于闪电连接过程算法的无人机航迹规划 文章目录 基于闪电连接过程算法的无人机航迹规划1.闪电连接过程搜索算法2.无人机飞行环境建模3.无人机航迹规划建模4.实验结果4.1地图创建4.2 航迹规划 5.参考文献6.Matlab代码 摘要:本文主要介绍利用闪电连接过程算法来优化无…

智能政务,办事更轻松!拓世法宝AI智慧政务数字人一体机,重新定义你的政务办理体验!

在构建现代化的政务服务体系中,高效、便捷是最重要的衡量标准。随着信息化技术的发展,很多政务服务已经实现了重要的线上办理,减轻了公民和企业的办事负担,同时也提升了政府部门的服务效率。可是,一些场景下的办事流程…

工业制造:如何有效监测漏水事件,让老板都挑不出毛病?

水浸监控技术作为一种关键的安全措施,在不同领域中扮演着至关重要的角色。随着自然灾害和人为事件的不断增加,包括洪水、泄漏和管道破裂等,对水浸监控系统的需求变得越来越紧迫。 客户案例 工业制造业 在工业制造领域,水浸监控系统…

素材收藏必备!免费获取这5个矢量图标库,设计更得心应手!

可以自由拉伸的矢量图标,在平面设计流程中的重要性,有过设计经验的用户一定不会陌生。 下面,我们给大家准备了5个免费使用的矢量logo图标库,建议大家一键收藏。 1:即时设计 即时设计的资源社区内有海量免费的矢量图…