登录
当前位置： 首页 > 编程笔记 >

Linux网络编程之基于UDP实现可靠的文件传输示例

花飞扬
2023-03-14
本文向大家介绍Linux网络编程之基于UDP实现可靠的文件传输示例，包括了Linux网络编程之基于UDP实现可靠的文件传输示例的使用技巧和注意事项，需要的朋友参考一下

了解网络传输协议的人都知道，采用TCP实现文件传输很简单。相对于TCP，由于UDP是面向无连接、不可靠的传输协议，所以我们需要考虑丢包和后发先至（包的顺序）的问题，所以我们想要实现UDP传输文件，则需要解决这两个问题。方法就是给数据包编号，按照包的顺序接收并存储，接收端接收到数据包后发送确认信息给发送端，发送端接收确认数据以后再继续发送下一个包，如果接收端收到的数据包的编号不是期望的编号，则要求发送端重新发送。

下面展示的是基于linux下C语言实现的一个示例程序，该程序定义一个包的结构体，其中包含数据和包头，包头里包含有包的编号和数据大小，经过测试后，该程序可以成功传输一个视频文件。

具体实现代码如下：

server端代码如下：

/************************************************************************* 
  > File Name: server.c 
  > Author: SongLee 
 ************************************************************************/ 
#include<sys/types.h> 
#include<sys/socket.h> 
#include<unistd.h> 
#include<netinet/in.h> 
#include<arpa/inet.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<errno.h> 
#include<netdb.h> 
#include<stdarg.h> 
#include<string.h> 
 
#define SERVER_PORT 8000 
#define BUFFER_SIZE 1024 
#define FILE_NAME_MAX_SIZE 512 
 
/* 包头 */ 
typedef struct 
{ 
  int id; 
  int buf_size; 
}PackInfo; 
 
/* 接收包 */ 
struct SendPack 
{ 
  PackInfo head; 
  char buf[BUFFER_SIZE]; 
} data; 
 
 
int main() 
{ 
  /* 发送id */ 
  int send_id = 0; 
 
  /* 接收id */ 
  int receive_id = 0; 
 
  /* 创建UDP套接口 */ 
  struct sockaddr_in server_addr; 
  bzero(&server_addr, sizeof(server_addr)); 
  server_addr.sin_family = AF_INET; 
  server_addr.sin_addr.s_addr = htonl(INADDR_ANY); 
  server_addr.sin_port = htons(SERVER_PORT); 
 
  /* 创建socket */ 
  int server_socket_fd = socket(AF_INET, SOCK_DGRAM, 0); 
  if(server_socket_fd == -1) 
  { 
    perror("Create Socket Failed:"); 
    exit(1); 
  } 
 
  /* 绑定套接口 */ 
  if(-1 == (bind(server_socket_fd,(struct sockaddr*)&server_addr,sizeof(server_addr)))) 
  { 
    perror("Server Bind Failed:"); 
    exit(1); 
  } 
 
  /* 数据传输 */ 
  while(1) 
  {   
    /* 定义一个地址，用于捕获客户端地址 */ 
    struct sockaddr_in client_addr; 
    socklen_t client_addr_length = sizeof(client_addr); 
 
    /* 接收数据 */ 
    char buffer[BUFFER_SIZE]; 
    bzero(buffer, BUFFER_SIZE); 
    if(recvfrom(server_socket_fd, buffer, BUFFER_SIZE,0,(struct sockaddr*)&client_addr, &client_addr_length) == -1) 
    { 
      perror("Receive Data Failed:"); 
      exit(1); 
    } 
 
    /* 从buffer中拷贝出file_name */ 
    char file_name[FILE_NAME_MAX_SIZE+1]; 
    bzero(file_name,FILE_NAME_MAX_SIZE+1); 
    strncpy(file_name, buffer, strlen(buffer)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer)); 
    printf("%s\n", file_name); 
 
    /* 打开文件 */ 
    FILE *fp = fopen(file_name, "r"); 
    if(NULL == fp) 
    { 
      printf("File:%s Not Found.\n", file_name); 
    } 
    else 
    { 
      int len = 0; 
      /* 每读取一段数据，便将其发给客户端 */ 
      while(1) 
      { 
        PackInfo pack_info; 
 
        if(receive_id == send_id) 
        { 
          ++send_id; 
          if((len = fread(data.buf, sizeof(char), BUFFER_SIZE, fp)) > 0) 
          { 
            data.head.id = send_id; /* 发送id放进包头,用于标记顺序 */ 
            data.head.buf_size = len; /* 记录数据长度 */ 
            if(sendto(server_socket_fd, (char*)&data, sizeof(data), 0, (struct sockaddr*)&client_addr, client_addr_length) < 0) 
            { 
              perror("Send File Failed:"); 
              break; 
            } 
            /* 接收确认消息 */ 
            recvfrom(server_socket_fd, (char*)&pack_info, sizeof(pack_info), 0, (struct sockaddr*)&client_addr, &client_addr_length); 
            receive_id = pack_info.id;  
          } 
          else 
          { 
            break; 
          } 
        } 
        else 
        { 
          /* 如果接收的id和发送的id不相同,重新发送 */ 
          if(sendto(server_socket_fd, (char*)&data, sizeof(data), 0, (struct sockaddr*)&client_addr, client_addr_length) < 0) 
          { 
            perror("Send File Failed:"); 
            break; 
          } 
          /* 接收确认消息 */ 
          recvfrom(server_socket_fd, (char*)&pack_info, sizeof(pack_info), 0, (struct sockaddr*)&client_addr, &client_addr_length); 
          receive_id = pack_info.id;  
        } 
      } 
      /* 关闭文件 */ 
      fclose(fp); 
      printf("File:%s Transfer Successful!\n", file_name); 
    } 
  } 
  close(server_socket_fd); 
  return 0; 
}

client端代码如下：

/************************************************************************* 
  > File Name: client.c 
  > Author: SongLee 
 ************************************************************************/ 
#include<sys/types.h> 
#include<sys/socket.h> 
#include<unistd.h> 
#include<netinet/in.h> 
#include<arpa/inet.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<errno.h> 
#include<netdb.h> 
#include<stdarg.h> 
#include<string.h> 
 
#define SERVER_PORT 8000 
#define BUFFER_SIZE 1024 
#define FILE_NAME_MAX_SIZE 512 
 
/* 包头 */ 
typedef struct  
{ 
  int id; 
  int buf_size; 
}PackInfo; 
 
/* 接收包 */ 
struct RecvPack 
{ 
  PackInfo head; 
  char buf[BUFFER_SIZE]; 
} data; 
 
 
int main() 
{ 
  int id = 1; 
 
  /* 服务端地址 */ 
  struct sockaddr_in server_addr; 
  bzero(&server_addr, sizeof(server_addr)); 
  server_addr.sin_family = AF_INET; 
  server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); 
  server_addr.sin_port = htons(SERVER_PORT); 
  socklen_t server_addr_length = sizeof(server_addr); 
 
  /* 创建socket */ 
  int client_socket_fd = socket(AF_INET, SOCK_DGRAM, 0); 
  if(client_socket_fd < 0) 
  { 
    perror("Create Socket Failed:"); 
    exit(1); 
  } 
 
  /* 输入文件名到缓冲区 */ 
  char file_name[FILE_NAME_MAX_SIZE+1]; 
  bzero(file_name, FILE_NAME_MAX_SIZE+1); 
  printf("Please Input File Name On Server: "); 
  scanf("%s", file_name); 
 
  char buffer[BUFFER_SIZE]; 
  bzero(buffer, BUFFER_SIZE); 
  strncpy(buffer, file_name, strlen(file_name)>BUFFER_SIZE?BUFFER_SIZE:strlen(file_name)); 
 
  /* 发送文件名 */ 
  if(sendto(client_socket_fd, buffer, BUFFER_SIZE,0,(struct sockaddr*)&server_addr,server_addr_length) < 0) 
  { 
    perror("Send File Name Failed:"); 
    exit(1); 
  } 
 
  /* 打开文件，准备写入 */ 
  FILE *fp = fopen(file_name, "w"); 
  if(NULL == fp) 
  { 
    printf("File:\t%s Can Not Open To Write\n", file_name);  
    exit(1); 
  } 
 
  /* 从服务器接收数据，并写入文件 */ 
  int len = 0; 
  while(1) 
  { 
    PackInfo pack_info; 
 
    if((len = recvfrom(client_socket_fd, (char*)&data, sizeof(data), 0, (struct sockaddr*)&server_addr,&server_addr_length)) > 0) 
    { 
      if(data.head.id == id) 
      { 
        pack_info.id = data.head.id; 
        pack_info.buf_size = data.head.buf_size; 
        ++id; 
        /* 发送数据包确认信息 */ 
        if(sendto(client_socket_fd, (char*)&pack_info, sizeof(pack_info), 0, (struct sockaddr*)&server_addr, server_addr_length) < 0) 
        { 
          printf("Send confirm information failed!"); 
        } 
        /* 写入文件 */ 
        if(fwrite(data.buf, sizeof(char), data.head.buf_size, fp) < data.head.buf_size) 
        { 
          printf("File:\t%s Write Failed\n", file_name); 
          break; 
        } 
      } 
      else if(data.head.id < id) /* 如果是重发的包 */ 
      { 
        pack_info.id = data.head.id; 
        pack_info.buf_size = data.head.buf_size; 
        /* 重发数据包确认信息 */ 
        if(sendto(client_socket_fd, (char*)&pack_info, sizeof(pack_info), 0, (struct sockaddr*)&server_addr, server_addr_length) < 0) 
        { 
          printf("Send confirm information failed!"); 
        } 
      } 
      else 
      { 
 
      } 
    } 
    else 
    { 
      break; 
    } 
  } 
 
  printf("Receive File:\t%s From Server IP Successful!\n", file_name); 
  fclose(fp); 
  close(client_socket_fd); 
  return 0; 
}

感兴趣的朋友可以动手测试一下该程序，相信会对大家的Linux下C语言网络编程带来一定的帮助。

 类似资料：
  • Linux网络编程之socket文件传输示例

    本文向大家介绍Linux网络编程之socket文件传输示例，包括了Linux网络编程之socket文件传输示例的使用技巧和注意事项，需要的朋友参考一下 本文所述示例程序是基于Linux平台的socket网络编程，实现文件传输功能。该示例是基于TCP流协议实现的socket网络文件传输程序。采用C语言编写。最终能够实现传输任何格式文件的文件传输程序。 具体实现代码如下： Server端代码如下： C

  • Windows网络编程之winsock实现文件传输示例

    本文向大家介绍Windows网络编程之winsock实现文件传输示例，包括了Windows网络编程之winsock实现文件传输示例的使用技巧和注意事项，需要的朋友参考一下 本文实例展示了Windows网络编程中winsock实现文件传输的方法，对于进行Windows下的winsock网络编程有一定的借鉴参考价值。 该程序代码主要是基于TCP流协议的winsock网络文件传输示例，采用Windows

  • Linux网络编程之UDP Socket程序示例

    本文向大家介绍Linux网络编程之UDP Socket程序示例，包括了Linux网络编程之UDP Socket程序示例的使用技巧和注意事项，需要的朋友参考一下 在网络传输协议中，TCP协议提供的是一种可靠的，复杂的，面向连接的数据流（SOCK_STREAM）传输服务，它通过三段式握手过程建立连接。TCP有一种“重传确认”机制，即接收端收到数据后要发出一个肯定确认的信号，发送端如果收到接收端肯定确认

  • python网络编程之数据传输UDP实例分析

    本文向大家介绍python网络编程之数据传输UDP实例分析，包括了python网络编程之数据传输UDP实例分析的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了python网络编程之数据传输UDP实现方法。分享给大家供大家参考。具体分析如下： 一、问题： 你觉得网络上像msn，qq之类的工具在多台机器之间互相传输数据神秘吗？你也想玩一下在两台机器之间传数据吗？今天让python告诉我们基本原

  • Python实现基于HTTP文件传输实例

    本文向大家介绍Python实现基于HTTP文件传输实例，包括了Python实现基于HTTP文件传输实例的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了Python实现基于HTTP文件传输的方法。分享给大家供大家参考。具体实现方法如下： 一、问题： 因为需要最近看了一下通过POST请求传输文件的内容 并且自己写了Server和Client实现了一个简单的机遇HTTP的文件传输工具 二、实现代

  • 3. 基于UDP协议的网络程序

    3. 基于UDP协议的网络程序 下图是典型的UDP客户端/服务器通讯过程（该图出自[UNPv13e]）。 图 37.3. UDP通讯流程 以下是简单的UDP服务器和客户端程序。 /* server.c */ #include <stdio.h> #include <string.h> #include <netinet/in.h> #include "wrap.h" #define MAXLIN

相关阅读

Python实现基于HTTP文件传输实例linux 网络编程 socket选项的实现python网络编程之文件下载实例分析Lua下基本的网络编程示例Linux编程之PING实现

相关文章

网络流的基本概念PyTorch神经网络基础华讯网络25届网络工程师日常实习二面华讯网络25届网络工程师日常实习一面RESTful JAX-RS文件上传示例

相关问答

为什么我的网络TCP/UDP实现不起作用？硒网络驱动程序上传文件 C#基于Keras的卷积神经网络输入形状流式传输中的网络洗牌可靠的消息传递

相关工具

《Go编程基础》《Julia 编程基础》基于BeeFramework的表格控件Pion网络库iOS 多线程编程实例

相关文档

Go 网络编程网络基本功系列深入理解 OpenStack 网络实现 NeutronShell 编程基础Gdip 编程基础
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.