Winsock2侦听回路

Question

你好，再次精彩的堆叠溢出社区！上一次我问了一个问题，这个问题很快就解决了，我希望这个问题也能解决。:)

所以我在玩winsock，我希望能够同时连接多个客户端到我的服务器。我觉得可以通过每次客户端连接时循环线程创建、套接字创建、绑定和侦听来实现这一点，但我这样做的努力只会出现“侦听失败和错误”，这取决于我尝试了什么。我在谷歌上搜索它，只是为了找到高级MSDN示例中最简单，但仍然太难找到的例子。有人有什么简单的建议吗？(附带问题:我似乎无法让"mrecv()“返回整个"recvbuf”变量。我只收到一封信。我知道这是我犯的一个新手错误，但我就是搞不懂。:/但是，这个问题可以等到以后。)

(以下是目前为止的服务器代码：)

#undef UNICODE

#define WIN32_LEAN_AND_MEAN

#include <windows.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#include <stdlib.h>
#include <stdio.h>
#include <iostream>

// Need to link with Ws2_32.lib
#pragma comment (lib, "Ws2_32.lib")
// #pragma comment (lib, "Mswsock.lib")

int minitialize();
int msend(char msendbuf[512]);
char mrecv();
int mshutdown();

#define DEFAULT_BUFLEN 512
#define DEFAULT_PORT "10150"
 WSADATA wsaData;
 int iResult;

 SOCKET ListenSocket = INVALID_SOCKET;
 SOCKET ClientSocket = INVALID_SOCKET;

 struct addrinfo *result = NULL;
 struct addrinfo hints;

 int iSendResult;
 char recvbuf[DEFAULT_BUFLEN];
 int recvbuflen = DEFAULT_BUFLEN;

int main(void) 
{
    minitialize();
    mrecv();

    char mmessage[512];
    if (strncmp(mmessage,"shutdown",(strlen(mmessage))) == 0) {mshutdown();}
    std::cin.getline(mmessage, 512);
    msend(mmessage);

    // shutdown the connection since we're done
    mshutdown();
    std::cin.ignore();

    return 0;
}

int msend(char msendbuf[512])   // Send a message
{
    int iResult3 = send( ClientSocket, msendbuf, 512, 0 );
    if (iResult3 == SOCKET_ERROR) {
        printf("send failed with error: %d\n", WSAGetLastError());
        closesocket(ClientSocket);
        WSACleanup();
        return 1;
    }

    printf("Bytes Sent: %ld\n", iResult);
            std::cout<<"msendbuf: "<<msendbuf<<"\n";
            std::cin.ignore();
}

char mrecv() //Recieve a message
{
    int iResult2 = recv(ClientSocket, recvbuf, 512, 0);
        if (iResult2 > 0) {
            printf("Bytes received: %d\n", iResult2);
        std::cout<<"recvbuf: "<<recvbuf<<"\n";
        }
        else if (iResult2 == 0)
            printf("Connection closing...\n");
        else  {
            printf("recv failed with error: %d\n", WSAGetLastError());
            closesocket(ClientSocket);
            WSACleanup();
            return 1;
        }
    return *recvbuf;
}

int minitialize()   //initialize the winsock server
{
    // Initialize Winsock
    iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
    if (iResult != 0) {
        printf("WSAStartup failed with error: %d\n", iResult);
        return 1;
    }

    ZeroMemory(&hints, sizeof(hints));
    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE;

    // Resolve the server address and port
    iResult = getaddrinfo(NULL, DEFAULT_PORT, &hints, &result);
    if ( iResult != 0 ) {
        printf("getaddrinfo failed with error: %d\n", iResult);
        WSACleanup();
        return 1;
    }

    // Create a SOCKET for connecting to server
    ListenSocket = socket(result->ai_family, result->ai_socktype, result->ai_protocol);
    if (ListenSocket == INVALID_SOCKET) {
        printf("socket failed with error: %ld\n", WSAGetLastError());
        freeaddrinfo(result);
        WSACleanup();
        return 1;
    }

    // Setup the TCP listening socket
    iResult = bind( ListenSocket, result->ai_addr, (int)result->ai_addrlen);
    if (iResult == SOCKET_ERROR) {
        printf("bind failed with error: %d\n", WSAGetLastError());
        freeaddrinfo(result);
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    freeaddrinfo(result);

    iResult = listen(ListenSocket, SOMAXCONN);
    if (iResult == SOCKET_ERROR) {
        printf("listen failed with error: %d\n", WSAGetLastError());
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    // Accept a client socket
    ClientSocket = accept(ListenSocket, NULL, NULL);
    if (ClientSocket == INVALID_SOCKET) {
        printf("accept failed with error: %d\n", WSAGetLastError());
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    // No longer need server socket
    closesocket(ListenSocket);
}

int mshutdown()     //shutdown the server
{
    iResult = shutdown(ClientSocket, SD_SEND);
    if (iResult == SOCKET_ERROR) {
        printf("shutdown failed with error: %d\n", WSAGetLastError());
        closesocket(ClientSocket);
        WSACleanup();
        return 1;
    }

    // cleanup
    closesocket(ClientSocket);
    WSACleanup();
    return 0;
}

是的，如果你想知道，我计划把所有这些全局变量放在它们各自的局部函数中。我只是需要他们在那里清理一点杂乱，暂时，这似乎没有引起任何问题。

Answer 1

mrecv()被定义为

char mrecv()。

在函数mrecv()中，它返回一个字符串。因为根据定义，mrecv()应该返回一个字符，所以返回recvbuf的第一个字符。编译器不会抱怨return *recvbuf。这在语法上是正确的，即使意图是返回一个字符。

accept()将文件描述符返回到客户端的连接。在返回accept()时，您可以生成一个新的进程来使用此描述符处理消息，而原始进程则返回到接受连接。或者，在原始线程恢复接受连接时，可以创建一个新线程来处理来自此描述符的消息。您需要在accept()上循环。

下面是一个可以用于服务器的骨架模板。您已经在minitialize()上获得了所有正确的信息。在下面的示例代码中，mrecv()接受一个参数，即连接的客户端newconn的文件描述符。

socket()
bind()
listen(mysock, 10);
while(keep listening) {
    newconn = accept(mysock, &peeraddr, &peeraddrlen)
    if(newconn > 0) {
        if(CreateThread(<security attribute>, <stack size>, (void *)&mrecv, (void *)&newconn, <creation flag>, <threadid>))
            perror("Unable to create thread\n");
    }
}
closesocket(mysock)

Answer 2

我觉得这可以通过每次客户机连接线程创建、套接字创建、绑定和侦听的循环来实现。

不是的。您只需接受客户端连接并使用该套接字启动一个线程。严禁使用监听套接字。它不受accept()操作的影响，也不需要以任何方式重新构建它。