Socket网络编程--小小网盘程序(1)

http://www.cnblogs.com/wunaozai/p/3886588.html

这个系列是准备讲基于Linux Socket进行文件传输。简单的文件传输就是客户端可以上传文件,可以从服务器端下载文件。就这么两个功能如果再加上身份验证,就成了FTP服务器了,如果对用户的操作再加上一些功能(如分享),就可以作为一个最简单的网盘了。想想是不是有点小激动啊。

  我这一小节就不讲那么高级的东西,就先了解文件怎么传输,我们以前的聊天程序传输数据都是一次发送就完成本次的发送,因为一个sendBuf是足够的。但是对于二进制文件来说,文件的大小就不一定了,有可能很大,所以我们的Buf是不知道要多少的。所以要传输大文件,就要分多次传输,然后在目的地进行合并。这样就可以实现大文件传输了。传输的方法有两种,一种是串行一种是并行。我接下来要实现的代码是使用串行传输的,因为比较简单,而并行传输,比较复杂,要传输几个控制信号,保证数据合并重整后不会出错。并行可以使用多进(线)程。优点是可以同时传输多个文件,串行是只能一次传输一个文件。我们看一下网盘,大多是可以下载多个文件(多任务)是吧?应该用的就是并行了。如果只是从原理上讲串行的传输速度肯定是比并行的快,因为并行还要控制信号要传,而且还要重新合并整合成一个文件。既然这样那为什么所有的网盘都是使用多任务下载呢?(多个任务同时下载,每个任务同时还有多个端口在接收数据)。是因为我们所处的网络环境问题。我们的网络环境并不是那么的稳定,如果只是用一个端口进行串行传输,那么如果网络突然中断或者什么原因,导致服务器与客户端暂时连接断开。那么我们之前传的数据就要重传了。这就是为什么今天下载个任务到80%,然后明天还可以接着下载了。如果是一次性串行传输就不行了。你就会问,那在串行传输再加个控制信号不就行了?那这样的话,与并行区别就不大了。

  废话说了一大堆,到了真正要写代码的时候我还是使用串行来写,因为比较容易实现。(求原谅!)

  实现客户端向服务器发送一个指定的二进制文件

  client.cpp (为什么用cpp了,因为上次用c,然后代码越写越多,结果很多变量都写在开头,找起来不是很方便,所以用cpp了,哎,用c++就是为了用这个,会不会被骂?)

复制代码
 1 #include <netinet/in.h> // sockaddr_in
 2 #include <sys/types.h> //socket
 3 #include <sys/socket.h> //socket
 4 #include <netdb.h> //gethostbyname
 5 #include <unistd.h> //close
 6 #include <stdio.h>
 7 #include <stdlib.h>
 8 #include <string.h>
 9 #include <time.h>
10 #include <arpa/inet.h> //inet_addr
11 
12 #define SERVVER_PORT 12138
13 #define LISTEN_QUEUE 20
14 #define BUFFER_SIZE 1024
15 
16 struct Addr
17 {
18     char host[64];
19     int port;
20 };
21 
22 int file_push(struct Addr addr,char *filenames)
23 {
24     struct sockaddr_in servAddr;
25     struct hostent * host;
26     int sockfd;
27     FILE *fp;
28 
29     host=gethostbyname(addr.host);
30     servAddr.sin_family=AF_INET;
31     servAddr.sin_addr=*((struct in_addr *)host->h_addr);
32     //servAddr.sin_addr.s_addr=inet_addr("127.0.0.1");
33     servAddr.sin_port=htons(addr.port);
34     if(host==NULL)
35     {
36         perror("获取IP地址失败");
37         exit(-1);
38     }
39     if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)
40     {
41         perror("socket创建失败");
42         exit(-1);
43     }
44 
45     if(connect(sockfd,(struct sockaddr *)&servAddr,sizeof(struct sockaddr_in))== -1)
46     {
47         perror("connect 失败");
48         exit(-1);
49     }
50 
51     //打开文件
52     if((fp=fopen(filenames,"rb"))==NULL)
53     {
54         perror("文件打开失败");
55         exit(-1);
56     }
57     char buffer[BUFFER_SIZE];
58     bzero(buffer,BUFFER_SIZE);
59     printf("正在传输文件");
60     int len=0;
61     //不断的读取文件直到文件结束
62     while((len=fread(buffer,1,BUFFER_SIZE,fp))>0)
63     {
64         if(send(sockfd,buffer,len,0)<0)
65         {
66             perror("发送数据失败");
67             exit(-1);
68         }
69         bzero(buffer,BUFFER_SIZE);
70         printf(".");//1K打印一个点//如果要实现百分比,就要计算文件大小,然后再处理即可
71     }
72 
73     fclose(fp);//关闭文件流
74     close(sockfd);//关闭socket连接
75 
76     return 0;
77 }
78 
79 int main(int argc,char *argv[])
80 {
81     char orderbuf[BUFFER_SIZE];
82     char orderch[BUFFER_SIZE];
83     struct Addr addr;
84 
85     strcpy(addr.host,argv[1]);
86     addr.port=atoi(argv[2]);
87     while(1)
88     {
89         printf("\n请输入文件名:");
90         fgets(orderbuf,BUFFER_SIZE,stdin);
91         orderbuf[strlen(orderbuf)-1]=0;//去掉获取到的回车符
92         //printf("%s\n",orderbuf);
93         file_push(addr,orderbuf);
94     }
95 
96     return 0;
97 }
复制代码

  server.cpp

复制代码
  1 #include <netinet/in.h>
  2 #include <sys/types.h>
  3 #include <sys/socket.h>
  4 #include <stdlib.h>
  5 #include <time.h>
  6 #include <string.h>
  7 #include <unistd.h>
  8 #include <stdio.h>
  9 #include <arpa/inet.h> //inet_ntoa
 10 
 11 #define SERVER_PORT 12138
 12 #define LISTEN_QUEUE 20
 13 #define BUFFER_SIZE 1024
 14 
 15 void print_time(char *ch);//打印时间
 16 
 17 int main(int argc,char *argv[])
 18 {
 19     struct sockaddr_in server_addr;
 20     bzero(&server_addr,sizeof(server_addr));
 21     server_addr.sin_family=AF_INET;
 22     server_addr.sin_addr.s_addr=htons(INADDR_ANY);
 23     server_addr.sin_port=htons(SERVER_PORT);
 24 
 25     //创建套接字
 26     int sockfd=socket(AF_INET,SOCK_STREAM,0);
 27     if(sockfd<0)
 28     {
 29         perror("创建套接字失败");
 30         exit(-1);
 31     }
 32 
 33     if(bind(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr))==-1)
 34     {
 35         perror("bind 失败");
 36         exit(-1);
 37     }
 38 
 39     if(listen(sockfd,LISTEN_QUEUE))
 40     {
 41         perror("listen 失败");
 42         exit(-1);
 43     }
 44 
 45     while(1)
 46     {
 47         pid_t pid;
 48         struct sockaddr_in client_addr;
 49         socklen_t length=sizeof(client_addr);
 50         int clientfd=accept(sockfd,(struct sockaddr *)&client_addr,&length);
 51         if(clientfd==-1)
 52         {
 53             perror("accept 失败");
 54             continue;
 55         }
 56         else
 57         {
 58             printf("客户端%s:%d连接成功\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));
 59             pid=fork();
 60             if(pid<0)
 61             {
 62                 perror("创建进程失败");
 63             }
 64             else if(pid==0)/*child*/
 65             {
 66                 char buffer[BUFFER_SIZE];
 67                 int data_len;
 68                 FILE * fp=NULL;
 69                 bzero(buffer,BUFFER_SIZE);
 70                 if((fp=fopen("data","wb"))==NULL)
 71                 {
 72                     perror("文件打开失败");
 73                     exit(-1);
 74                 }
 75                 //循环接收数据
 76                 int size=0;//表示有多少个块
 77                 while(data_len=recv(clientfd,buffer,BUFFER_SIZE,0))//data_len为0时结束,是因为当客户端没有再发送数据过来时是接收0的,也表示该文件传输完毕了。
 78                 {
 79                     if(data_len<0)
 80                     {
 81                         perror("接收数据错误");
 82                         exit(-1);
 83                     }
 84                     size++;
 85                     if(size==1)
 86                     {
 87                         printf("正在接收来自%s:%d的文件\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));
 88                     }
 89                     else
 90                     {
 91                         printf(".");
 92                     }
 93                     //向文件中写入
 94                     int write_len=fwrite(buffer,sizeof(char),data_len,fp);//向文件中写入,默认文件打开时会有一个文件指针进行写入。如果是并行传输就要修改这个文件指针了,还是有点麻烦的,如果是串行的,我们都不用管了,多方便。
 95                     if(write_len>data_len)
 96                     {
 97                         perror("写入数据错误");
 98                         exit(-1);
 99                     }
100                     bzero(buffer,BUFFER_SIZE);
101                 }
102                 if(size>0)
103                 {
104                     printf("\n%s:%d的文件传送完毕\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));
105                 }
106                 else
107                 {
108                     printf("\n%s:%d的文件传送失败\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));//如果传过来的文件大小为0,也是会出现这个错误
109                 }
110                 fclose(fp);
111                 //rename("data","asdf");//这里可以修改文件的名字。保存到服务器的话可以随便改个名字,防止文件名重复
112                 exit(0);
113             }
114             else /*pather*/
115             {
116                 ;
117             }
118         }
119         close(clientfd);
120     }
121 
122     return 0;
123 }
124 
125 void print_time(char *ch)
126 {
127     time_t now;
128     struct tm * stm;
129     time(&now);
130     stm=localtime(&now);
131     sprintf(ch,"%02d:%02d:%02d\n",stm->tm_hour,stm->tm_min,stm->tm_sec);
132     return ;
133 }
复制代码

  两部分的代码都不难理解,关键的代码就是那个while循环了。这个就不给截图了,运行是没有问题。

 

  这篇杜鑫先生的回答很不错,可以看一下: http://www.zhihu.com/question/21591490

  本文地址: http://www.cnblogs.com/wunaozai/p/3886588.html


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

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

相关文章

HDU - 4348To the moon——主席树+区间修改

HDU - 4348To the moon 【题目描述】 【题目分析】 题目中说明每次更新后时间都会加1&#xff0c;而且还会需要查询以前的区间&#xff0c;还会需要返回以前的时间&#xff0c;所以是很裸的主席树。区间查询的话我们同样需要用到lazy标记 通过这道题我发现线段树的操作还是很灵…

进入一个目录需要那些权限

1.文件访问者的分类 文件的访问者具体可分为以下几类&#xff1a; (1)拥有者 (2)组拥有者 (3)其他用户 这些都代表什么意思呢&#xff1f; 其中r表示只读&#xff0c;w表示只写&#xff0c;x表示可执行&#xff0c;第一个字母代表了文件的类型&#xff0c;其中文件类型可以分为…

Socket网络编程--小小网盘程序(2)

http://www.cnblogs.com/wunaozai/p/3887728.html 这一节将不会介绍太多的技术的问题&#xff0c;这节主要是搭建一个小小的框架&#xff0c;为了方便接下来的继续编写扩展程序。本次会在上一小节的基础上加上一个身份验证的功能。 因为网盘程序不像聊天程序&#xff0c;网盘是…

Linux下的重要目录

1.bin目录 主要防止系统下的各种必备可执行文件 2./proc 目录 这个目录相当于Windows下的计算机系统信息查看以及进程动态查看&#xff0c;可以查看计算机信息&#xff0c;用来存放当前计算机上的进程信息 3./sys 目录 (1)其中block目录用于存放块设备文件 (2)bus存放总线类型…

HDU - 6278 Just $h$-index主席树+二分

HDU - 6278 Just hhh-index 【题目描述】 【题目分析】 题目要求在区间[l,r][l,r][l,r]内大于h的数不少于h个&#xff0c;对于这种最大化问题&#xff0c;我们应该想到二分。 最小情况显然是1.最大情况显然是r−l1r-l1r−l1&#xff0c;对于一个hhh&#xff0c;我们如何判断能…

Socket网络编程--小小网盘程序(3)

http://www.cnblogs.com/wunaozai/p/3891062.html 接上一小节&#xff0c;这次增加另外的两张表&#xff0c;用于记录用户是保存那些文件。增加传上来的文件的文件指纹&#xff0c;使用MD5表示。 两张表如下定义: 1 create table files(2 fid int,3 filename varchar(64),4 md…

LInux下du, df, top, free, pstack, su, sudo, adduser, password命令

1.du命令&#xff1a;du [选项] 文件 (1)功能该命令是显示指定文件以及下的所有文件占用系统数据块的情况&#xff0c;如果没有文件&#xff0c;默认为是当前工作目录 -a    显示所有文件对系统数据块的使用情况 -b    显示数据块大小时以字节为基本单位 -c    除了显…

HDU - 5919 Sequence II——主席树+区间种类++逆序建树

【题目描述】 HDU - 5919 Sequence II 【题目分析】 题目给定一个数组&#xff0c;每次查询一个区间&#xff0c;找出区间内不同数字的个数x&#xff0c;然后输出按出现顺序第x/2向上取整个数字的位置。 按照要求&#xff0c;我们首先需要能够找出给定区间不同的数字个数。 首…

Socket网络编程--小小网盘程序(4)

http://www.cnblogs.com/wunaozai/p/3892729.html 在这一小节中实现了文件的下载&#xff0c;具体的思路是根据用户的uid和用户提供的文件名filename联合两张表&#xff0c;取得md5唯一标识符&#xff0c;然后操作这个标识符对应的文件发送给客户端。 实现下载的小小网盘程序 …

静态顺序表的实现

实现对顺序表的初始化&#xff0c;头插&#xff0c;头删&#xff0c;尾插&#xff0c;尾删&#xff0c; 任意下标的删除&#xff0c; 任意下标处的的元素删除&#xff0c;任意下标处的元素插入&#xff0c;任意元素的下标返回&#xff0c;任意下标处的元素返回&#xff0c; 删除…

树链剖分入门+HYSBZ - 1036树的统计Count

今天学习了树链剖分&#xff0c;记录一下。 【题目背景】 HYSBZ - 1036树的统计Count 【题目分析】 题目要求求任意结点之间路径的和以及路径上最大的结点&#xff0c;还有可能修改。如果正常做可能会很复杂&#xff08;我也不知道正常应该怎么做&#xff0c;应该要用到LCA什么…

Socket网络编程--小小网盘程序(5)

http://www.cnblogs.com/wunaozai/p/3893469.html 各位好呀&#xff01;这一小节应该就是这个小小网盘程序的最后一小节了&#xff0c;这一节将实现最后的三个功能&#xff0c;即列出用户在服务器中的文件列表&#xff0c;还有删除用户在服务器中的文件&#xff0c;最后的可以共…

进程相关概念

1.进程相关概念 进程是代码的一次动态执行&#xff0c;担当分配系统资源的角色&#xff0c;进程信息是被放在一个一个数据结构中&#xff0c;是一个结构体task_struct 2.进程控制块内容 //linux下的进程控制块 struct task_struct {volatile long state;// 说明了该进程是否可以…

SPOJ - QTREE3Query on a tree again!——树链剖分

【题目描述】 SPOJ - QTREE3Query on a tree again! 【题目分析】 题目要求是输出从111到xxx的路径上遇到的第一个黑色的点。我们可以用树链剖分&#xff08;不了解的同学请出门左拐&#xff0c;详见树链剖分入门&#xff09; 我们用线段树维护每个区间第一次遇到黑点的位置&a…

C++中的函数指针和函数对象总结

http://www.cnblogs.com/lvpengms/archive/2011/02/21/1960078.html 篇一、函数指针 函数指针&#xff1a;是指向函数的指针变量&#xff0c;在C编译时&#xff0c;每一个函数都有一个入口地址&#xff0c;那么这个指向这个函数的函数指针便指向这个地址。 函数指针的用途是很…

开发工具

1.编辑器 &#xff08;1&#xff09;vim     vim是从vi发展出来的一个文本编辑器。代码补完、编译错误跳转等方便编程的功能特别丰富&#xff0c;在程序员中被广泛使用。 &#xff08;2&#xff09;sed     sed是一种流编辑器&#xff0c;它一次处理一行内容。处理时…

c++ 智能指针用法详解

http://www.cnblogs.com/TenosDoIt/p/3456704.html 本文介绍c里面的四个智能指针: auto_ptr, shared_ptr, weak_ptr, unique_ptr 其中后三个是c11支持&#xff0c;并且第一个已经被c11弃用。 为什么要使用智能指针&#xff1a;我们知道c的内存管理是让很多人头疼的事&#xff0…

CodeForces - 786BLegacy——线段树建图+最短路

【题目描述】 CodeForces - 786BLegacy 【题目分析】 题目大概意思就是有三种操作&#xff1a; 从某个点到另一个点从某个点到另一个区间从某个区间到另一个点 然后询问从其中一个点到其他所有点的距离——这很显然是一个求单源最短路径的。我们简单的想法显然是建一个图&a…

自主编写shell

1.替换原理 用fork创建子进程后执行的是和父进程相同的程序&#xff08;但有可能执行不同的代码分支&#xff09;&#xff0c;子进程往往要调用一种exec函数以执行例外一个程序。当进程调用一种exec函数时&#xff0c;该进程的用户空间代码和数据完全被新程序替换&#xff0c;从…

HYSBZ - 2243染色——树链剖分+线段树建树技巧

【题目描述】 HYSBZ - 2243染色 【题目分析】 我一直没有看清楚题&#xff0c;以为求的是路径上出现颜色的种类&#xff0c;然后就写了一个区间染色的线段树进行维护&#xff0c;过样例的时候才发现题读错了&#xff0c;人家要求的是路径上出现的颜色段&#xff0c;所以颜色的…