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.pswp.cn/news/384137.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/384137.shtml
英文地址，請注明出處：http://en.pswp.cn/news/384137.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

使用 Verdaccio 構建自己的私有 npm 倉庫

使用 Verdaccio 構建自己的私有 npm 倉庫

前言 無論你是公司的開發者&#xff0c;還是個人開發者&#xff0c;你可能都聽說過或者使用過 npm&#xff0c;這是一個使用廣泛的 JavaScript 包管理器。但是&#xff0c;你是否遇到過以下的問題&#xff1a;你需要一個私有的包存放地方&#xff0c;或者你需要在離線環境下使…
閱讀更多...
HDU - 4348To the moon——主席樹+區間修改

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)

Socket網絡編程--小小網盤程序(2)

http://www.cnblogs.com/wunaozai/p/3887728.html 這一節將不會介紹太多的技術的問題&#xff0c;這節主要是搭建一個小小的框架&#xff0c;為了方便接下來的繼續編寫擴展程序。本次會在上一小節的基礎上加上一個身份驗證的功能。 因為網盤程序不像聊天程序&#xff0c;網盤是…
閱讀更多...
Linux下的重要目錄

Linux下的重要目錄

1.bin目錄 主要防止系統下的各種必備可執行文件 2./proc 目錄 這個目錄相當于Windows下的計算機系統信息查看以及進程動態查看&#xff0c;可以查看計算機信息&#xff0c;用來存放當前計算機上的進程信息 3./sys 目錄 (1)其中block目錄用于存放塊設備文件 (2)bus存放總線類型…
閱讀更多...
HDU - 6278 Just $h$-index主席樹+二分

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)

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命令

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——主席樹+區間種類++逆序建樹

【題目描述】 HDU - 5919 Sequence II 【題目分析】 題目給定一個數組&#xff0c;每次查詢一個區間&#xff0c;找出區間內不同數字的個數x&#xff0c;然后輸出按出現順序第x/2向上取整個數字的位置。 按照要求&#xff0c;我們首先需要能夠找出給定區間不同的數字個數。 首…
閱讀更多...
Socket網絡編程--小小網盤程序(4)

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

樹鏈剖分入門+HYSBZ - 1036樹的統計Count

今天學習了樹鏈剖分&#xff0c;記錄一下。 【題目背景】 HYSBZ - 1036樹的統計Count 【題目分析】 題目要求求任意結點之間路徑的和以及路徑上最大的結點&#xff0c;還有可能修改。如果正常做可能會很復雜&#xff08;我也不知道正常應該怎么做&#xff0c;應該要用到LCA什么…
閱讀更多...
Socket網絡編程--小小網盤程序(5)

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!——樹鏈剖分

【題目描述】 SPOJ - QTREE3Query on a tree again! 【題目分析】 題目要求是輸出從111到xxx的路徑上遇到的第一個黑色的點。我們可以用樹鏈剖分&#xff08;不了解的同學請出門左拐&#xff0c;詳見樹鏈剖分入門&#xff09; 我們用線段樹維護每個區間第一次遇到黑點的位置&a…
閱讀更多...
C++中的函數指針和函數對象總結

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;它一次處理一行內容。處理時…
閱讀更多...
575 div3RGB Substring (hard version)——思維-

575 div3RGB Substring (hard version)——思維-

【題目描述】 The only difference between easy and hard versions is the size of the input. You are given a string s consisting of n characters, each character is ‘R’, ‘G’ or ‘B’. You are also given an integer k . Your task is to change the minimum …
閱讀更多...
c++ 智能指針用法詳解

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——線段樹建圖+最短路

【題目描述】 CodeForces - 786BLegacy 【題目分析】 題目大概意思就是有三種操作&#xff1a; 從某個點到另一個點從某個點到另一個區間從某個區間到另一個點 然后詢問從其中一個點到其他所有點的距離——這很顯然是一個求單源最短路徑的。我們簡單的想法顯然是建一個圖&a…
閱讀更多...
最新文章

Copyright @ 2022~2023