使用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
问题是(行为不端的)透明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