Windows下C 用 Socket 发送图片--基础

Windows下C 用 Socket 发送图片--基础

服务器端:

#include <stdio.h>
#include <winsock2.h>
#include <winsock2.h>
#define SERVER_PORT 9210 //侦听端口
#pragma comment(lib,"ws2_32.lib")

struct Data //数据包
{
int length;
char receivemessage[2000]; //内容信息
int fin;
}data;

int main()
{
FILE * fp;
if (!(fp = fopen("abc.jpg", "wb+")))
{
printf("open abc.jpg error");
exit(0);
}
WORD wVersionRequested;//双字节；高字节存取副版本号，低字节存取高版本号。
WSADATA wsaData;//存取套接字实现的具体信息
int ret, length;
SOCKET sListen, sServer; //侦听套接字，连接套接字
struct sockaddr_in saServer, saClient; //地址信息

//WinSock初始化
wVersionRequested = MAKEWORD(2, 2);
ret = WSAStartup(wVersionRequested, &wsaData);
if (ret != 0)
{
printf("WSAStartup() failed!\n");
return 0;
}
//创建Socket,使用TCP协议
sListen = socket(AF_INET, SOCK_STREAM, 0);
if (sListen == INVALID_SOCKET)
{
WSACleanup();
printf("socket() faild!\n");
return 0;
}
//构建本地地址信息
saServer.sin_family = AF_INET; //地址家族
saServer.sin_port = htons(SERVER_PORT); //注意转化为网络字节序
saServer.sin_addr.S_un.S_addr = htonl(INADDR_ANY); //使用INADDR_ANY 指示任意地址

//绑定
ret = bind(sListen, (struct sockaddr *)&saServer, sizeof(saServer));
if (ret == SOCKET_ERROR)
{
printf("bind() faild! code:%d\n", WSAGetLastError());
closesocket(sListen); //关闭套接字
WSACleanup();
return 0;
}

//侦听连接请求
ret = listen(sListen, 5);
if (ret == SOCKET_ERROR)
{
printf("listen() faild! code:%d\n", WSAGetLastError());
closesocket(sListen); //关闭套接字
return 0;
}

printf("Waiting for client connecting!\n");
printf("Tips: Ctrl+c to quit!\n");
length = sizeof(saClient);
sServer = accept(sListen, (struct sockaddr *)&saClient, &length);
if (sServer == INVALID_SOCKET)
{
printf("accept() faild! code:%d\n", WSAGetLastError());
closesocket(sListen); //关闭套接字
WSACleanup();
return 0;
}

//阻塞等待接受客户端连接
while (!data.fin)
{
memset(data.receivemessage, '0', sizeof(data.receivemessage));
ret = recv(sServer, (char *)&data, sizeof(struct Data), 0); //第二个参数使用强制类型，为一个数据包
if (ret == SOCKET_ERROR)
{
printf("recv() failed!\n");
return 0;
}
if (ret == 0) //客户端已经关闭连接
{
printf("Client has closed the connection\n");
break;
}
fwrite(data.receivemessage, data.length, 1, fp);
}

closesocket(sListen);
closesocket(sServer);
WSACleanup();
return 0;
}


客户端:

#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <stdio.h>
#include <stdlib.h>
#include <winsock2.h>
#define SERVER_PORT 9210 //侦听端口
#pragma comment(lib,"ws2_32.lib")

struct Data
{
int length;
char sendMessage[2000];
int fin;
}data;

int main()
{
FILE * fp;
errno_t err = fopen_s(&fp, "D:\\7.jpg", "rb+");
WORD wVersionRequested;
WSADATA wsaData;
int ret;
SOCKET sClient; //连接套接字
struct sockaddr_in saServer; //地址信息

BOOL fSuccess = TRUE;

fseek(fp, 0, SEEK_END);
int end = ftell(fp);
fseek(fp, 0, 0);
//WinSock初始化
wVersionRequested = MAKEWORD(2, 2); //希望使用的WinSock DLL的版本
ret = WSAStartup(wVersionRequested, &wsaData);
if (ret != 0)
{
printf("WSAStartup() failed!\n");
return 0;
}
//确认WinSock DLL支持版本2.2
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
WSACleanup();
printf("Invalid WinSock version!\n");
return 0;
}
//创建Socket,使用TCP协议
sClient = socket(AF_INET, SOCK_STREAM, 0);
if (sClient == INVALID_SOCKET)
{
WSACleanup();
printf("socket() failed!\n");
return 0;
}
//构建服务器地址信息
saServer.sin_family = AF_INET; //地址家族
saServer.sin_port = htons(SERVER_PORT); //注意转化为网络节序
saServer.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
//连接服务器
ret = connect(sClient, (struct sockaddr *)&saServer, sizeof(saServer));
if (ret == SOCKET_ERROR)
{
printf("connect() failed!\n");
closesocket(sClient); //关闭套接字
WSACleanup();
return 0;
}

int nZero = 10;
setsockopt(sClient, SOL_SOCKET, SO_SNDBUF, (char *)&nZero, sizeof(nZero));
while (end > 0)
{
memset(data.sendMessage, '0', sizeof(data.sendMessage));
fread(data.sendMessage, 1024, 1, fp);
if (end >= 1024) //剩余很多信息
{
data.fin = 0;
data.length = 1024;
}
else
{
data.fin = 1;
data.length = end;
}
ret = send(sClient, (char *)&data, sizeof(struct Data), 0);
if (ret == SOCKET_ERROR)
{
printf("send() failed!\n");
}
else
{
end -= 1024;
}
}

closesocket(sClient); //关闭套接字
WSACleanup();
return 0;
}