用udp協議傳輸文件

• 用udp協議傳輸文件
  • 頭文件/巨集定義
  • 客戶端
  • 伺服器

頭文件/巨集定義

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <time.h>
#include <pthread.h>
#include <netinet/tcp.h>
#include <unistd.h>
#include <strings.h>
#include <errno.h>
#include <sys/stat.h>
#include <fcntl.h>

// 緩存區大小
#define BUFFER 512

客戶端

/********************************************************************
 *
 * name  :  main    客戶端
 * function :  使用udp網路協議從伺服器發送音頻文件到客戶端
 * argument :
 *    @n  :arg
 *
 * retval  :  none
 * author  :  [email protected]
 * date  :  2024年6月4日
 *  note  :
 *
 * *****************************************************************/

int main(int argc, char const *argv[])
{

    // 1.創建UDP套接字
    int udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
    if (udp_socket == -1)
    {
        fprintf(stderr, "udp socket error,errno:%d,%s\n", errno, strerror(errno));
        exit(1);
    }

    // 2.需要先綁定主機的埠和地址
    struct sockaddr_in host_addr;
    host_addr.sin_family = AF_INET;                                     // 協議族，是固定的
    host_addr.sin_port = htons(atoi(argv[1]));                          // 目標埠，必須轉換為網路位元組序
    host_addr.sin_addr.s_addr = inet_addr(argv[2]);                     // 目標地址 "192.168.64.xxx"  已經轉換為網路位元組序
    bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr)); // 綁定

    // 3.創建接收文件
    int fd_mp3 = open("./my.mp3", "wb");
    if (fd_mp3 == -1)
    {
        fprintf(stderr, "open my.mp3 error,errno:%d,%s\n", errno, strerror(errno));
        exit(1);
    }

    // 設置緩存區
    char buf[BUFFER] = {0};

    // 3.迴圈發送數據
    while (1)
    {
        recvfrom(udp_socket, buf, sizeof(buf), 0, NULL, NULL);
        int write_fb= write(fd_mp3, &buf, BUFFER);
         if (write_fb == -1)
            {
                fprintf(stderr, "read demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
                exit(1);
            }
        bzero(buf, sizeof(buf));
    }

    return 0;
}

伺服器

/********************************************************************
 *
 * name  :  main    伺服器
 * function :  使用udp網路協議從伺服器發送音頻文件到客戶端
 * argument :
 *    @n  :argc
 *              @n  :argv
 * retval  :  none
 * author  :  [email protected]
 * date  :  2024年6月4日
 *  note  :
 *
 * *****************************************************************/

int main(int argc, char const *argv[])
{

    // 1.創建UDP套接字
    int udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
    if (udp_socket == -1)
    {
        fprintf(stderr, "udp socket error,errno:%d,%s\n", errno, strerror(errno));
        exit(1);
    }

    // 2.需要先綁定主機的埠和地址
    struct sockaddr_in host_addr;
    host_addr.sin_family = AF_INET;                                     // 協議族，是固定的
    host_addr.sin_port = htons(atoi(argv[1]));                          // 目標埠，必須轉換為網路位元組序
    host_addr.sin_addr.s_addr = inet_addr(argv[2]);                     // 目標地址 "192.168.64.xxx"  已經轉換為網路位元組序
    bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr)); // 綁定

    // 3.發送打開音頻文件
    int fd_mp3 = open("./demo.mp3", "rb");
    if (fd_mp3 == -1)
    {
        fprintf(stderr, "open demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
        exit(1);
    }

    // 計算發送次數
    char buf[BUFFER] = {0};

    struct stat stat_buf;
    statstat("./demo.mp3", &stat_buf);
    int cnt = stat_buf.st_size / BUFFER;
    if (stat_buf.st_size % BUFFER)
    {
        cnt++;
    }

    // 3.迴圈發送數據
    while (1)
    {
        for (int i = 0; i < cnt; i++)
        {
            int read_fb = read(fd_mp3, &buf, BUFFER);
            if (read_fb == -1)
            {
                fprintf(stderr, "read demo.mp3 error,errno:%d,%s\n", errno, strerror(errno));
                exit(1);
            }
            sendto(udp_socket, buf, strlen(buf), 0, (struct sockaddr *)&host_addr, sizeof(host_addr));
            bzero(buf, sizeof(buf));
        }
    }

    return 0;
}