Чтение последовательных сообщений - PullRequest
Новая
       29

Чтение последовательных сообщений

0 голосов
/ 14 мая 2018

Я создал сервер и пытаюсь прослушивать определенный порт. Когда я отправляю сообщение с 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) и запускаю новый, я могу снова прочитать первое отправленное сообщение. Но это все.

1 Ответ

0 голосов
/ 14 мая 2018

accept() принимает новое соединение. Поэтому каждый раз в цикле вы устанавливаете fd_client_serv для идентификатора сокета нового соединения, отказываясь от старого соединения. («Отказаться» в том смысле, что вы никогда больше не будете read от него, поскольку вы потеряли его идентификатор. Вы не закрыли его, но забыли об этом.)

...