gpt4 book ai didi

c - 读取连续消息

转载 作者:太空宇宙 更新时间:2023-11-03 23:39:08 25 4
gpt4 key购买 nike

我已经创建了一个服务器并试图监听一个特定的端口。当我用 netcat 向这个特定端口发送消息时,我成功读取了第一条消息,带有

read(fd_client_serv, buf, sizeof(buf));

系统调用。之后,将不会打印任何发送的消息。为什么会这样?

这是我的代码:

void start_server(void)
{

int fd_serv, fd_client_serv, bytes_read;
struct sockaddr_in client_serv_addr;
char buf[2048];

socklen_t sin_len_serv = sizeof(client_serv_addr);

fd_serv = initialize_server(get_serving_port());
fd_set_blocking(fd_serv, 0);

while(1)
{
fd_client_serv = accept(fd_serv, (struct sockaddr *) &client_serv_addr, &sin_len_serv);

puts("HA!!! you cannot block me!!!");
sleep(2);
memset(buf, 0, sizeof(buf));
write(fd_client_serv, "thank you for answering", 30);
bytes_read = read(fd_client_serv, buf, sizeof(buf));
printf("%d\n", bytes_read);
fflush(stdout);
printf("%s\n", buf);
}
}


int initialize_server(int port)
{

struct sockaddr_in server_addr;

int fd_temp;

int on = 1;

fd_temp = socket(AF_INET, SOCK_STREAM, 0);
if (fd_temp < 0)
{
perror("socket");
exit(1);
}
setsockopt(fd_temp, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(int));

server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(port);

if (bind(fd_temp,(struct sockaddr *) &server_addr, sizeof(server_addr)) == -1)
{
perror("bind");
close(fd_temp);
exit(1);
}
if (listen(fd_temp, 10) == -1)
{
perror("listen");
close(fd_temp);
exit(1);
}
return fd_temp;
}


int fd_set_blocking(int fd, int blocking)
{
/* Save the current flags */
int flags = fcntl(fd, F_GETFL, 0);
if (flags == -1)
return 0;

if (blocking)
flags &= ~O_NONBLOCK;
else
flags |= O_NONBLOCK;
return fcntl(fd, F_SETFL, flags) != -1;
}

我刚刚注意到,如果我关闭 netcat(或 telnet)并启动一个新的,我可以再次阅读发送的第一条消息。但仅此而已。

最佳答案

accept() 接受一个新连接。因此,每次通过循环,您都将 fd_client_serv 设置为新连接的套接字 ID,从而放弃旧连接。 (“放弃”是指您永远不会再从中读取,因为您已经丢失了它的 ID。您没有关闭它,但您已经忘记了它。)

关于c - 读取连续消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50321932/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com