UDP文件上传
通过socket(AF_INET, SOCK_DGRAM, 0)建议数据套接字,实现udp协议上传视频操作。
可以上传10M级文件,更大一点的没有测试,应该也可以传输。
内部实现通过malloc动态分配内存,给数据包打上用户id,包索引值,以及结束标识符。
包结构
发送接受的包结构示意:
- [index] [flag] [userId] [data]
- index:包索引值
- flag:标识字节,如果为0表示该包为中间包,为1表示为结束包,大于1表示此时传送的是第一个包,flag为长度值。
- userId:用户id标识。
- data:字符串数据指针,最大长度为1K。
客户端
先生成一个userId,然后每个包的第三个字节都为这个userId,表示这些包是同一个客户机发送的。
1、开始包:上传时先发送文件长度包,服务端根据文件长度包动态构建缓冲区存储数据。
2、中间包:中间包发送数据,并通过变量i给每个包打上索引值。
3、结束包:发送结束包时将flag置1。
发送需要一定延迟 避免服务器处理不过来
服务端
- 1、定义一个结构体用来保存用户的数据缓冲区。并定义一个大小为10的全局数组,表示同时最多可以有十个用户传输数据。
struct RecvData {
// 标识用户
int userId;
// 是否结束,1表示结束
int flag;
// 数据缓存区
// char buff[PACKET_SEQ][LENGTH];
char **buff;
};
// 定义单个用户的结束数据类型
typedef struct RecvData RecvData;
// 定义10个用户存储区
RecvData datas[DATAS_LENGTH];
-
2、接收数据,先解包,提取前三个字节的值。然后有三种包:
- 1、如果index=0表示为第一个包,为长度包,将userId占用一个缓冲区,并为其分配相关长度的内存。
- 2、如果index不等于0并且flag不为1,表示这个包为中间包,将它的数据拷贝到其userId所在的缓冲区的buff[index]中。
- 3、如果flag为1,表示这个包为结束包,打印相关信息,然后新开一个线程生成文件。
-
3、生成文件。将指定userId对应的RecvData块的buff指针中的数据按照index的顺序逐步取出,然后写入创建的文件中,最后清理userId所占用的那个RecvData块,准备被下一个userId占用。