用udp协议传输文件

用udp协议传输文件


目录

• 用udp协议传输文件
  
  
  
  • 头文件/宏定义
    
  • 客户端
    
  • 服务器
    
  
  

头文件/宏定义

1. #include <stdio.h>
2. #include <stdlib.h>
3. #include <string.h>
4. #include
5. #include <netinet/in.h>
6. #include <sys/types.h>
7. #include <sys/socket.h>
8. #include <time.h>
9. #include <pthread.h>
10. #include <netinet/tcp.h>
11. #include <unistd.h>
12. #include <strings.h>
13. #include <errno.h>
14. #include <sys/stat.h>
15. #include <fcntl.h>
17. // 缓存区大小
18. #define BUFFER 512

复制代码

客户端

1. /********************************************************************
2. *
3. * name  :  main    客户端
4. * function :  使用udp网络协议从服务器发送音频文件到客户端
5. * argument :
6. *    @n  :arg
7. *
8. * retval  :  none
9. * author  :  17647576169@163.com
10. * date  :  2024年6月4日
11. *  note  :
12. *
13. * *****************************************************************/
15. int main(int argc, char const *argv[])
16. {
18.     // 1.创建UDP套接字
19.     int udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
20.     if (udp_socket == -1)
21.     {
22.         fprintf(stderr, "udp socket error,errno:%d,%s\n", errno, strerror(errno));
23.         exit(1);
24.     }
26.     // 2.需要先绑定主机的端口和地址
27.     struct sockaddr_in host_addr;
28.     host_addr.sin_family = AF_INET;                                     // 协议族，是固定的
29.     host_addr.sin_port = htons(atoi(argv[1]));                          // 目标端口，必须转换为网络字节序
30.     host_addr.sin_addr.s_addr = inet_addr(argv[2]);                     // 目标地址 "192.168.64.xxx"  已经转换为网络字节序
31.     bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr)); // 绑定
33.     // 3.创建接收文件
34.     int fd_mp3 = open("./my.mp3", "wb");
35.     if (fd_mp3 == -1)
36.     {
37.         fprintf(stderr, "open my.mp3 error,errno:%d,%s\n", errno, strerror(errno));
38.         exit(1);
39.     }
41.     // 设置缓存区
42.     char buf[BUFFER] = {0};
44.     // 3.循环发送数据
45.     while (1)
46.     {
47.         recvfrom(udp_socket, buf, sizeof(buf), 0, NULL, NULL);
48.         int write_fb= write(fd_mp3, &buf, BUFFER);
49.          if (write_fb == -1)
50.             {
51.                 fprintf(stderr, "read demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
52.                 exit(1);
53.             }
54.         bzero(buf, sizeof(buf));
55.     }
57.     return 0;
58. }

复制代码

服务器

1. /********************************************************************
2. *
3. * name  :  main    服务器
4. * function :  使用udp网络协议从服务器发送音频文件到客户端
5. * argument :
6. *    @n  :argc
7. *              @n  :argv
8. * retval  :  none
9. * author  :  17647576169@163.com
10. * date  :  2024年6月4日
11. *  note  :
12. *
13. * *****************************************************************/
15. int main(int argc, char const *argv[])
16. {
18.     // 1.创建UDP套接字
19.     int udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
20.     if (udp_socket == -1)
21.     {
22.         fprintf(stderr, "udp socket error,errno:%d,%s\n", errno, strerror(errno));
23.         exit(1);
24.     }
26.     // 2.需要先绑定主机的端口和地址
27.     struct sockaddr_in host_addr;
28.     host_addr.sin_family = AF_INET;                                     // 协议族，是固定的
29.     host_addr.sin_port = htons(atoi(argv[1]));                          // 目标端口，必须转换为网络字节序
30.     host_addr.sin_addr.s_addr = inet_addr(argv[2]);                     // 目标地址 "192.168.64.xxx"  已经转换为网络字节序
31.     bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr)); // 绑定
33.     // 3.发送打开音频文件
34.     int fd_mp3 = open("./demo.mp3", "rb");
35.     if (fd_mp3 == -1)
36.     {
37.         fprintf(stderr, "open demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
38.         exit(1);
39.     }
41.     // 计算发送次数
42.     char buf[BUFFER] = {0};
44.     struct stat stat_buf;
45.     statstat("./demo.mp3", &stat_buf);
46.     int cnt = stat_buf.st_size / BUFFER;
47.     if (stat_buf.st_size % BUFFER)
48.     {
49.         cnt++;
50.     }
52.     // 3.循环发送数据
53.     while (1)
54.     {
55.         for (int i = 0; i < cnt; i++)
56.         {
57.             int read_fb = read(fd_mp3, &buf, BUFFER);
58.             if (read_fb == -1)
59.             {
60.                 fprintf(stderr, "read demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
61.                 exit(1);
62.             }
63.             sendto(udp_socket, buf, strlen(buf), 0, (struct sockaddr *)&host_addr, sizeof(host_addr));
64.             bzero(buf, sizeof(buf));
65.         }
66.     }
68.     return 0;
69. }

复制代码

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！