C Prog - Постоянное прослушивание веб-сервера - PullRequest
Новая
       10

C Prog - Постоянное прослушивание веб-сервера

1 голос
/ 14 марта 2011

Я пытаюсь научиться программировать в Winsock, используя онлайн-уроки.Этот пример взят из библиотеки MSDN, хотя и изменен.Я скомпилировал его, и он, кажется, работает нормально только для одного запроса.После обработки одного запроса сервер завершает работу.Я читал, как обрабатывать множественные запросы, и сделать сервер постоянным можно с помощью потоков, но я не знаю, как это сделать, и никаких полезных примеров не найдено в Интернете.Пожалуйста, помогите. 

#undef UNICODE

#define WIN32_LEAN_AND_MEAN

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

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

#define DEFAULT_BUFLEN 4096
#define DEFAULT_PORT "27015"
char recvbuf[DEFAULT_BUFLEN];

void handleBuffer()
{
recvbuf[DEFAULT_BUFLEN-1]='\0';
printf("\n************The server has received the following request***************\n");
printf("%s",recvbuf);
}

int __cdecl main(void)
{
WSADATA wsaData;
SOCKET ListenSocket = INVALID_SOCKET,
       ClientSocket = INVALID_SOCKET;
struct addrinfo *result = NULL,hints;
char* sendbuf = "HTTP/1.0 200 OK\r\nServer: Test\r\nContent-Type: text/HTML\r\n\r\n<html><title>Test Server</title><body><span style=\"color:#2032DC; font-family:arial; font-size:large; position:absolute; left:4%;\">This is test server responding.</span></body></html>";
int iResult, iSendResult;
int recvbuflen = DEFAULT_BUFLEN;
char e;

// Initialize Winsock
iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
if (iResult != 0) {
    printf("WSAStartup failed with error: %d\n", iResult);
    return 1;
}
else
    printf("\nInitialising winsock...done");

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

// 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;
}
else
    printf("\nResolving server address...done");
//localhost:27015/
// 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;
}
else
    printf("\nCreating connection socket...done");

// 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;
}
else
    printf("\nCreating listening socket...done");
    printf("\nWaiting for connection... ");

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);

    iResult = recv(ClientSocket, recvbuf, recvbuflen,0);
    if (iResult > 0)
    {
        printf("Bytes received: %d\n", iResult);
    }
    else if (iResult == 0)
        printf("Connection closing...\n");
    else
    {
        printf("recv failed with error: %d\n", WSAGetLastError());
        closesocket(ClientSocket);
        WSACleanup();
        return 1;
    }


    iSendResult = send(ClientSocket,sendbuf,(int)strlen(sendbuf), 0 );
        if (iSendResult == SOCKET_ERROR)
        {
            printf("send failed with error: %d\n", WSAGetLastError());
            closesocket(ClientSocket);
            WSACleanup();
            return 1;
        }
    printf("Bytes sent: %d\n", iSendResult);
    handleBuffer();

    // shutdown the connection since we're done
    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();
printf("\n\nPress any key to quit.");

getch();
return 0;
}

1 Ответ

1 голос
/ 14 марта 2011

Это прямо вперед. 

  ClientSocket = accept(ListenSocket, NULL, NULL);

Возвращает сокет, используемый для связи с подключенным клиентом, все, что вам нужно сделать, это сделать цикл чтения / записи для этого сокета и вставить его в новый поток. Тем временем, продолжайте свой основной цикл на accept ().

Что ты не получишь?

EDIT

Предполагая, что вы собираетесь использовать Posix Threads, посмотрите на это http://www.yolinux.com/TUTORIALS/LinuxTutorialPosixThreads.html

После освоения этого вам может потребоваться больше мощности и гибкости: проверьте это http://www.lowtek.com/sockets/select.html

Вы можете использовать select, чтобы избежать использования потоков, вы можете использовать его для распределения ваших клиентов через потоки (например, 1.N клиент управляется 1 потоком)

Примечание

Подождите, в вашем коде есть дыра: 

int recvbuflen = DEFAULT_BUFLEN;

затем вы используете это в получении .. это плохо, это может привести к переполнению, чтобы решить эту проблему, объявите ваш буфер как: char recvbuf [DEFAULT_BUFLEN + 1];

...