udp传输文件-创新互联

本程序转自腾讯课堂里面的《C++之网络编程》视频教程里的。地址为   https://ke.qq.com/course/141506#term_id=100159728

服务器端：

#include

#include
#include
#include
#include
#pragma comment(lib,"WS2_32.lib")

#define MAX_BUF 65536
using namespace std;

int main()
{
//初始化版本号
WSADATA wsaData;
int ret=WSAStartup(MAKEWORD(2,2),&wsaData);
if(ret!=0)
{
cout<<"wsastarup error"<return 0;
}

//建立套接字
SOCKET s;
s=socket(AF_INET,SOCK_DGRAM,0);
if(s==INVALID_SOCKET)
{
 cout<<"socket error"< WSACleanup();
 return 0;
}

//定义一个地址，并进行绑定
sockaddr_in sin;
sin.sin_family=AF_INET;
sin.sin_port=htons(5000);
sin.sin_addr.S_un.S_addr=htonl(INADDR_ANY);

//绑定地址
int r=bind(s,(sockaddr*)&sin,sizeof(sin));
if(r==SOCKET_ERROR)
{
 cout<<"bind error"< closesocket(s);
 WSACleanup();
 return 0;
}

//接收缓存区
char recvbuf[MAX_BUF];

//初始化缓存区
memset(recvbuf,0,MAX_BUF);

//定义一个地址结构
sockaddr_in addr;
int addrlen=sizeof(addr);

//输入文件的路径
char path[100]={"0"};
cout<<"请输入文件的路径：（例如D:\\1.txt）"<cin>>path;

//打开文件
FILE *fp;
fopen_s(&fp,path,"wb");
if(!fp)
{
cout<<"文件打开失败"<return 0;
}
else
{
 cout<<"文件已经打开，等待传输......"<}
while (true)
{
//接收
memset(recvbuf,0,MAX_BUF);
int rBye=recvfrom(s,recvbuf,MAX_BUF,0,(sockaddr*)&addr,&addrlen);

//接收失败
if(rBye==SOCKET_ERROR)
{
cout<<"recvfrom error"<closesocket(s);
WSACleanup();
return 0;
}

//接收成功
fwrite(recvbuf,1,1024,fp);
fclose(fp);
}
closesocket(s);
WSACleanup();
return 0;

}

客户端：

本程序转自腾讯课堂里面的《C++之网络编程》视频教程里的。地址为   https://ke.qq.com/course/141506#term_id=100159728

#include
#include
#include
#include
#include
#pragma comment(lib,"WS2_32.lib")

using namespace std;

int main()
{
  //初始化版本号
WSADATA wsaData;
int ret=WSAStartup(MAKEWORD(2,2),&wsaData);
if(ret!=0)
{
cout<<"wsastarup error"<return 0;
}

//建立套接字
SOCKET s;
s=socket(AF_INET,SOCK_DGRAM,0);
if(s==INVALID_SOCKET)
{
cout<<"socket error"<WSACleanup();
return 0;
}

//目的地址
sockaddr_in sin;
sin.sin_family=AF_INET;
sin.sin_port=htons(5000);
sin.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");

//要发送的文件路径
char path[100]={"0"};
cout<<"请输入要发送文件的路径：（例如D:\\1.txt）"<cin>>path;

//打开文件
FILE *fp;
fopen_s(&fp,path,"rb");

if(!fp)
{
  cout<<"fopen_s error"<return 0;
}
else
{
cout<<"文件已经打开，客户端等待传输"<}

//发送缓存区
char sendbuf[1024]={0};
while (!feof(fp))
{
//清空sendbuf
memset(sendbuf,1,1024);

//把数据写入sendbuf
fread(sendbuf,1,1024,fp);

//发送sendbuf
int n=sendto(s,sendbuf,strlen(sendbuf),0,(sockaddr*)&sin,sizeof(sin));
if(n==SOCKET_ERROR)
{
cout<<"sendto error"<closesocket(s);
WSACleanup();
return 0;
}
}
fclose(fp);
closesocket(s);
WSACleanup();
return 0;
}

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。