0

Написал сокет-сервер на python (ubuntu), а клиента на c++ (windows). Проблема в том, что на сервере функция recv требует оповещение об закрытиии сокета (shutdown) от клиента, иначе на этом месте скрипт останавливается. Если же я вызову shutdown на стороне клиента, сервер примет сообщение и отправит ответное, но клиент-сокет больше не сможет ни отправлять, ни получать данные (из-за этого shutdown). А мне нужно обмениваться данными в цикле.

Вот примерно так:

клиент:

 1.инициализация сокета
 2. подключение к серверу
 3. отправка данных
 4. получение ответа от сервера
 5. отправка данных
 6. получение ответа от сервера  ...
 55. закрытие соединения

server.py:

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind((host, port))

sock.listen(10)

while 1:
    conn, addr = sock.accept()
    print('new connection from ' + addr[0] + ":" + str(addr[1]))

    data = bytearray()

    while 1:
        while 1:
            chunk = conn.recv(128)

            if not chunk:
                break
            else:
                data += chunk

        print(str(len(data)) + " bytes received (" + data.decode('ascii', 'strict') + ")")

        date = strftime("%Y-%m-%d %H:%M:%S", gmtime())

        bytes_len = conn.send(date.encode('ascii'))
        print(str(bytes_len) + " bytes sent")

    print('closing the connection..')
    conn.close()

sock.close()

client.exe:

int send_data(SOCKET sock, const char* data, int datalen)
{
    int bytes_len = send(sock, data, datalen, 0);

    if (bytes_len < 0) {
        return -1;
    }

    /*if (shutdown(sock, SD_SEND) < 0) {
        return -1;
    }*/

    return bytes_len;
}

int recv_data(SOCKET sock, char* buf)
{
    log("0");
    int recvlen = 0;

    char chunk[128];
    memset(chunk, 0, sizeof(chunk));

    do {
        log("1");
        int len = recv(sock, chunk, sizeof(chunk), 0);
        log("2");
        if (len == -1)
            return -1;

        if (len == 0)
        {
            /*if (shutdown(sock, SD_RECEIVE) < 0) {
                return -1;
            }*/

            return recvlen;
        }

        memcpy(buf + recvlen, chunk, len);
        memset(chunk, 0, sizeof(chunk));

        recvlen += len;

    } while (true);
}

void force()
{
    char* ip = "";
    int port = 0;

    int result;
    WSADATA wsaData;

    log("socket startup..");
    result = WSAStartup(MAKEWORD(2, 2), &wsaData);

    if (result != 0) {
        log("wsastartup failed: %d", result);
        return;
    }

    log("creating socket..");
    SOCKET sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

    if (sock == INVALID_SOCKET) {
        log("error creating socket: %d", WSAGetLastError());
        WSACleanup();
        return;
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(struct sockaddr_in));

    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr(ip);
    addr.sin_port = htons(port);

    log("connecting to %s:%d", ip, port);
    result = connect(sock, (sockaddr *)&addr, sizeof(addr));

    if (result == SOCKET_ERROR) {
        log("Unnable to connect to server: %d", WSAGetLastError());
        WSACleanup();
        return;
    }


    for (int i = 0; i < 10; i++)
    {
        string msg = "hello from windows " + to_string(i);

        int bytes_len = send_data(sock, msg.c_str(), msg.length());

        if (bytes_len < 0)
        {
            log("Error sending data: %d", WSAGetLastError());
            closesocket(sock);
            WSACleanup();
            return;
        }

        log("%d bytes sent..", bytes_len);

        char buf[1024];
        memset(buf, 0, sizeof(buf));

        bytes_len = recv_data(sock, buf);

        if (bytes_len < 0)
        {
            log("Error receiving data: %d", WSAGetLastError());
            closesocket(sock);
            WSACleanup();
            return;
        }

        log("%d bytes received (%s)", bytes_len, buf);
    }

    log("socket closing..");
    closesocket(sock);

    log("wsa cleanup..");
    WSACleanup();

    return;
}
7
  • "на этом месте скрипт останавливается" - так наверное надо делать обработку ошибок каким-то образом, не? 25 авг 2018 в 14:21
  • > функция recv требует оповещение об закрытиии сокета Что значит "требует" в данном контексте?
    – isnullxbh
    25 авг 2018 в 15:23
  • @VTT, это нормальное поведение функции, ф-я recv останавливает скрипт и ждет данные, но проблема в том, что когда она их получает, она не возобновляет скрипт, пока не получит shutdown() со стороны клиента, а должна дальше возобновлять работу скрипта. По крайней мере, в документациях я такого не находил
    – saulgdmn
    25 авг 2018 в 15:46
  • @isnullxbh, не дает дальше исполняться скрипту, пока не получит shutdown() со стороны клиента. Хотя так быть не должно, я не знаю в чем проблема. Если использовать shutdown(), то все работает, данные получаются и скрипт дальше исполняется, но в таком случае и клиентский сокет сворачивается и дальше его использовать нельзя.
    – saulgdmn
    25 авг 2018 в 15:48
  • @saulgdmn, покажите версию кода серверной части вместе с вызовом ф-ии shutdown.
    – isnullxbh
    25 авг 2018 в 16:36

1 ответ 1

1

Сервер ожидает, что ему придет от клиента 128 байт данных:

chunk = conn.recv(128)

Клиент отправляет явно меньше:

string msg = "hello from windows " + to_string(i);

Вызов conn.recv(128) - блокирующий, т.е., если в буфере сокета нет данных - он будет ждать.

Спасибо @jfs за замечание

Когда Вы вызываете shutdown(sock, SD_RECEIVE) отправляется пакет с сегментом FIN (на самом деле их отправляется несколько) - и тогда read возвращает ноль (EOF - с данного сокета вы больше не можете читать данные):

if not chunk:
                break

Что в итоге позволяет выйти из цикла.

7
  • Вы верно меня поняли. Но как это обойти?
    – saulgdmn
    25 авг 2018 в 22:31
  • @saulgdmn, тут уже Вам нужно думать, потому что это зависит от задачи. Можете передавать в первых четырех байтах размер посылки. Можете реалиовать полноценный протокол (размер сообщения завсит от его типа). В общем, учтите, что ни серверная сторона, ни клиентская ничего не знают о размере посылки с противоположной стороны.
    – isnullxbh
    26 авг 2018 в 2:40
  • благодарю за ответ)
    – saulgdmn
    26 авг 2018 в 11:12
  • @saulgdmn: fyi, conn.recv(128) не обязан ждать полные 128 байт. Этот вызов может вернуться прочитав только один байт. 128 это размер буфера, а не размер результата: 1 <= len(chunk) <= 128.
    – jfs
    26 авг 2018 в 19:03
  • @jfs, спасибо огромное за замечание, ведь действительно, данное поведение ничем не отличается от поведения системного вызова recv. Спасибо!
    – isnullxbh
    26 авг 2018 в 19:15

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.