#include<WinSock2.h>//头文件
#include<stdbool.h>
#include<stdio.h>
#include<iostream>
#pragma comment(lib, "ws2_32.lib")//库文件
#pragma warning(disable:4996)
#define err(errMsg) printf("[error] %s failed,code %d \
line:%d\n ",errMsg,WSAGetLastError(),__LINE__)
#define PORT 8888 //0~1024一般不用
using namespace std;
long g_fileSzie;
char* g_fileBuf;
bool init_Socket()//初始化网络库
{
WSADATA wsadata;
if (0 != WSAStartup(MAKEWORD(2, 2), &wsadata))//windows异步套接字启动
{
printf("[error]WSAStarup failed,code %d\n", WSAGetLastError());
return false;
}
return true;
}
bool close_Socket()//关闭网络库
{
if (0 != WSACleanup())
{
printf("[error]WSACleanup failed,code %d", WSAGetLastError());
return false;
}
return true;
}
SOCKET create_serverSocket()
{
SOCKET fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);//创建一个空的socket
if (INVALID_SOCKET == fd)
{
printf("[error]socket failed,code %d", WSAGetLastError());
return INVALID_SOCKET;
}
struct sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_port = htons(PORT);//把本地字节序转换为网络字节序
addr.sin_addr.S_un.S_addr = ADDR_ANY;//绑定本地任意IP
if (SOCKET_ERROR == bind(fd, (struct sockaddr*)&addr, sizeof(addr)))
{
printf("[error]bind failed,code %d", WSAGetLastError());
return INVALID_SOCKET;//-1
}
listen(fd, 10);
return fd;
}
int main()
{
int send_len ;
int recv_len ;//定义长度变量
int len ;
char send_buf[100] = { '\0' };
char recv_buf[100] = { '\0' };//定义发送缓冲区和接受缓冲区
init_Socket();
SOCKET serfd = create_serverSocket();
printf("服务端创建成功，等待客户端连接\n ");
SOCKET clifd = accept(serfd, NULL, NULL);//s_accept = accept(s_server, (SOCKADDR*)&accept_addr, &len);
while (true)
{
if (clifd == INVALID_SOCKET)
{
printf("[error]accept failed,code %d", WSAGetLastError());
closesocket(clifd);
closesocket(serfd);
close_Socket();
return 0;
}
printf("客户端连接成功\n");
while (true)
{
if (SOCKET_ERROR == recv(clifd, recv_buf, sizeof(recv_buf), 0))//recv_len = recv(s_accept, recv_buf, 100, 0);
{
printf("[error] failed,code %d", WSAGetLastError());
}
else
{
printf("客户端信息：%s\n", recv_buf);
}
if (strcmp(recv_buf, "bye") == 0)
{ //断开通信
cout << "本次通信结束！" << endl;
break;
}
cout << "请输入回复信息：\0";
cin >> send_buf;
send_len = send(clifd, send_buf, sizeof(send_buf), 0);
if (send_len < 0)
{
cout << "发送失败！" << endl;
break;
}
}
break;
}
closesocket(clifd);
closesocket(serfd);
close_Socket();
return 0;
}
评论0