C++套接字多个请求

Question

我已经为套接字通信创建了一个简短的类，并希望向同一设备发送和接收多次(这里以 www.kernel.org 为例，在我的例子中，它是一个通过以太网连接的传感器)。通信正在使用 HTTP，我使用“PacketSender”测试了设备，它工作正常。

我第一次尝试发送请求并获得预期的响应。然后我想循环它，但是我可以发送尽可能多的不同请求，但我什么也得不到。

这是我的类(class)(我只是把它作为草稿留在了 H-File 中，当它工作时会让它更体面)

#ifndef SOCKETCLASS_H_INCLUDED
#define SOCKETCLASS_H_INCLUDED

#include <windows.h>
#include <winsock2.h>

#include <stdio.h>

#pragma comment(lib, "Ws2_32.lib")

class WinSocket{
private:
    SOCKET s;
    long rc;
    int Status = 0;
    int PackageSize = 10;

public:

    WinSocket(){
       rc=startWinsock();
        if(rc!=0){
            printf("Error: startWinsock failed, ErCode %d \n",int(rc));
            Status= -1;
        }else{
            printf("Winsock ready!\n");
        }

    }

    int openSocket(char *IPv4, int Port){
        SOCKADDR_IN addr;

        int rc = 0;

        s = socket(AF_INET,SOCK_STREAM,0);
        if(s==INVALID_SOCKET){
            printf("Error: Socket could not be created! ErCode: %d\n",WSAGetLastError());
            return 1;
        }else{
            printf("Socket created\n");
        }

        memset(&addr,0,sizeof(SOCKADDR_IN));
        addr.sin_family=AF_INET;
        addr.sin_port=htons(80);    
        addr.sin_addr.s_addr=inet_addr(IPv4);    

        rc=connect(s,(SOCKADDR*)&addr,sizeof(SOCKADDR));
        if(rc==SOCKET_ERROR){
            printf("Error: Failed to connect, ErCode: %d\n",WSAGetLastError());
            return 1;
        }else{
            printf("Connected to %s...\n",IPv4);

        }

        return 0;
    }

    int sendPackage(char *Buffer, int BufferSize){
        int i,j;
        int result;
        int Pointer = 0;


        char *Package;
        Package = new char[PackageSize];

        for(i = 0; i < BufferSize; i+=PackageSize){
            for(j = 0; j < PackageSize; j++){
                Package[j] = Buffer[Pointer];
                Pointer++;
                if(BufferSize <= Pointer){
                    break;
                }
            }

            result = send(s,Package,PackageSize,0);
            if(result<0){
                printf("Error Occured!\n");
                return -1;
            }

        }
        delete[]Package;

        return 0;

    }



int readLine(char *Buffer, int *BufferSize){
    int MAX_BUFFERSIZE = 1024;
    int res = 0;
    char B[1];
    *BufferSize = 0;
    int Pointer = 0;

    for(int i=0;i<MAX_BUFFERSIZE;i++){
        res = recv(s,B,1,0);
        if(res > 0){
            if(B[0]!='\n'){
                //printf("%d;%s\n",res,B);
                Buffer[Pointer] = B[0];
                Pointer += 1;
            }else{
                Buffer[Pointer]='\n';
                *BufferSize = Pointer;
                return 0;
            }
        }else if(res == 0){
            return 1;
        }else{
            return -1;
        }
    }

    return 0;
}

int startWinsock(void){
    WSADATA wsa;
    return WSAStartup(MAKEWORD(2,0),&wsa);
}



      ~WinSocket(){
          closesocket(s);
      }
  };

  #endif // SOCKETCLASS_H_INCLUDED

作为主要功能，我使用以下代码:

#include <stdio.h>
#include "SocketClass.h"

int main(){
    char buf[256];

    int i,j;

    int requestSize = 100;
    char request[100];

    char Buf[1024];
    int BufferSize = 1;

    WinSocket S;

    S.openSocket("147.75.44.153",80);
    for(int l = 0; l<10; l++){
        printf("Loop %d\n",l);
        printf("Sending: ");
        requestSize =  sprintf(request,"GET /faq.html HTTP/1.1\r\nHost: www.kernel.org\r\nConnection: close\r\n\r\n");
        printf("%d Bytes: \n",requestSize);
        S.sendPackage(request,100);
        for(j= 0; j < requestSize; j ++){
            printf("%c",request[j]);
        }
        printf("\n");

        Sleep(500);


        printf("Waiting for responset...\n");

        while(BufferSize!=0){
            printf("Received: ");
            S.readLine(Buf, &BufferSize);
            printf("%d Bytes: \n",BufferSize);

            for(int i=0;i<BufferSize;i++){
                    printf("%c",Buf[i]);
            }
            printf("\n");
        }
        if(BufferSize==0){
            printf("\nNothing more received...\n");
        }
        printf("Repeat!\n");
        Sleep(5000);
    }

    printf("Finished...\n");
    printf("Press ENTER to continue...\n");
    getchar();
    return 0;
}

我测试了在每个循环中打开和关闭套接字。这有时是有效的(所以有没有我没有提到的未定义的指针？)，但我想要长时间的连接。

我不明白的是，为什么我可以发送多次，但只在第一次发送任何数据时接收。

我正在使用 Windows 7 和 mingw(GNU GCC 编译器)。

感谢您的帮助。

Answer 1

在您的 HTTP 请求中，您发送了一个 Connection: close header 。这意味着服务器将在发送响应后关闭其 TCP 连接的末端。您没有检测到该情况，因此您可以关闭当前套接字并在下一个请求时使用新套接字重新连接到服务器。

您说您希望连接对多个请求保持打开状态。这意味着您必须使用 HTTP keep-alives(参见 RFC 2616 Section 8.1 和 RFC 7230 Section 6.3 )。您需要从请求中删除 Connection: close header (因为 HTTP 1.1 默认使用 keep-alives)，或者用显式 Connection: keep-alive 替换它标题。

但是，无论哪种方式，您都必须正确阅读响应(您不是)以检测响应的正确结尾(参见 RFC 2616 Section 4.4 和 RFC 7230 Section 3.3.3 )，这样您就不会'在同一连接上的多个响应之间损坏数据。

并且您必须注意服务器响应中的 Connection header ，因为无法保证服务器实际上会接受保持连接的请求。如果服务器发送没有显式 Connection: keep-alive header 的 HTTP 1.0 响应，或者发送带有显式 Connection: close header 的 HTTP 1.1 响应，或者发送一个消息的长度由服务器指示以关闭连接，您必须关闭当前套接字并在下一个请求时重新连接新套接字。