c语言实现http下载功能,显示进度条和下载速率

#include <stdio.h>//printf
#include <string.h>//字符串处理
#include <sys/socket.h>//套接字
#include <arpa/inet.h>//ip地址处理
#include <fcntl.h>//open系统调用
#include <unistd.h>//write系统调用
#include <netdb.h>//查询DNS
#include <stdlib.h>//exit函数
#include <sys/stat.h>//stat系统调用获取文件大小
#include <sys/time.h>//获取下载时间
//下载地址   http://dldir1.qq.com/qqfile/qq/QQ7.9/16638/QQ7.9.exe
struct HTTP_RES_HEADER//保持相应头信息
{int status_code;//HTTP/1.1 '200' OKchar content_type[128];//Content-Type: application/gziplong content_length;//Content-Length: 11683079
};void parse_url(const char *url, char *host, int *port, char *file_name)
{/*通过url解析出域名, 端口, 以及文件名*/int j = 0;int start = 0;*port = 80;char *patterns[] = {"http://", "https://", NULL};for (int i = 0; patterns[i]; i++)//分离下载地址中的http协议if (strncmp(url, patterns[i], strlen(patterns[i])) == 0)start = strlen(patterns[i]);//解析域名, 这里处理时域名后面的端口号会保留for (int i = start; url[i] != '/' && url[i] != '\0'; i++, j++)host[j] = url[i];host[j] = '\0';//解析端口号, 如果没有, 那么设置端口为80char *pos = strstr(host, ":");if (pos)sscanf(pos, ":%d", port);//删除域名端口号for (int i = 0; i < (int)strlen(host); i++){if (host[i] == ':'){host[i] = '\0';break;}}//获取下载文件名j = 0;for (int i = start; url[i] != '\0'; i++){if (url[i] == '/'){if (i !=  strlen(url) - 1)j = 0;continue;}elsefile_name[j++] = url[i];}file_name[j] = '\0';
}struct HTTP_RES_HEADER parse_header(const char *response)
{/*获取响应头的信息*/struct HTTP_RES_HEADER resp;char *pos = strstr(response, "HTTP/");if (pos)//获取返回代码sscanf(pos, "%*s %d", &resp.status_code);pos = strstr(response, "Content-Type:");if (pos)//获取返回文档类型sscanf(pos, "%*s %s", resp.content_type);pos = strstr(response, "Content-Length:");if (pos)//获取返回文档长度sscanf(pos, "%*s %ld", &resp.content_length);return resp;
}void get_ip_addr(char *host_name, char *ip_addr)
{/*通过域名得到相应的ip地址*/struct hostent *host = gethostbyname(host_name);//此函数将会访问DNS服务器if (!host){ip_addr = NULL;return;}for (int i = 0; host->h_addr_list[i]; i++){strcpy(ip_addr, inet_ntoa( * (struct in_addr*) host->h_addr_list[i]));break;}
}void progress_bar(long cur_size, long total_size, double speed)
{/*用于显示下载进度条*/float percent = (float) cur_size / total_size;const int numTotal = 50;int numShow = (int)(numTotal * percent);if (numShow == 0)numShow = 1;if (numShow > numTotal)numShow = numTotal;char sign[51] = {0};memset(sign, '=', numTotal);printf("\r%.2f%%[%-*.*s] %.2f/%.2fMB %4.0fkb/s", percent * 100, numTotal, numShow, sign, cur_size / 1024.0 / 1024.0, total_size / 1024.0 / 1024.0, speed);fflush(stdout);if (numShow == numTotal)printf("\n");
}unsigned long get_file_size(const char *filename)
{//通过系统调用直接得到文件的大小struct stat buf;if (stat(filename, &buf) < 0)return 0;return (unsigned long) buf.st_size;
}void download(int client_socket, char *file_name, long content_length)
{/*下载文件函数*/long hasrecieve = 0;//记录已经下载的长度struct timeval t_start, t_end;//记录一次读取的时间起点和终点, 计算速度int mem_size = 8192;//缓冲区大小8Kint buf_len = mem_size;//理想状态每次读取8K大小的字节流int len;//创建文件描述符int fd = open(file_name, O_CREAT | O_WRONLY, S_IRWXG | S_IRWXO | S_IRWXU);if (fd < 0){printf("文件创建失败!\n");exit(0);}char *buf = (char *) malloc(mem_size * sizeof(char));//从套接字流中读取文件流long diff = 0;int prelen = 0;double speed;while (hasrecieve < content_length){gettimeofday(&t_start, NULL ); //获取开始时间len = read(client_socket, buf, buf_len);write(fd, buf, len);gettimeofday(&t_end, NULL ); //获取结束时间hasrecieve += len;//更新已经下载的长度//计算速度if (t_end.tv_usec - t_start.tv_usec >= 0 &&  t_end.tv_sec - t_start.tv_sec >= 0)diff += 1000000 * ( t_end.tv_sec - t_start.tv_sec ) + (t_end.tv_usec - t_start.tv_usec);//usif (diff >= 1000000)//当一个时间段大于1s=1000000us时, 计算一次速度{speed = (double)(hasrecieve - prelen) / (double)diff * (1000000.0 / 1024.0);prelen = hasrecieve;//清零下载量diff = 0;//清零时间段长度}progress_bar(hasrecieve, content_length, speed);if (hasrecieve == content_length)break;}
}int main(int argc, char const *argv[])
{/* 命令行参数: 接收两个参数, 第一个是下载地址, 第二个是文件的保存位置和名字, 下载地址是必须的, 默认下载到当前目录* 示例: ./download http://www.baidu.com baidu.html*/char url[2048] = "127.0.0.1";//设置默认地址为本机,char host[64] = {0};//远程主机地址char ip_addr[16] = {0};//远程主机IP地址int port = 80;//远程主机端口, http默认80端口char file_name[256] = {0};//下载文件名if (argc == 1){printf("您必须给定一个http地址才能开始工作\n");exit(0);}elsestrcpy(url, argv[1]);puts("1: 正在解析下载地址...");parse_url(url, host, &port, file_name);//从url中分析出主机名, 端口号, 文件名if (argc == 3){printf("\t您已经将下载文件名指定为: %s\n", argv[2]);strcpy(file_name, argv[2]);}puts("2: 正在获取远程服务器IP地址...");get_ip_addr(host, ip_addr);//调用函数同访问DNS服务器获取远程主机的IPif (strlen(ip_addr) == 0){printf("错误: 无法获取到远程服务器的IP地址, 请检查下载地址的有效性\n");return 0;}puts("\n>>>>下载地址解析成功<<<<");printf("\t下载地址: %s\n", url);printf("\t远程主机: %s\n", host);printf("\tIP 地 址: %s\n", ip_addr);printf("\t主机PORT: %d\n", port);printf("\t 文件名 : %s\n\n", file_name);//设置http请求头信息char header[2048] = {0};sprintf(header, \"GET %s HTTP/1.1\r\n"\"Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8\r\n"\"User-Agent: Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537(KHTML, like Gecko) Chrome/47.0.2526Safari/537.36\r\n"\"Host: %s\r\n"\"Connection: keep-alive\r\n"\"\r\n"\,url, host);puts("3: 创建网络套接字...");int client_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (client_socket < 0){printf("套接字创建失败: %d\n", client_socket);exit(-1);}//创建IP地址结构体struct sockaddr_in addr;memset(&addr, 0, sizeof(addr));addr.sin_family = AF_INET;addr.sin_addr.s_addr = inet_addr(ip_addr);addr.sin_port = htons(port);//连接远程主机puts("4: 正在连接远程主机...");int res = connect(client_socket, (struct sockaddr *) &addr, sizeof(addr));if (res == -1){printf("连接远程主机失败, error: %d\n", res);exit(-1);}puts("5: 正在发送http下载请求...");write(client_socket, header, strlen(header));//write系统调用, 将请求header发送给服务器int mem_size = 4096;int length = 0;int len;char *buf = (char *) malloc(mem_size * sizeof(char));char *response = (char *) malloc(mem_size * sizeof(char));//每次单个字符读取响应头信息puts("6: 正在解析http响应头...");while ((len = read(client_socket, buf, 1)) != 0){if (length + len > mem_size){//动态内存申请, 因为无法确定响应头内容长度mem_size *= 2;char * temp = (char *) realloc(response, sizeof(char) * mem_size);if (temp == NULL){printf("动态内存申请失败\n");exit(-1);}response = temp;}buf[len] = '\0';strcat(response, buf);//找到响应头的头部信息int flag = 0;for (int i = strlen(response) - 1; response[i] == '\n' || response[i] == '\r'; i--, flag++);if (flag == 4)//连续两个换行和回车表示已经到达响应头的头尾, 即将出现的就是需要下载的内容break;length += len;}struct HTTP_RES_HEADER resp = parse_header(response);printf("\n>>>>http响应头解析成功:<<<<\n");printf("\tHTTP响应代码: %d\n", resp.status_code);if (resp.status_code != 200){printf("文件无法下载, 远程主机返回: %d\n", resp.status_code);return 0;}printf("\tHTTP文档类型: %s\n", resp.content_type);printf("\tHTTP主体长度: %ld字节\n\n", resp.content_length);printf("7: 开始文件下载...\n");download(client_socket, file_name, resp.content_length);printf("8: 关闭套接字\n");if (resp.content_length == get_file_size(file_name))printf("\n文件%s下载成功! ^_^\n\n", file_name);else{remove(file_name);printf("\n文件下载中有字节缺失, 下载失败, 请重试!\n\n");}shutdown(client_socket, 2);//关闭套接字的接收和发送return 0;
}

运行效果:

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

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

相关文章

机器学习实战:基于sklearn的工业蒸汽量预测

文章目录 写在前面工业蒸汽量预测1.基础代码2.模型训练3.模型正则化4.模型交叉验证5.模型超参空间及调参6.学习曲线和验证曲线 写在后面 写在前面 本期内容&#xff1a;基于机器学习的工业蒸汽量预测 实验环境&#xff1a; anaconda python sklearn 注&#xff1a;本专栏内所有…

K8s学习笔记——认识理解篇

1. K8s诞生背景 回顾应用的部署&#xff0c;经历了以下几个阶段&#xff1a; 传统部署&#xff1a;物理服务器上运行应用程序。虚拟机部署&#xff1a;物理服务器上安装虚拟机&#xff0c;在虚拟机上运行应用程序。容器部署&#xff1a;物理服务器上安装容器运行时&#xff0…

YB4554是一款经济高效、完全集成的高端输入电压单电池锂离子电池充电器。

YB4554 带OVP保护的高输入电压充电器 概述&#xff1a; YB4554是一款经济高效、完全集成的高端输入电压单电池锂离子电池充电器。这个充电器使用锂离子要求的CC/CV充电模式电池充电器可接受高达24V&#xff0c;但当输入电压超过OVP阈值&#xff0c;通常为6.8V&#xff0c;以防…

antdv使用a-cascader联级选择器实现自定义浮层样式

一般的使用组件库想要自定义样式都会使用深度选择器deep去实现 但是有的组件不管是deep还是!important还是写行内样式都改不掉 这里主要讲使用a-cascader联级选择器的浮层改变样式 一&#xff0c;使用组件 <a-cascader:options"regionOptions"change-on-selectv…

30道高频Vue面试题快问快答

面试中的快问快答 快问快答的情景在面试中非常常见。 在面试过程中&#xff0c;面试官通常会使用快问快答的方式来快速评估面试者的基础知识、思维能力和反应速度。 这种情景下&#xff0c;面试官会提出一系列简短的问题&#xff0c;并期望面试者能够迅速做出回答或提供简洁明…

云计算实战项目之---学之思在线考试系统

简介&#xff1a; 学之思开源考试系统是一款 java vue 的前后端分离的考试系统。主要优点是开发、部署简单快捷、界面设计友好、代码结构清晰。支持web端和微信小程序&#xff0c;能覆盖到pc机和手机等设备。 支持多种部署方式&#xff1a;集成部署、前后端分离部署、docker部…

初识rust

调试下rust 的执行流程 参考&#xff1a; 认识 Cargo - Rust语言圣经(Rust Course) 新建一个hello world 程序&#xff1a; fn main() {println!("Hello, world!"); }用IDA 打开exe&#xff0c;并加载符号&#xff1a; 根据字符串找到主程序入口&#xff1a; 双击…

SpringCloud 微服务全栈体系(十二)

第十一章 分布式搜索引擎 elasticsearch 一、初识 elasticsearch 1. 了解 ES 1.1 elasticsearch 的作用 elasticsearch 是一款非常强大的开源搜索引擎&#xff0c;具备非常多强大功能&#xff0c;可以帮助我们从海量数据中快速找到需要的内容 例如&#xff1a; 在 GitHub 搜…

【安全】Java幂等性校验解决重复点击(6种实现方式)

目录 一、简介1.1 什么是幂等&#xff1f;1.2 为什么需要幂等性&#xff1f;1.3 接口超时&#xff0c;应该如何处理&#xff1f;1.4 幂等性对系统的影响 二、Restful API 接口的幂等性三、实现方式3.1 数据库层面&#xff0c;主键/唯一索引冲突3.2 数据库层面&#xff0c;乐观锁…

亚马逊云科技产品测评』活动征文|通过使用Amazon Neptune来预测电影类型初体验

文章目录 福利来袭Amazon Neptune什么是图数据库为什么要使用图数据库什么是Amazon NeptuneNeptune 的特点 快速入门环境搭建notebook 图神经网络快速构建加载数据配置端点Gremlin 查询清理 删除环境S3 存储桶删除 授权声明&#xff1a;本篇文章授权活动官方亚马逊云科技文章转…

chatgpt升级啦,训练数据时间更新到2023年4月,支持tools(升级functionCall),128k上下文

&#xff08;2023年11月7日&#xff09; gpt-4-1106-preview https://platform.openai.com/docs/models/gpt-4-and-gpt-4-turbo 训练数据日期升级到2023年四月 上线文增加到128k 调用一次chatgpt接口&#xff0c;可以得到多次函数调用 import OpenAI from "openai"…

水利部加快推进小型水库除险加固,大坝安全监测是重点

国务院常务会议明确到2025年前&#xff0c;完成新出现病险水库的除险加固&#xff0c;配套完善重点小型水库雨水情和安全监测设施&#xff0c;实现水库安全鉴定和除险加固常态化。 为加快推进小型水库除险加固前期工作&#xff0c;水利部协调财政部提前下达了2023年度中央补助…

网络流量分类概述

1. 什么是网络流量&#xff1f; 一条网络流量是指在一段特定的时间间隔之内&#xff0c;通过网络中某一个观测点的所有具有相同五元组(源IP地址、目的IP地址、传输层协议、源端口和目的端口)的分组的集合。 比如(10.134.113.77&#xff0c;47.98.43.47&#xff0c;TLSv1.2&…

YOLOv8-Pose推理详解及部署实现

目录 前言一、YOLOv8-Pose推理(Python)1. YOLOv8-Pose预测2. YOLOv8-Pose预处理3. YOLOv8-Pose后处理4. YOLOv8-Pose推理 二、YOLOv8-Pose推理(C)1. ONNX导出2. YOLOv8-Pose预处理3. YOLOv8-Pose后处理4. YOLOv8-Pose推理 三、YOLOv8-Pose部署1. 源码下载2. 环境配置2.1 配置CM…

web前端js基础------制作滚动图片

1&#xff0c;要求 通过定时器使其出现滚动的效果 可以通过按键控制图片滚动的方向&#xff08;设置两个按钮绑定点击事件&#xff09; 当鼠标悬停时图片停止&#xff0c;鼠标离开时图片继续向前滚动&#xff08;可以设置鼠标的悬停和离开事件&#xff09; 参考如下 conten…

揭开堆叠式自动编码器的强大功能

一、介绍 在不断发展的人工智能和机器学习领域&#xff0c;深度学习技术因其处理复杂和高维数据的能力而广受欢迎。在各种深度学习模型中&#xff0c;堆叠式自动编码器是一种多功能且功能强大的工具&#xff0c;可用于特征学习、降维和数据表示。本文探讨了堆叠式自动编码器在深…

【论文阅读】Generating Radiology Reports via Memory-driven Transformer (EMNLP 2020)

资料链接 论文原文&#xff1a;https://arxiv.org/pdf/2010.16056v2.pdf 代码链接&#xff08;含数据集&#xff09;&#xff1a;https://github.com/cuhksz-nlp/R2Gen/ 背景与动机 这篇文章的标题是“Generating Radiology Reports via Memory-driven Transformer”&#xf…

【JAVA】:万字长篇带你了解JAVA并发编程-死锁优化【六】

目录 【JAVA】&#xff1a;万字长篇带你了解JAVA并发编程-并发编程的优化【六】并发编程的优化避免死锁死锁产生的条件避免死锁的方式死锁例程代码使用JpsJstack查看进程死锁问题 避免资源竞争 个人主页: 【⭐️个人主页】 需要您的【&#x1f496; 点赞关注】支持 &#x1f4a…

C#,数值计算——偏微分方程,谱方法的微分矩阵的计算方法与源程序

1 文本格式 using System; namespace Legalsoft.Truffer { /// <summary> /// 谱方法的微分矩阵 /// Differentiation matrix for spectral methods /// </summary> public class Weights { public Weights() { …

Spring Boot项目中通过 Jasypt 对属性文件中的账号密码进行加密

下面是在Spring Boot项目中对属性文件中的账号密码进行加密的完整步骤&#xff0c;以MySQL的用户名为root&#xff0c;密码为123321为例&#xff1a; 步骤1&#xff1a;引入Jasypt依赖 在项目的pom.xml文件中&#xff0c;添加Jasypt依赖&#xff1a; <dependency><…