devbox
Li_阴宅
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

坐牢第二十六天（tftp文件传输）

作者：Li_阴宅 | 2024-08-18 18:55:28

赞

踩

坐牢第二十六天（tftp文件传输）

1.基于UDP的TFTP文件传输

1）tftp协议概述

简单文件传输协议，适用于在网络上进行文件传输的一套标准协议，使用UDP传输

特点：

是应用层协议

基于UDP协议实现

数据传输模式

octet：二进制模式（常用）

mail：已经不再支持

2）tftp下载模型

TFTP通信过程总结

服务器在69号端口等待客户端的请求

服务器若批准此请求，则使用 临时端口 与客户端进行通信。

每个数据包的编号都有变化（从1开始）

每个数据包都要得到ACK的确认，如果出现超时，则需要重新发送最后的数据包或ACK包

数据长度以512Byte传输的，小于512Byte的数据意味着数据传输结束。

3）tftp协议分析

 4）代码

main.c

  1. #include "tftp.h"
  2. int main(int argc, char const *argv[])
  3. {
  4.     while (1)
  5.     {
  6.         // 菜单
  7.         printf("*******************\n");
  8.         printf("******1:下载*******\n");
  9.         printf("******2:上传*******\n");
  10.         printf("******0:退出*******\n");
  11.         printf("*******************\n");
  12.         int a = -1;
  13.         printf("请输入要进行的功能:");
  14.         scanf("%d", &a);
  15.         switch (a)
  16.         {
  17.         case 1:
  18.         {
  19.             // 调用下载函数
  20.             if (download() == -1)
  21.             {
  22.                 perror("下载失败");
  23.                 return -1;
  24.             }
  25.             printf("请输入任意字符后按回车键继续...");
  26.             getchar();       // 等待用户输入一个字符
  27.             system("clear"); // 清空终端（在Linux系统中）
  28.         }
  29.         break;
  30.         case 2:
  31.         {
  32.             // 调用上传函数
  33.             if (upload() == -1)
  34.             {
  35.                 perror("上传失败");
  36.                 return -1;
  37.             }
  38.             printf("请输入任意字符后按回车键继续...");
  39.             getchar();       // 等待用户输入一个字符
  40.             system("clear"); // 清空终端（在Linux系统中）
  41.         }
  42.         break;
  43.         case 0:
  44.         {
  45.             goto END;
  46.         }
  47.         break;
  48.         default:
  49.             printf("请重新输入\n");
  50.             break;
  51.         }
  52.     }
  53.     END:
  54.     return 0;
  55. }

 tfitp.c

  1. #include "tftp.h"
  2. //定义下载文件函数
  3. int download()
  4. {
  5.     // 创建套接字文件
  6.         int cfd = socket(AF_INET, SOCK_DGRAM, 0);
  7.         if (cfd == -1)
  8.         {
  9.             perror("socket error");
  10.             return -1;
  11.         }
  12.         //printf("cfd = %d\n", cfd); // 3
  13.         // 向服务器发送下载请求
  14.         char buf[516] = "";
  15.         short *p1 = (short *)buf; // 操作码
  16.         *p1 = htons(1);
  17.         char *p2 = buf + 2; // 文件名
  18.         printf("请输入要下载的文件名：");
  19.         scanf("%s", p2);
  20.         getchar();
  21.         char *p4 = p2 + strlen(p2) + 1;
  22.         strcpy(p4, "octet");
  23.         int size = 2 + strlen(p2) + strlen(p4) + 2; // 请求包总长度
  24.  
  25.         // 将请求包发送给服务器
  26.         struct sockaddr_in sin;
  27.         sin.sin_family = AF_INET;
  28.         sin.sin_port = htons(SER_PORT);
  29.         sin.sin_addr.s_addr = inet_addr(SER_IP);
  30.  
  31.         sendto(cfd, buf, size, 0, (struct sockaddr *)&sin, sizeof(sin));
  32.         printf("请求包发送成功\n");
  33.  
  34.         // 绑定客户端
  35.         struct sockaddr_in cin;
  36.         cin.sin_family = AF_INET;
  37.         cin.sin_port = htons(CLI_PORT);
  38.         cin.sin_addr.s_addr = inet_addr(CLI_IP);
  39.  
  40.         // 打开要写入的文件
  41.  
  42.         int fd = -1;
  43.         if ((fd = open(p2, O_WRONLY | O_CREAT | O_TRUNC, 0664)) == -1)
  44.         {
  45.             perror("open error");
  46.             return -1;
  47.         }
  48.         // 接收数据包
  49.         char msg[516] = "";
  50.         socklen_t len = sizeof(sin);
  51.         while (1)
  52.         {
  53.             int n = recvfrom(cfd, msg, sizeof(msg), 0, (struct sockaddr *)&sin, &len);
  54.             printf("%d\n",n);
  55.             if (n==-1)
  56.             {
  57.                 perror("recvfrom error");
  58.                 return -1;
  59.             }
  60.             short *p5 = (short *)msg;     // 操作码
  61.             short *p6 = (short *)(msg + 2); // 块编号
  62.             char *p7 = msg + 4;           // 文件内容
  63.             short num = ntohs(*p5);
  64.             short key = ntohs(*p6);
  65.  
  66.             if (num == 3)
  67.             {
  68.                 // 处理数据包
  69.                 write(fd, p7, n-4);
  70.                 // 发送ACK
  71.                 char ack[516] = "";
  72.                 short *p8 = (short *)ack; // 操作码
  73.                 *p8 = htons(4);
  74.                 short *p9 = (short *)(ack + 2); // 块编号
  75.                 *p9 = htons(key);
  76.                 sendto(cfd, ack, 4, 0, (struct sockaddr *)&sin, sizeof(sin));
  77.                 if (n< 516)
  78.                 {
  79.                     printf("文件下载完毕\n");
  80.                     break;
  81.                 }
  82.             }
  83.             else if (num == 5)
  84.             {
  85.                 printf("error\n");
  86.                 break;
  87.             }
  88.         }
  89.         // 关闭文件描述符
  90.         close(cfd);
  91.         close(fd);
  92. }
  93. //定义上传文件函数
  94. int upload()
  95. {
  96.     // 创建套接字文件
  97.         int cfd = socket(AF_INET, SOCK_DGRAM, 0);
  98.         if (cfd == -1)
  99.         {
  100.             perror("socket error");
  101.             return -1;
  102.         }
  103.         printf("cfd = %d\n", cfd); // 3
  104.         // 向服务器发送上传请求
  105.         char buf[516] = "";
  106.         short *p1 = (short *)buf; // 操作码
  107.         *p1 = htons(2);
  108.  
  109.         char *p2 = buf + 2; // 文件名
  110.         printf("请输入要上传的文件名：");
  111.         scanf("%s", p2);
  112.         getchar();
  113.         
  114.         char *p4 = p2 + strlen(p2) + 1;
  115.         strcpy(p4, "octet");
  116.         int size = 2 + strlen(p2) + strlen(p4) + 2; // 请求包总长度
  117.  
  118.         // 将请求包发送给服务器
  119.         struct sockaddr_in sin;
  120.         sin.sin_family = AF_INET;
  121.         sin.sin_port = htons(SER_PORT);
  122.         sin.sin_addr.s_addr = inet_addr(SER_IP);
  123.         socklen_t len = sizeof(sin);//数据包大小
  124.  
  125.         sendto(cfd, buf, size, 0, (struct sockaddr *)&sin, len);
  126.         printf("请求包发送成功\n");
  127.  
  128.         // 绑定客户端
  129.         struct sockaddr_in cin;
  130.         cin.sin_family = AF_INET;
  131.         cin.sin_port = htons(CLI_PORT);
  132.         cin.sin_addr.s_addr = inet_addr(CLI_IP);
  133.  
  134.         // 打开要上传的文件
  135.         int fd = -1;
  136.         if ((fd = open(p2, O_RDONLY)) == -1)
  137.         {
  138.             perror("open error");
  139.             return -1;
  140.         }
  141.         short n = 0;
  142.         while (1)
  143.         {
  144.             // 等待ACK
  145.             if (recvfrom(cfd, buf, sizeof(buf), 0, (struct sockaddr *)&sin, &len) == -1)
  146.             {
  147.                 perror("接收ACK失败");
  148.                 close(fd);
  149.                 return -1;
  150.             }
  151.             // 准备一个要发送的数据包
  152.             char msg[516] = "";
  153.             short *p5 = (short *)msg; // 操作码
  154.             *p5 = htons(3);
  155.             short *p6 = (short *)(msg + 2); // 块编号
  156.           
  157.             *p6 = htons(++n);
  158.             char *p7 = msg + 4; // 文件内容
  159.  
  160.             read(fd, p7, 512);
  161.             int size_msg = 4 + strlen(p7);
  162.  
  163.             // 发送数据包
  164.             sendto(cfd, msg, size_msg, 0, (struct sockaddr *)&sin, len);
  165.             printf("发送成功\n");
  166.  
  167.             // 接收ACK
  168.             char ack[516] = "";
  169.             short *p8 = (short *)ack;     // 操作码
  170.             short *p9 = (short *)(ack + 2); // 块编号
  171.             recvfrom(cfd, ack, 4, 0, (struct sockaddr *)&sin, &len);
  172.  
  173.             // 判断是否上传完毕
  174.             if (strlen(p7) < 512)
  175.             {
  176.                 printf("文件上传完毕\n");
  177.                 break;
  178.             }
  179.         }
  180.         close(cfd);
  181.         close(fd);
  182.         return 0;
  183. }

 

tftp.h

  1. #ifndef TFTP_H
  2. #define TFTP_H
  3. #define SER_PORT 69            // 服务器端口号
  4. #define SER_IP "192.168.0.131" // 服务器ip地址
  5. #define CLI_PORT 5555          // 客户端端口号
  6. #define CLI_IP "192.168.0.105" // 客户端地址
  7. #include<myhead.h>
  8. //定义下载文件函数
  9. int download();
  10. //定义上传文件函数
  11. int upload();
  12. #endif

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Li_阴宅/article/detail/998724
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号