服务器端代码#define _WINSOCK_DEPRECATED_NO_WARNINGS #define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <stdlib.h> #include <string.h> #include <WinSock2.h> #ifndef MSG_NOSIGNAL #define MSG_NOSIGNAL 0 #endif #pragma comment(lib,"ws2_32.lib") SOCKET g_clientSockets[10]; int g_clientCount = 0; DWORD WINAPI ClientThread(LPVOID lpParam) { SOCKET clientSocket = (SOCKET)lpParam; char recvBuf[50], sendBuf[50]; while (1) { // 接收客户端消息并处理 int ret = recv(clientSocket, recvBuf, 50, 0); if (ret <= 0) { break; } printf("Received message from client: %s\n", recvBuf); // 转发消息给所有客户端 for (int i = 0; i < g_clientCount; i++) { if (g_clientSockets[i] != clientSocket) { send(g_clientSockets[i], recvBuf, strlen(recvBuf) + 1, 0); } } } // 关闭客户端套接字 closesocket(clientSocket); // 从全局变量中移除该客户端套接字 for (int i = 0; i < g_clientCount; i++) { if (g_clientSockets[i] == clientSocket) { g_clientCount--; memmove(&g_clientSockets[i], &g_clientSockets[i + 1], (g_clientCount - i) * sizeof(SOCKET)); break; } } return 0; } int main() { WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD(1, 1); err = WSAStartup(wVersionRequested, &wsaData); if (err != 0) { return -1; } if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { WSACleanup(); return -1; } // 创建套接字并绑定到本地地址 SOCKET sockSrv = socket(AF_INET, SOCK_STREAM, 0); SOCKADDR_IN addrSrv; addrSrv.sin_family = AF_INET; addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY); addrSrv.sin_port = htons(6000); bind(sockSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR)); // 开始监听客户端连接请求 listen(sockSrv, 5); while (1) { // 接受客户端连接并处理消息 SOCKADDR_IN addrClient; int len = sizeof(SOCKADDR); SOCKET sockConn = accept(sockSrv, (SOCKADDR*)&addrClient, &len); // 将新连接的客户端套接字加入全局变量 g_clientSockets[g_clientCount++] = sockConn; // 创建新线程来处理该客户端的消息 HANDLE hThread = CreateThread(NULL, 0, ClientThread, &sockConn, 0, NULL); // 关闭线程句柄 CloseHandle(hThread); } closesocket(sockSrv); WSACleanup(); return 0; }
时间: 2024-04-27 16:20:49 浏览: 98
这段代码是一个简单的服务器端代码,主要功能是接受客户端连接,并将客户端发送的消息转发给其他客户端。它使用了 WinSock2 库来进行网络编程。在主函数中,首先调用了 WSACleanup() 函数来释放 WinSock2 库占用的资源。然后创建了一个套接字,并将其绑定到本地地址。接着开始监听客户端连接请求,在循环中不断接受客户端连接。每当有新的客户端连接时,就将其套接字加入全局变量 g_clientSockets 中,并创建一个新线程来处理该客户端的消息。在 ClientThread 函数中,首先接收客户端发送的消息,然后将其转发给其他客户端。当客户端断开连接时,将其套接字从全局变量中移除,并关闭该客户端的套接字。最后关闭套接字并释放 WinSock2 库占用的资源。
相关问题
#include "stdafx.h" #define _WINSOCK_DEPRECATED_NO_WARNINGS #include <Winsock2.h> #include <stdio.h> #include <stdlib.h> #define DEFAULT_PORT 5050 //服务端默认端口 #pragma comment(lib, "wsock32.lib")什么意思
这段代码主要是实现了一个基于 Winsock2 库的服务端程序,其中:
- `#include "stdafx.h"` 是用来包含预编译头文件的指令。
- `#define _WINSOCK_DEPRECATED_NO_WARNINGS` 定义了一个宏,表示不使用已经过时的 Winsock API。
- `#include <Winsock2.h>` 是包含 Winsock2 库的头文件。
- `#include <stdio.h>` 和 `#include <stdlib.h>` 是标准 C 库头文件,用于输入/输出和内存管理等操作。
- `#define DEFAULT_PORT 5050` 定义了一个常量,表示服务端程序的默认端口号为 5050。
- `#pragma comment(lib, "wsock32.lib")` 是指定连接 Winsock 库时需要使用的库文件。
综上,这段代码主要是为了支持服务端程序通过 Winsock2 库实现网络通信,其中包含了 Winsock2 库的头文件和库文件,并定义了一些常量和宏来实现网络通信。
客户端代码#define _WINSOCK_DEPRECATED_NO_WARNINGS #define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <stdlib.h> #include <string.h> #include <WinSock2.h> #ifndef MSG_NOSIGNAL #define MSG_NOSIGNAL 0 #endif #pragma comment(lib,"ws2_32.lib") DWORD WINAPI ReceiveThread(LPVOID lpParam) { SOCKET sockClient = (SOCKET)lpParam; char recvBuf[50]; while (1) { // 接收服务器的消息并打印出来 int ret = recv(sockClient, recvBuf, 50, 0); if (ret <= 0) { break; } printf("Received from server: %s\n", recvBuf); } return 0; } int main() { WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD(1, 1); err = WSAStartup(wVersionRequested, &wsaData); if (err != 0) { return -1; } if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { WSACleanup(); return -1; } // 创建套接字并连接到服务器 SOCKET sockClient = socket(AF_INET, SOCK_STREAM, 0); SOCKADDR_IN addrSrv; addrSrv.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); addrSrv.sin_family = AF_INET; addrSrv.sin_port = htons(6000); connect(sockClient, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR)); // 创建新线程来接收服务器的消息 HANDLE hThread = CreateThread(NULL, 0, ReceiveThread, &sockClient, 0, NULL); char sendBuf[50]; while (1) { // 读取用户输入的消息并发送给服务器 printf("Input message to send: "); fgets(sendBuf, 50, stdin); send(sockClient, sendBuf, strlen(sendBuf) + 1, 0); } // 关闭线程句柄 CloseHandle(hThread); closesocket(sockClient); WSACleanup(); return 0; }
这段代码是一个简单的客户端代码,主要功能是连接服务器,并发送和接收消息。它也使用了 WinSock2 库来进行网络编程。在主函数中,首先调用了 WSACleanup() 函数来释放 WinSock2 库占用的资源。然后创建了一个套接字,并将其连接到服务器。接着创建一个新线程来接收服务器的消息,使用 fgets() 函数读取用户输入的消息,并将其发送给服务器。在 ReceiveThread 函数中,不断接收服务器发送的消息,并打印出来。当服务器断开连接时,该线程退出。在主函数中,当用户输入 exit 命令时,关闭线程句柄,释放套接字并释放 WinSock2 库占用的资源。
阅读全文