Как правильно читать данные с tcp-socket?

Question

[Quiab]

Здравствуйт! Как правильнее обходить следующую ошибку:
Разрабатывают клиент-серверное приложение
При определенных условиях клиент отправляет серверу сначала заголовок с размером следующего сообщения и прочей информацией, а затем отправляет данные для записи в БД
Кое-как кодится сервак, на самом деле, слишком много подводных камней
Сейчас, например, долго не мог понять, почему код перестал работать, а я лишь закоментил print(data) на сервере между sock.recv(title) и sock.recv(size), ибо закоментив строку у меня в первом чтение данных приходит сообщение типа: "size{message}" вместо просто size. Но если раскоментить print, сервер получает какую-то задержку и читает отдельно сообщения
Уже слишком часто бьюсь об проблему, что сервер читает больше или меньше данных, чем должен, поэтому решил обратиться сюда за помощью в решение. Как правильнее строить взаимодействие?

Comments

[Дмитрий]

Что мешает использовать стандартный протокол, а не писать свой?

Answer 1

[alfss]

Достаточно написать рабочий код.
Еще полезно почитать документацию.
Применив свой опыт телепат, я могу сказать, что вы вероятно не смотрели документацию по sock.recv . А вот что вы и как шлете, вообще загадка, вы бы привели код клиента и сервера, а заодно описание протокола общения. Еще можете поискать примеры на github.

Comments

[Quiab]

client

def fill_youself(owner):
        """ The func returns a list of notes """
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        sock.connect(('127.0.0.1',8888))
        title = "hash.get_all.%s"%owner #get_all
        sock.sendall(title.encode('utf-8'))
        if sock.recv(1024).decode() == "Success":

            #owner 
            sock.sendall(owner.encode('utf-8'))
            
            #get array
            notes = []

            for _ in range(int(sock.recv(512).decode())):
                size = sock.recv(1024).decode()
                if not size: break
                note = sock.recv(int(size))
                notes.append(json.loads(note))
               # print(notes)
            sock.close()
            return notes

        else:
            sock.close()
            return False

server

data = conn.recv(1024).decode()
        elif data.split('.')[1] == "get_all": # Get all notes
            # Send size
            owner = conn.recv(1024).decode() # Владелец
            notes = find_all(owner) # список всех записок для владельца
            conn.send(str(len(notes)).encode('utf-8'))
            for note in notes:
                note['_id'] = str(note['_id'])
                j_note = json.dumps(note)
                print(j_note)
                conn.send(str(sys.getsizeof(j_note)).encode('utf-8'))
                conn.send(j_note.encode('utf-8'))

Если уберу print, то чтение данных смещивается и сервак падает

[alfss]

for _ in range(int(sock.recv(512).decode())):
    size = sock.recv(1024).decode()

вы точно уверены в коде?

[Quiab]

Напротив, точно неуверен. К этому моменту не возвращался, все заработало и был рад, сейчас увидел, исправлю. Тем не мене, я в поисках объяснений на другой вопрос, понимаю, что считывая кб с потока я получу гораздо больше, чем ожидаю, но ищу я решение в общем виде, как избежать проблемы, что данные мешаются? Только строгим отслеживанием размеров входящих и исходящих данных?

[alfss]

Опишите свой протокол, что бы можно было различить один пакет от другого и следуя своему протоколу (поверх tcp) обрабптыаайте входящие данные. recv точно можно оставить 1 на все и пускать его в цикле.