2. 程式人生 > >基於TCP伺服器檔案上傳與下載

基於TCP伺服器檔案上傳與下載

阿新 • • 發佈：2018-11-19 
**

## service.c

**

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>     
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include <sys/types.h>
#include <dirent.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#define  N  128


int process_list(int newsockfd,char *buf)
{

    DIR * dirp;
    int ret;
    struct dirent * direntp;
    dirp = opendir("./");
    if(dirp == NULL)
    {
        perror("opendir");
        exit(-1);
    }
    while( (direntp = readdir(dirp)) != NULL)
    {
        if(strncmp(direntp->d_name,".",1) == 0 ) continue; 
        strcpy(buf,direntp->d_name);
        ret = write(newsockfd,buf,N);
        if(ret < 0)
        {
            perror("write");
            exit(-1);
        }
    }
    close(newsockfd);


    return 0;
}
int process_get(int newsockfd,char *buf)
{

    int ret,fd,nbytes;

    fd = open(buf+4,O_RDWR);
    if(fd < 0)
    {
        perror("open");
        exit(-1);
    }
    while( (nbytes= read(fd,buf,N)) > 0)
    {
        ret = write(newsockfd,buf,nbytes);
        if(ret < 0)
        {
            perror("write");
            exit(-1);
        }
    }
    close(newsockfd);


    return 0;
}
int process_put(int newsockfd,char *buf)
{

    int ret,fd,nbytes;

    fd = open(buf+4,O_RDWR|O_CREAT|O_TRUNC,0664);
    if(fd < 0)
    {
        perror("open");
        exit(-1);
    }
    while( (nbytes= read(newsockfd,buf,N)) > 0)
    {
        ret = write(fd,buf,nbytes);
        if(ret < 0)
        {
            perror("write");
            exit(-1);
        }
    }
    close(newsockfd);
    close(fd);


    return 0;
}
int main(int argc, const char *argv[])
{
    char buf[N] ={0};
    int sockfd,ret,newsockfd;
    struct sockaddr_in myaddr,client;
    if(argc != 3)
    {
        printf("執行程式時帶入ip 和 port\n");
        exit(-1);
    }
    socklen_t addrlen = sizeof(client);
    sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(sockfd < 0)
    {
        perror("socket");
        exit(-1);
    }
    printf("sockfd=%d\n",sockfd);
    memset(&myaddr,0,sizeof(myaddr));
    myaddr.sin_family = AF_INET ;
    myaddr.sin_port   = htons(atoi(argv[2]));
    myaddr.sin_addr.s_addr   = inet_addr(argv[1]); 
    ret = bind(sockfd,(struct sockaddr *)&myaddr,sizeof(myaddr)) ; // 給socket 一個固定的ip 和埠 
    if(ret < 0)
    {
        perror("bind");
        exit(-1);
    }
    ret = listen(sockfd,10);
    if(ret < 0)
    {
        perror("listen");
        exit(-1);
    }
    while(1)
    {
        newsockfd = accept(sockfd,(struct sockaddr *)&client,&addrlen) ; 
        if(newsockfd < 0)
        {
            printf("accept");
            exit(-1);
        }
        printf("newsockfd = %d\n",newsockfd);
        ret = read(newsockfd,buf,N);
        if(ret  < 0)
        {
            printf("read");
            exit(-1);
        }
        printf("buf=%s\n",buf);
        if( strncmp(buf,"list",4) == 0 ) 
        {
            process_list(newsockfd,buf);
        }
        else if( strncmp(buf,"get",3) == 0 ) 
        {
            process_get(newsockfd,buf);
        }
        else if( strncmp(buf,"put",3) == 0 ) 
        {
            process_put(newsockfd,buf);
        }
    }


    
    return 0;
}


 

## client.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>       
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#define  N  128 


int process_list(struct sockaddr_in *addr,char * buf)
{
    int ret,sockfd,nbytes;
    sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(sockfd < 0)
    {
        perror("socket");
        exit(-1);
    }
    ret = connect(sockfd,(struct sockaddr *)addr,sizeof(*addr)) ;
    if(ret < 0)
    {
        perror("connect");
        exit(-1);
    }
    ret = write(sockfd,buf,N);
    if(ret < 0)
    {
        perror("write");
        exit(-1);
    }
    while( (nbytes= read(sockfd,buf,N)) > 0)
    {
        printf("%s\n",buf);
    }
    close(sockfd);

    return 0;
}
int process_get(struct sockaddr_in *addr,char * buf)
{
    int ret,sockfd,nbytes,fd;
    sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(sockfd < 0)
    {
        perror("socket");
        exit(-1);
    }
    ret = connect(sockfd,(struct sockaddr *)addr,sizeof(*addr)) ;
    if(ret < 0)
    {
        perror("connect");
        exit(-1);
    }
    ret = write(sockfd,buf,N);
    if(ret < 0)
    {
        perror("write");
        exit(-1);
    }
    fd = open(buf+4,O_RDWR|O_CREAT|O_TRUNC,0664);
    if(fd < 0)
    {
        perror("open");
        exit(-1);
    }
    while( (nbytes= read(sockfd,buf,N)) > 0)
    {
        ret = write(fd,buf,nbytes);
        if(ret < 0)
        {
            perror("write");
            exit(-1);
        }
    }
    close(sockfd);
    return 0;
}
int process_put(struct sockaddr_in *addr,char * buf)
{
    int ret,sockfd,nbytes,fd;
    sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(sockfd < 0)
    {
        perror("socket");
        exit(-1);
    }
    ret = connect(sockfd,(struct sockaddr *)addr,sizeof(*addr)) ;
    if(ret < 0)
    {
        perror("connect");
        exit(-1);
    }
    ret = write(sockfd,buf,N);
    if(ret < 0)
    {
        perror("write");
        exit(-1);
    }
    fd = open(buf+4,O_RDWR);
    if(fd < 0)
    {
        perror("open");
        exit(-1);
    }
    while( (nbytes= read(fd,buf,N)) > 0)
    {
        ret = write(sockfd,buf,nbytes);
        if(ret < 0)
        {
            perror("write");
            exit(-1);
        }
    }
    close(sockfd);
    close(fd);
    return 0;
}
int main(int argc, const char *argv[])
{

    char buf[N] = {0};
    int sockfd,ret;
    struct sockaddr_in server,client;
    if(argc != 3)
    {
        printf("執行程式時帶入ip 和 port\n");
        exit(-1);
    }
    memset(&server,0,sizeof(server));
    server.sin_family = AF_INET ;
    server.sin_port   = htons( atoi(argv[2]) );
    server.sin_addr.s_addr   = inet_addr(argv[1]); 
    while(1)
    {
        printf(">:");
        fgets(buf,N,stdin);
        buf[strlen(buf)-1] = '\0';
        if( strncmp(buf,"list",4) == 0 ) 
        {
            process_list(&server,buf);
        }
        else if( strncmp(buf,"get",3) == 0 ) 
        {
            process_get(&server,buf);
        }
        else if( strncmp(buf,"put",3) == 0 ) 
        {
            process_put(&server,buf);
        }
        else if( strncmp(buf,"quit",4) == 0 ) 
        {
            break;
        }
        else if( strncmp(buf,"exit",4) == 0 ) 
        {
            break;
        }
        else 
        {
            printf("命令錯誤，請重新輸入\n");
        }
        
    }


#if 0 
    printf(">:");
    fgets(buf,N,stdin);
    ret  = write(sockfd,buf,N) ;
    if(ret < 0)
    {
        perror("write");
        exit(-1);
    }
    ret = read(sockfd,buf,N);
    if(ret  < 0)
    {
        printf("read");
        exit(-1);
    }
    printf("%s\n",buf);
    close(sockfd);


#endif
    
    return 0;
}

基於tcp的檔案上傳下載伺服器與客戶端的開發;
該專案具體如下：
1、基於tcp伺服器部分
分成三個部分：
第一個是list如果客戶端傳送一個"list",伺服器會將當前的目錄開啟，並將當前的檔名傳送給客戶端介面，供使用者參考。
第二個是get 如果客戶端送一個"get+filename" , 伺服器會開啟當前的filename讀此檔案的所有內容寫入給客戶端。
第三個是put 如果客戶端送一個"put+filename",伺服器會開啟filename如果不存在就建立一個新的檔案否則則截斷清空等待讀客戶端傳送的資料並寫入。
2、客戶端部分
相應的分成三部分
第一部分是list 客戶端選擇的是list 首先是將選擇的命令傳送給伺服器，之後就等待獲取當前伺服器上有所有有效檔案的檔名。
第二部分是get 客戶端選擇是"get+filename" 將在客戶端方，開啟或是建立一個同伺服器相同的filename檔案，並讀取伺服器傳送的資料寫入當前filename檔案。
第三部分是put 客戶端選擇是"put+filename" 開啟要上傳的檔案，將資料讀出傳送到伺服器。

相關推薦

基於TCP伺服器檔案上傳與下載

** ## service.c ** #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/types.h> #include &l

Java基於TCP協議的Socket客戶端檔案上傳與下載

import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.F

【Ceph】基於Tornado的Ceph檔案上傳與下載及線上預覽

概述 用tornado作為http伺服器 在處理post/get請求的方法中，呼叫librados(python)介面實現讀寫 設定Content-disposition中為inline則線上瀏覽，

Http伺服器實現檔案上傳與下載(二)

一、引言 歡迎大家接著看我的部落格，如何大家有什麼想法的話回覆我哦，閒話不多聊了，接著上一講的內容來說吧，在上一節中已經講到了請求頭字串的解析，並且在解析中我我們已經獲取了url。就是上節中提到的/doing。當瀏覽器傳送了/doing請求後，這是的與伺服器的連線並沒有

Http伺服器實現檔案上傳與下載(五)

一、引言      歡迎大家和我一起編寫Http伺服器實現檔案的上傳和下載，現在我回顧一下在上一章節中提到的一些內容，之前我已經提到過檔案的下載，在檔案的下載中也提到了檔案的續下載只需要在響應頭中填寫Content-Range這一欄位，並且伺服器的檔案指標指向讀取的指定

Http伺服器實現檔案上傳與下載(一)

一、引言 　　大家都知道web程式設計的協議就是http協議，稱為超文字傳輸協議。在J2EE中我們可以很快的實現一個Web工程，但在C++中就不是非常的迅速，原因無非就是底層的socket網路編寫需要自己完成，上層的http協議需要我們自己完成，使用者介面需要我們自己完

Http伺服器實現檔案上傳與下載(三)

一、引言 　　在前2章的內容基本上已經講解了整個的大致流程。在設計Http伺服器時，我設計為四層的結構，最底層是網路傳輸層，就是socket程式設計。接著一層是請求和響應層，叫做Request和Response。在上一層是URL解析流程走向層。最頂層我設計為索引層。這一層主要多檔案時對檔案進行記憶體上的索引

Http伺服器實現檔案上傳與下載(四)

一、引言 　　歡迎大家來到和我一起編寫Http伺服器實現檔案的上傳和下載，現在我稍微回顧一下之前我說的，第一、二章說明說明了整體的HTTP走向，第三章實現底層的網路程式設計。接著這一章我想給大家講的是請求獲取，和響應傳送的內容。這裡主要講解的響應內容，為什麼？因為我們編寫的是一個與瀏覽器互動的HTTP伺服器

基於js-ipfs-api實現ipfs的檔案上傳與下載

配置本地的ipfs節點 # 初始化ipfs節點 ipfs init # 執行ipfs節點 ipfs daemon 使用js-ipfs-api呼叫ipfs服務 連線本地ipfs節點 const ipfsAPI = require('ip

C# 之 FTP伺服器中檔案上傳與下載（二）

        通過上一篇部落格《C# 之 FTP伺服器中檔案上傳與下載（一）》，我們已經建立好了一個FTP伺服器，並且該伺服器需要使用者名稱和密碼的驗證。今天我們來實現檔案的上傳。 首先，我們前臺需要一個FileUpload控制元件和一個Button控制元件 <

struts2實現檔案上傳與下載功能

一、Demo介紹 基於struts2框架，實現多檔案的上傳和下載功能。 實現原理圖： 部分介面圖： 上傳成功及下載頁面： 二、主要程式碼 uploadFile.jsp:在form表單中包含一個文字框（上傳使用者的姓名）和兩個檔案上傳選項. <%@

Spring Boot——檔案上傳與下載

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apac

java web檔案上傳與下載

jsp程式碼（檔案上傳） <form id="upLoad" method="post">

struts2 檔案上傳與下載

檔案上傳： 三種上傳方案 虛擬路徑與真實路徑 /upload copyFile與copydirectory 檔案上傳的三種方案 1.將上傳的檔案以二進位制的形式存放到資料庫 oa系統 activiti工作流框架 2.將檔案上傳到檔案伺服器（硬碟足夠大）中 3.上傳到t

struts的檔案上傳與下載

struts的檔案上傳與下載後臺程式碼 package interceptor; import java.io.File; import java.io.IOException;import org.apache.commons.io.FileUtils; import web.Base

java：檔案上傳與下載

一.檔案上傳 1.注意： jsp提交方式必須為post 必須採用複雜格式 : enctype=“multipart/form-data” <form action="/upload" method="post" enctype="multipart/form

Spring 中的檔案上傳與下載控制

先建立根應用上下文配置，WebDemo/src/main/java/com/seliote/webdemo/config/RootContextConfig.java package com.seliote.webdemo.config; import org.springframework.c

Struts 2 檔案上傳與下載

單個檔案上傳 表單設定enctype="multipart/form-data“ 表單設定method="POST“ <s:file name="f1" label="logo"/> 多檔案上傳： 把所有的屬性改為陣列即可。 private File []f1;

Spring Boot 整合之檔案上傳與下載

1.匯入依賴 <dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId>

Java進階學習第十三天（檔案上傳與下載、JavaMail郵件開發）

一、檔案上傳與下載 1、檔案上傳 案例：登錄檔單/儲存商品等相關模組！ 頭像 / 商品圖片（資料庫：儲存圖片路徑 / 圖片儲存到伺服器中指定的目錄） 2、檔案上傳要點 ① 表單提交方式：post ② 表單中有檔案上傳的表單項： <input type=”file” />