天天看点

c语言socket编程传输视频流,C语言socket编程实现网络数据传输

仅供参考

// serverTCP.cpp : 定义控制台应用程序的入口点。

//

#include "stdafx.h"

using namespace std;

long long cnt = 0;

void transFile(SOCKET s)

{

printf("新子服务%d......",cnt);

send(s,"welcome to TCP FILE SERVER !",strlen("welcome to TCP FILE SERVER !")+1,0);

char Buf[BUFSIZE];

FILE *fp;

//printf("客户端已打开\n请输入存放文件地址:\n");

char FilePath[128]={"0"};

ltoa(cnt,FilePath,10);

if((fp=fopen(FilePath,"wb"))==NULL)

{

printf("文件未打开\n");

return;

}

else

{

send(s,"开始传送",strlen("开始传送")+1,0);

//得到文件大小

char Size[20];

long int FileSize=0;

recv(s,Size,21,0);

FileSize=atol(Size);

printf("得到文件大小: %d\n",FileSize);

//开始传送

char Block[BUFSIZE];

long int x=0;

while (1)

{

x += BUFSIZE;

if(x < FileSize)

{

recv(s,Block,BUFSIZE+1,0);

fwrite(Block,1,BUFSIZE,fp);

}

else

{

recv(s,Block,FileSize+BUFSIZE-x+1,0);

printf("文件接收完毕\n");

fwrite(Block,1,FileSize+BUFSIZE-x,fp);

fclose(fp);

break;

}

}

}

fclose(fp);

closesocket(s);

}

int _tmain(int argc, _TCHAR* argv[])

{

WORD myVersionRequest;

WSADATA wsaData;

myVersionRequest=MAKEWORD(1,1);

int err;

err = WSAStartup(myVersionRequest,&wsaData);

if (!err)

{

printf("服务器启动......\n");

}

else

{

printf("服务器启动失败!");

exit(0);

}

SOCKET serSocket = socket(AF_INET,SOCK_STREAM,0);//创建了可识别套接字

SOCKADDR_IN addr;

addr.sin_family=AF_INET;

addr.sin_addr.S_un.S_addr=htonl(INADDR_ANY);//ip地址

addr.sin_port=htons(PORTBASE);//绑定端口

bind(serSocket,(SOCKADDR*)&addr,sizeof(SOCKADDR));//绑定完成

listen(serSocket,ACESIZE);//其中第二个参数代表能够接收的最多的连接数

SOCKADDR_IN clientAddr;

int len = sizeof(SOCKADDR);

while(1)

{

cnt++;

SOCKET serConn;

serConn = accept(serSocket,(SOCKADDR*)&clientAddr,&len);//如果这里不是accept而是conection的话。。就会不断的监听

if(_beginthread((void (*)(void *))transFile, ACESIZE,(void *)serConn) < 0)return 0;

}

return 0;

}

// clientTCP.cpp : 定义控制台应用程序的入口点。

//

#include "stdafx.h"

using namespace std;

int _tmain(int argc, _TCHAR* argv[])

{

WORD myVersionRequest;

WSADATA wsaData;

myVersionRequest=MAKEWORD(1,1);

int err;

err=WSAStartup(myVersionRequest,&wsaData);

if (!err)

{

printf("已打开套接字\n");

}

else

{

//进一步绑定套接字

printf("套接字未打开!");

return 0;

}

SOCKET cliSocket =socket(AF_INET,SOCK_STREAM,0);

SOCKADDR_IN addr;

char ip_addr[16]={"127.0.0.1"};

addr.sin_addr.S_un.S_addr=inet_addr(ip_addr);

addr.sin_family=AF_INET;

addr.sin_port=htons(PORT);

char ACK[64];

connect(cliSocket,(SOCKADDR*)&addr,sizeof(SOCKADDR));//开始连接

recv(cliSocket,ACK,sizeof(ACK),0);

printf("%s\n",ACK);

FILE *fp;

int FileSize=0;

char Block[BUFSIZE]={"0"};

char FilePath[128]={"0"};

int i=0;

do

{

printf("请输入文件地址:\n");

gets(FilePath);

i = 0;

if((fp=fopen(FilePath,"rb"))==NULL)

{

i = 1;

printf("文件打开失败\n");

}

}while(i);

fseek(fp,0L,SEEK_END);

FileSize=ftell(fp);

printf("待传送文件大小: %d\n",FileSize);

printf("等待服务器接受......\n");

recv(cliSocket,Block,sizeof(Block),0);

printf("%s\n",Block);

if(strcmp(Block,"开始传送")==0)

{

char Size[20];

ltoa(FileSize,Size,10);

send(cliSocket,Size,sizeof(Size),0);

fseek(fp,0L,SEEK_SET);

long int y=0;

char trans[BUFSIZE];

while(!feof(fp))

{

fread(trans,1,BUFSIZE,fp);

y=y+BUFSIZE;

if(y

{

send(cliSocket,trans,BUFSIZE+1,0);

}

else

{

send(cliSocket,trans,FileSize+BUFSIZE-y+1,0);

closesocket(cliSocket);

WSACleanup();

}

}

}

printf("文件发送完毕\n");

fclose(fp);

closesocket(cliSocket);

WSACleanup();

system("pause");

return 0;

}

追问

请问这个是在什么环境下运行的?为什么都没有main函数?

温馨提示:答案为网友推荐,仅供参考