当前位置: 首页 > 知识库问答 >
问题:

客户端在关机后向收到的数据包发送RST(SHUT_WR)

何长恨
2023-03-14

使用shutdown()关闭套接字连接的写入方向后,所有随后接收的数据都会导致发送RST数据包,并且返回0的大小,表示读取方向的EOF。为什么会这样,即使阅读方向没有关闭?

我使用wireshark检查了发送的数据包:

No. Time     Source        Destination   Protocol Length Info
1   0.000000 192.168.0.175 3.85.154.144  TCP      78     55318 → 80 [SYN] Seq=0 Win=65535 Len=0 MSS=1460 WS=32
2   0.114608 3.85.154.144  192.168.0.175 TCP      74     80 → 55318 [SYN, ACK] Seq=0 Ack=1 Win=26847 Len=0 MSS=1460 WS=256
3   0.114706 192.168.0.175 3.85.154.144  TCP      66     55318 → 80 [ACK] Seq=1 Ack=1 Win=131744 Len=0
4   0.115371 192.168.0.175 3.85.154.144  HTTP     112    GET /bytes/512 HTTP/1.1 
5   0.115401 192.168.0.175 3.85.154.144  TCP      66     55318 → 80 [FIN, ACK] Seq=47 Ack=1 Win=131744 Len=0
6   0.222652 3.85.154.144  192.168.0.175 TCP      66     80 → 55318 [ACK] Seq=1 Ack=47 Win=26880 Len=0
7   0.224444 3.85.154.144  192.168.0.175 HTTP     801    HTTP/1.1 200 OK  (application/octet-stream)
8   0.224543 192.168.0.175 3.85.154.144  TCP      54     55318 → 80 [RST] Seq=48 Win=0 Len=0
9   0.226056 3.85.154.144  192.168.0.175 TCP      66     80 → 55318 [FIN, ACK] Seq=736 Ack=48 Win=26880 Len=0
10  0.226100 192.168.0.175 3.85.154.144  TCP      54     55318 → 80 [RST] Seq=48 Win=0 Len=0

发送[FIN,ACK]后,所有接收到的数据都用RST响应。即使发送了FIN(表示写入数据的结束)而不是RST(表示连接的结束),本地端似乎认为连接已完全关闭。远程端希望能够发送数据,但不能。使用netstat监视套接字状态表明,在调用shutdown(sockfd,SHUT\u WR)后,连接立即完全关闭。

这是C中的一个MWE。它假设所有不相关的函数都成功,否则就会中止。检查所有函数的返回码是否有错误,以确保它们没有导致结果错误。

#include <arpa/inet.h>
#include <cerrno>
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>

#define RUN_OR_ABORT(fun) {\
    int RETVAL = fun;\
    if (RETVAL == -1)\
    {\
        perror(#fun);\
        abort();\
    }\
}

int main() {
    // Establish connection to httpbin.org:80
    int sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sockfd == -1) exit(EXIT_FAILURE);
    sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(80);
    // "httpbin.org" resolves to 3.85.154.144 or 52.71.234.219
    int retcode = inet_pton(addr.sin_family, "3.85.154.144", &addr.sin_addr);
    if (retcode != 1) exit(EXIT_FAILURE);
    RUN_OR_ABORT(connect(sockfd, (sockaddr*)&addr, sizeof(addr)));

    // Request 512 random bytes
    const char* msg = "GET /bytes/512 HTTP/1.1\r\nHost: httpbin.org\r\n\r\n";
    ssize_t write_len = write(sockfd, msg, strlen(msg));
    if (write_len != strlen(msg)) exit(EXIT_FAILURE);
    RUN_OR_ABORT(shutdown(sockfd, SHUT_WR));

    // Prepare buffer for recieving data
    size_t buf_size = 1024, read_offset = 0;
    char* buf = new char[buf_size];

    // Read as long as there is data available
    while (true) {
        ssize_t read_len = read(sockfd, buf + read_offset, buf_size - read_offset);
        if (read_len == -1 and (errno & (EAGAIN | EINTR)))
            continue;
        else if (read_len == -1) {
            perror("recv()");
            exit(EXIT_FAILURE);
        }
        read_offset += read_len;
        if (read_len == 0) {
            // EOF?
            printf("%lu bytes have been read\n", read_offset);
            break;
        }
        if (read_offset >= buf_size) {
            fprintf(stderr, "Unexpectedly large response\n");
            exit(EXIT_FAILURE);
        }
    }
}

我希望调用返回一个非零大小,并且套接字在关闭写入端后保持打开以进行读取(sockfd,SHUT\u WR)。MWE的预期输出为:

740 bytes have been read

(或类似,但读取字节数应大于512字节)。实际输出为:

0 bytes have been read

共有1个答案

羊舌旭尧
2023-03-14

问题是(行为不端的)透明HTTP代理。Avast的Web Shield在发送或接收数据包之前拦截数据包,并检查其是否存在恶意软件。Avast为此使用单独的内部套接字。一旦发送第一个FIN,Avast(错误地)关闭其内部插槽。这会被传递到客户端的套接字,这就是为什么它之后不会出现在netstat中。然后拒绝服务器的数据,因为负责处理传入数据的Avast套接字不再打开。Avast关闭第一个FIN数据包上的连接的策略(不告诉服务器;在收到数据之前没有RST数据包)有效,因为几乎所有HTTP客户端都不会调用shutdown(sockfd,SHUT\u WR),只有在没有更多数据可读取时才调用连接。

 类似资料:
  • 长连接服务(TCP、WebSocket)支持向客户端推送数据,具体用法https://doc.imiphp.com/utils/Server.html

  • 长连接服务(TCP、WebSocket)支持向客户端推送数据,具体用法https://doc.imiphp.com/utils/Server.html

  • 使用worker来做服务器,没有用GatewayWorker,如何实现向指定用户推送消息? <?php use WorkermanWorker; require_once __DIR__ . '/Workerman/Autoloader.php'; // 初始化一个worker容器,监听1234端口 $worker = new Worker('websocket://workerman.net:1

  • 我正在开发一个应用程序,创建一个报告,并将其发送给客户端。我使用了以下代码:XDocReport和Grails。 1)给定上面的代码,哪里出了问题?bug的原因是什么?2)为了将文件发送到客户机,需要执行的触发器或代码行是什么?

  • 使用worker来做服务器,没有用GatewayWorker,如何实现向指定用户推送消息? <?php use WorkermanWorker; require_once __DIR__ . '/Workerman/Autoloader.php'; // 初始化一个worker容器,监听1234端口 $worker = new Worker('websocket://workerman.net:1