socket文件传输功能的实现
2015-11-13 08:30
267 查看
摘要: 在D盘中准备好send.avi文件,先运行 server,再运行 client:
Input filename to save: D:\\recv.avi↙
服务端:
客户端:
Input filename to save: D:\\recv.avi↙
服务端:
#include <stdio.h> #include <winsock2.h> #pragma comment (lib, "ws2_32.lib") //加载 ws2_32.dll #define BUF_SIZE 1024 int main(int argc, char *argv[]){ //先检查文件是否存在 char *filename = "Beyond.mp3";//文件名 FILE *fp = fopen(filename, "rb");//以二进制方式打开文件 if(fp == NULL) { printf("Cannot open file, press any key to exit!\n"); system("pause"); exit(0); } //初始化 DLL WSADATA wsaData; WSAStartup( MAKEWORD(2, 2), &wsaData); //创建套接字 SOCKET servSock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); if(servSock == INVALID_SOCKET) { printf("Failed socket().\n"); WSACleanup(); return 0; } //绑定套接字 struct sockaddr_in sockAddr; memset(&sockAddr, 0, sizeof(sockAddr)); //每个字节都用0填充 sockAddr.sin_family = PF_INET; //使用IPv4地址 sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); //具体的IP地址 sockAddr.sin_port = htons(1234); //端口 if(bind(servSock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR)) == SOCKET_ERROR) { printf("Failed bind().\n"); WSACleanup(); return 0; } //进入监听状态 listen(servSock, 20); //循环接收客户端请求 int nSize = sizeof(SOCKADDR); char buffer[BUF_SIZE] = {0};//缓冲区 SOCKADDR clntAddr; SOCKET clntSock; for(;;) { clntSock = accept(servSock, (SOCKADDR*)&clntAddr, &nSize); if(clntSock == INVALID_SOCKET) { printf("Failed accept().\n"); continue; } int nCount; while(nCount = fread(buffer, 1, BUF_SIZE, fp) > 0) { send(clntSock, buffer, nCount, 0);//循环发送数据,直到文件结尾 } shutdown(clntSock, SD_SEND);//文件读取完毕,断开输出流,向客户端发送FIN包 recv(clntSock, buffer, BUF_SIZE, 0);//阻塞,等待客户端接收完毕 memset(buffer, 0, BUF_SIZE);//设置缓冲区 fclose(fp); closesocket(clntSock); } //关闭套接字 closesocket(servSock); //终止 DLL 的使用 WSACleanup(); system("pause"); return 0; }
客户端:
#include <stdio.h> #include <stdlib.h> #include <winsock2.h> #pragma comment(lib, "ws2_32.lib") #define BUF_SIZE 1024 int main(int argc, char *agrv[]) { //先输入文件名,看文件是否能创建成功 char filename[100] = {0}; //文件名 printf("Input filename to save: "); gets(filename); FILE *fp = fopen(filename, "wb");//以二进制方式打开(创建)文件 if(fp == NULL) { printf("Cannot open file, press any key to exit!\n"); system("pause"); exit(0); } //初始化DLL WSADATA wsaData; WSAStartup(MAKEWORD(2,2), &wsaData); //创建套接字 SOCKET sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); if(sock == INVALID_SOCKET) { printf("Failed socket().\n"); WSACleanup(); return 0; } //向服务器发起请求 struct sockaddr_in sockAddr; memset(&sockAddr, 0, sizeof(sockAddr)); //每个字节都用0填充 sockAddr.sin_family = PF_INET; sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); sockAddr.sin_port = htons(1234); if(connect(sock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR)) == -1) { printf("Failed connect().\n"); WSACleanup(); return 0; } //循环接受数据,知道文件传输完毕 char buffer[BUF_SIZE] = {0}; //文件缓冲区 int nCount; while((nCount = recv(sock, buffer, BUF_SIZE, 0)) > 0) { fwrite(buffer, nCount, 1, fp); } puts("File transfer success!\n"); memset(buffer, 0, BUF_SIZE);//重置缓冲区 fclose(fp); closesocket(sock); //终止使用DLL WSACleanup(); system("pause"); return 0; }
相关文章推荐
- jQuery css,position,offset,scrollTop,scrollLeft用法
- 微软承认错误 0×80240020错误代码导致win7/8自动升级win10
- 第十周 二叉树遍历的递归算法
- 第10周项目3用二叉树遍历思想解决问题
- Docker逐渐火起来了,收集了一些这方面的书
- 第十周实践项目3 - 利用二叉树遍历思想解决问题
- 郁闷啊,买错书了。。。。
- Python学习笔记(一)--- Matplotlib
- ubuntu下恢复rm删除的数据
- Activity之间数据的传递方式
- 第9周 项目4-广义表算法库及应用(1)
- 双系统怎么安装Win10 TH2正式版? Win7、Win8.1双系统图文安装教程
- 第十一周项目1—— 二叉树算法验证(1)
- java程序——输入判断成绩
- VC++ GDI 总结 一一 CBitmap类
- 第8周 项目5-计数的模式匹配
- 新手教程 Win10 TH2正式版ISO镜像安装方法大全
- 第十周实践项目2--二叉树遍历的递归算法
- 第十一周项目1-二叉树算法验证(4)
- 男人一生要闯十道关