【问题标题】:c++ sockets multiple requestsc ++套接字多个请求
【发布时间】:2018-11-28 13:48:31
【问题描述】:

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

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

这是我的课(我只把它作为草稿留在了 H 文件中,当它工作时会使它更体面)

#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 编译器)。

感谢您的帮助。

【问题讨论】:

    标签: c++ sockets http client


    【解决方案1】:

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

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

    但是,无论哪种方式,您都必须正确阅读响应(您不是)才能检测到响应的正确结尾(请参阅RFC 2616 Section 4.4RFC 7230 Section 3.3.3),所以您不要'不会损坏同一连接上的多个响应之间的数据。

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

    【讨论】:

    • 我不明白,正确结束响应是什么意思?连接失败是因为我在队列中有东西吗?我在套接字类中添加了一个关闭例程并打开套接字并在循环中打开和关闭套接字,但在第二个循环中我仍然没有响应。
    • 你读过我链接的 RFC 吗?他们解释了我指的是什么。如果要通过单个 TCP 连接发送多个请求,则需要正确读取响应。您必须阅读到响应的正确结尾,不多也不少,否则您将破坏您处理的数据。 ReadLine() 循环可用于读取 HTTP 响应标头,但它不是读取 HTTP 响应正文的正确方法,甚至不能关闭。
    • 是的。但是当我阅读只要服务器发送一些东西时,我就找不到下一个请求没有得到响应的原因(或者有时只有标头而没有消息正文)阅读或发送后没有确认,或者我错了?
    • @TRode 你必须遵守协议!我怎么强调都不过分。你不能只是盲目地阅读,直到没有东西可以阅读。您必须首先阅读响应标头并对其进行分析,以了解是否存在响应正文以及以何种格式对其进行编码,以便您知道如何读取它以及何时停止读取它。正确的阅读逻辑见this pseudo code
    • 好的,首先感谢您的帮助...我会更清楚地解释我的问题。我使用 HTTP 连接到传感器,但没有内容长度。当我无法收到标题时,如何分析内容长度?我发送第一个 recv() - 命令。比我得到的标题“HTTP/1.1 400 Bad Reques Server: nginx Date: xxx Content-Type: text/html Content-Length 166 Connection: keep-alive \empty line ... 所以。当我在头文件完成后读取了我的 166 个字节,我仍然无法通过发送 GET 命令发送请求来接收任何附加内容。
    【解决方案2】:

    在第二个循环中send() 为我返回错误:WSAECONNABORTED

    当涉及到错误时,套接字真的很有趣,因此您应该使用真实的错误编号检查 send() 等失败背后的真实错误。换行

        if(result<0){
            printf("Error Occured!\n");
            return -1;
        }
    

        if(result < 0) {
            printf( "Error Occured: %i\n", WSAGetLastError() );
            return -1;
        }
    

    得到真正的错误。

    WSAECONNABORTED 表示协议可能存在超时或问题。 Windows socket errors

    我认为这是由于服务器在完成请求后自动断开连接造成的,因此每个请求都需要一个新的连接。 There is no persistent connection.

    我查看了自己的代码,并按此顺序进行:

    • 连接
    • 发送请求
    • 接收数据
    • 等待服务器断开连接

    除此之外,您的代码中似乎还有一些错误。 例如。在 result = send(s,Package,PackageSize,0); 中,您始终发送 10 个字符,即使之前的循环由于 if(BufferSize &lt;= Pointer) 而被留下 - 这意味着您向服务器发送了一些垃圾字符。这可以避免

    for(i = 0; i < BufferSize; i += PackageSize) {
        int packageSize = 0;
        for(j = 0; j < PackageSize; j++) {
            Package[j] = Buffer[Pointer];
            packageSize = Pointer;
            Pointer++;
            if(BufferSize <= Pointer) {
                break;
            }
        }
        result = send( s, Package, packageSize, 0 );
    
        if(result < 0) {
            printf( "Error Occured: %i\n", WSAGetLastError() );
            return -1;
        }
    
    }
    

    【讨论】:

    • 谢谢。当我添加“连接:保持活动”或关闭并在每个循环中重新打开套接字时,我摆脱了 WSAECONNABORTED。我还在每个错误语句中添加了带有 WSAGetLastError() 的端口。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2011-08-05
    • 1970-01-01
    • 1970-01-01
    • 2021-01-12
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多