实现C/S架构，有一台服务器，服务器中存储n首音频，要求客户端可以直接下载服务器的音频，并且可以正常在客户端播放。
- 服务器
/*************************************************************************************************************************
*
* file name: udp_server_music.c
* author : Dazz
* date : 2024/6/4
* function : 实现C/S架构，有一台服务器，服务器中存储n首音频，要求客户端可以直接下载服务器的音频，并且可以正常在客户端播放。
* 用stat 获取音频 xxx.mp3的属性
*
* note : 该程序为服务器 ./a.out port addr
*
* CopyRight (c) 2024 [email protected] All Right Reseverd
*
* **************************************************************************************************************************/
#include <errno.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/udp.h>
#include <string.h>
#include <pthread.h>
#include <stdlib.h>
#include <stdio.h>
#include <strings.h>
#include <unistd.h>
#include <time.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#define CLIENT_PORT "9999"
#define CLIENT_IP "192.168.64.233"
pthread_t pthreadsend;
pthread_t pthreadrecv;
int flag = 0;
/************************************************线程任务*************************************************************************/
// 接收消息线程:等待接收客户端的消息
void *pthreadrecv_task(void *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("9999")); // 目标端口，必须转换为网络字节序
host_addr.sin_addr.s_addr = htonl(INADDR_ANY); // 目标地址 "192.168.64.xxx" 已经转换为网络字节序 INADDR_ANY
bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr));
// 3.调用recvfrom等待接收数据，并且接收客户端的网络信息
char buf[128] = {0};
struct sockaddr_in client;
socklen_t client_len = sizeof(client);
char music[8] = "xxx";
while (1)
{
recvfrom(udp_socket, buf, sizeof(buf), 0, (struct sockaddr *)&client, &client_len); // 默认会阻塞
printf("消息来源:[%s] 消息内容:[%s]\n", inet_ntoa(client.sin_addr), buf);
// 当接收到的内容为“xxx”时，向该IP发送音频文件
if (!strcmp(buf, music))
{
flag = 1;
}
// 清空缓存区
bzero(buf, sizeof(buf));
}
}
/************************************************END*************************************************************************/
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);
}
// 创建线程等待接受客户端的信息
int result = pthread_create(&pthreadrecv, NULL, pthreadrecv_task, NULL);
if (result)
{
fprintf(stderr, "create thread error,errno:%d,%s\n", errno, strerror(errno));
exit(1);
}
printf("222222222222222222222!\n");
// int size = 0;
while (1)
{
if (flag)
{
printf("I am coming!\n");
// 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.向目标主机发送消息,需要设置目标端口和目标地址
char buf[1024] = {0};
struct sockaddr_in dest_addr;
dest_addr.sin_family = AF_INET; // 协议族，是固定的
dest_addr.sin_port = htons(atoi(CLIENT_PORT)); // 服务器端口，必须转换为网络字节序
dest_addr.sin_addr.s_addr = inet_addr(CLIENT_IP); // 服务器地址 "192.168.64.xxx"
FILE *fd = fopen("./xxx.mp3", "rb"); // 打开文件
fseek(fd, 0, SEEK_SET);
struct stat *statbuf;
stat("./xxx.mp3", statbuf);
int count = statbuf->st_size / 1024 + 1;
printf("loop num is %d\n", count);
while (count--)
{
// 从音频文件中读取内容
fread(buf, 1, 1024, fd);
// 向客户端发送本次读取到的内容
sendto(udp_socket, buf, sizeof(buf), 0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
// 清空缓存区
bzero(buf, 1024);
usleep(1000 * 1000 / 100);
}
printf("over!over!\n");
// 通知客户端文件发送完毕
sprintf(buf, "over");
printf("the buf is %s\n", buf);
// 向客户端发送本次读取到的内容
sendto(udp_socket, buf, strlen(buf), 0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
bzero(buf, sizeof(buf));
flag = 0;
}
}
return 0;
}
- 客户端
/*************************************************************************************************************************
*
* file name: udp_client_music.c
* author : Dazz
* date : 2024/6/4
* function : 实现C/S架构，有一台服务器，服务器中存储n首音频，要求客户端可以直接下载服务器的音频，并且可以正常在客户端播放。
* 用stat 获取音频 xxx.mp3的属性
*
* note : 该程序为客户端 ./a.out port addr
*
* CopyRight (c) 2024 [email protected] All Right Reseverd
*
* **************************************************************************************************************************/
#include <stdio.h>
#include <errno.h>
#include <arpa/inet.h>
#include <netinet/udp.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <sys/stat.h>
#include <sys/types.h>
#define DESTPORT 9999
/************************************************线程任务*************************************************************************/
void *DownloadMusic(void *argv)
{
// 创建一个用来存放音乐的目录
int dir = mkdir("./music", 0664);
if (-1 == dir && (!(errno == EEXIST)))
{
// 返回值为-1且文件不存在则退出
fprintf(stderr, "mkdir fail ,errno:%d,%s\n", errno, strerror(errno));
exit(1);
}
// 给服务器发送下载音乐的请求
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(2);
}
// 需要先绑定主机的端口和地址
struct sockaddr_in host_addr;
host_addr.sin_family = AF_INET; // 协议族，是固定的
host_addr.sin_port = htons(DESTPORT); // 目标端口，必须转换为网络字节序
host_addr.sin_addr.s_addr = htonl(INADDR_ANY); // 目标地址,转换为网络字节序，这里设置为任意地址，也可设置为指定地址
bind(udp_socket, (struct sockaddr *)&host_addr, sizeof(host_addr));
FILE *music;
// 创建音乐文件
music = fopen("./music/666.mp3", "wb+");
if (NULL == music)
{
fprintf(stderr, "fopen file fail,errno:%d,%s\n", errno, strerror(errno));
exit(1);
}
// 循环调用recvfrom准备接收数据
char buf[1024] = {0};
int size; //
int count; // 记录需要接收多少次
while (1)
{
// 接收服务器传输的数据，一次接收1024字节
size = recvfrom(udp_socket, buf, 1024, 0, NULL, NULL);
// 打印接收了多少次数据
printf(" has received %d times!!! \n", count++);
// 如收到服务器传来的“over”，则表示音乐传输完毕
if (!strcmp(buf, "over")) // 这里使用strstr()函数也可以
{
printf("\n\n\n");
printf("***************************************\n");
printf("The music is downloaded!!!!\n");
printf("***************************************\n");
break;
}
printf("recv data size = %d\n", size);
// 向创建的音乐文件里写入接收的数据
fwrite(buf, 1, size, music);
// 清空缓存区
bzero(buf, sizeof(buf));
}
// 关闭文件
fclose(music);
close(udp_socket);
}
/************************************************END*************************************************************************/
int main(int argc, char *argv[])
{
// 检查参数有效性
if (argc != 3)
{
fprintf(stderr, "argument is invaild ,errno:%d,%s\n", errno, strerror(errno));
exit(1);
}
// 给服务器发送下载音乐的请求
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(2);
}
// 创建线程来接收服务器发送的音乐
pthread_t thread;
pthread_create(&thread, NULL, DownloadMusic, NULL);
// 向目标主机发送消息,需要设置目标端口和目标地址
char sendbuf[128] = "xxx";
struct sockaddr_in dest_addr;
dest_addr.sin_family = AF_INET; // 协议族，是固定的
dest_addr.sin_port = htons(atoi(argv[1])); // 服务器端口，必须转换为网络字节序
dest_addr.sin_addr.s_addr = inet_addr(argv[2]); // 服务器地址 "192.168.64.xxx"
// 向服务器发送请求下载音乐的请求
int xxx = sendto(udp_socket, sendbuf, strlen(sendbuf), 0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
// 等待子线程结束
pthread_join(thread, NULL);
return 0;
}