/****************************************************************************** |
* 程序: winsock_server.c |
* 目的: 创建流式套接字,等待客户端连接并向客户端发送数据 |
* 作者: 周 晨 |
* 学号: 2011210154 |
*****************************************************************************/ |
#include <stdio.h> |
#include <stdlib.h> |
#include <string.h> |
#include <WinSock2.h> |
#include <Windows.h> |
/* 导入win32函数库 */ |
#pragma comment(lib, "WS2_32.lib") |
/* winsock初始化成功标志 */ |
#define WSA_STARTUP_SUCCESS 0 |
/* 请求队列长度 */ |
#define REQUEST_QUEUE_LENGTH 10 |
/* 获取系统当前的日期和时间 */ |
void GetSystemCurrentTime() |
{ |
SYSTEMTIME sys; |
GetLocalTime(&sys); |
printf ( "%4d-%02d-%02d %02d:%02d:%02d - " , |
sys.wYear, sys.wMonth, sys.wDay, sys.wHour, sys.wMinute, sys.wSecond); |
} |
int main() |
{ |
/* 接收函数调用返回的状态码 */ |
int state_code = 0; |
/* 服务器端口号 */ |
int server_port = 5199; |
/* 声明一个用于监听的Socket连接 */ |
SOCKET listener_socket; |
/* 声明一个客户端连接成功的Socket */ |
SOCKET client_socket; |
/* 声明客户端的网络地址结构 */ |
SOCKADDR_IN client_address; |
/* 声明服务器端的网络地址结构 */ |
SOCKADDR_IN server_address; |
/* 清空服务器端的网络地址结构 */ |
memset (&server_address, 0, sizeof (server_address)); |
/* 设置为Internet协议簇 */ |
server_address.sin_family = AF_INET; |
/* 设置服务器本地IP地址 */ |
server_address.sin_addr.S_un.S_addr = INADDR_ANY; |
/* 转化服务器端口号 */ |
server_address.sin_port = htons(server_port); |
/* 网络地址结构所占字节大小 */ |
int server_address_size = ( int ) sizeof (SOCKADDR_IN); |
int client_address_size = ( int ) sizeof (SOCKADDR_IN); |
/* 当前已连接的客户端数目 */ |
int visitors = 0; |
/* 接受服务器数据的缓冲区 */ |
char buffer[] = "Client,你好,欢迎你的连接,我是Server..." ; |
GetSystemCurrentTime(); |
printf ( "Server:服务器已启动!\n" ); |
/* 初始化 WinSock 连接 */ |
WSADATA wsadata; |
state_code = WSAStartup(MAKEWORD(2, 2), &wsadata); |
if (WSA_STARTUP_SUCCESS != state_code) |
{ |
GetSystemCurrentTime(); |
printf ( "发生错误:初始化WinSock连接失败!错误码:%d\n" , WSAGetLastError()); |
exit (EXIT_FAILURE); |
} |
/* 创建监听器的 Socket 连接 */ |
listener_socket = socket(AF_INET, SOCK_STREAM, 0); |
GetSystemCurrentTime(); |
if (INVALID_SOCKET == listener_socket) |
{ |
printf ( "发生错误:服务器监听套接字创建失败!错误码:%d\n" , WSAGetLastError()); |
closesocket(listener_socket); |
WSACleanup(); |
exit (EXIT_FAILURE); |
} |
printf ( "Server:服务器监听套接字已成功创建!\n" ); |
/* 将本地地址绑定到监听套接字 */ |
state_code = bind(listener_socket, (SOCKADDR*)&server_address, server_address_size); |
GetSystemCurrentTime(); |
if (SOCKET_ERROR == state_code) |
{ |
printf ( "发生错误:服务器本地地址绑定到监听套接字失败!错误码:%d\n" , WSAGetLastError()); |
closesocket(listener_socket); |
WSACleanup(); |
exit (EXIT_FAILURE); |
} |
printf ( "Server:服务器本地地址已成功绑定到监听套接字!\n" ); |
/* 开始监听,并指定监听套接字请求队列长度 */ |
state_code = listen(listener_socket, REQUEST_QUEUE_LENGTH); |
GetSystemCurrentTime(); |
if (SOCKET_ERROR == state_code) |
{ |
printf ( "发生错误:服务器监听套接字失败!错误码:%d\n" , WSAGetLastError()); |
closesocket(listener_socket); |
WSACleanup(); |
exit (EXIT_FAILURE); |
} |
printf ( "Server:服务器已成功启动套接字监听!\n" ); |
GetSystemCurrentTime(); |
printf ( "Server:开始监听...\n" ); |
/* 服务器主循环 - 接受和处理来自客户端的连接请求 */ |
while (1) |
{ |
client_socket = accept(listener_socket, (SOCKADDR*)&client_address, &client_address_size); |
GetSystemCurrentTime(); |
if (INVALID_SOCKET == client_socket) |
{ |
printf ( "发生错误:当前客户端连接失败!错误码:%d\n" , WSAGetLastError()); |
closesocket(client_socket); |
WSACleanup(); |
exit (EXIT_FAILURE); |
} |
visitors++; // 访问量+1 |
/* 向客户端发送消息 */ |
send(client_socket, buffer, strlen (buffer), 0); |
printf ( "Server:发现新的连接用户,已发送问候消息!\n" ); |
GetSystemCurrentTime(); |
printf ( "Server:当前累计在线 %d 位用户!\n" , visitors); |
closesocket(client_socket); |
} |
return EXIT_SUCCESS; |
} |