Что делать если данные при передаче через сокеты сливаются?

Question

[Тимофей Болгарин]

Я передаю несколько данных, картинку и после текст через сокеты. При работе на локальном пк все было нормально более менее. Когда запустил приложение на разных пк(клиент и сервер), то почти все строки стали битыми.

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))
While True:
        # Recieve photo
        data = s.recv(1000000)
        image = png_bytes_2_opencv_image(data)
        coords = (1,2)
        
        # Recieve state
        data = s.recv(1000000)
        state = {}
        try:
            decoded_data = data.decode("utf-8")
            state = json_.loads(decoded_data)
        except Exception as e:
            print(e)

IPEndPoint ipPoint = new IPEndPoint(IPAddress.Parse(addr), port);
        listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        try
        {
            listenSocket.Bind(ipPoint);
            listenSocket.Listen(1);
            connected = true;
            Debug.Log("Сервер запущен. Ожидание подключений...");
            Application.runInBackground = true;
            listenerFlag = true;
            startServer();
        }
        catch (Exception ex)
        {
            Debug.Log(ex.Message);
        }
Socket handler = listenSocket.Accept();
while(true){
//Sending png
                    byte[] data_png = car_controller.PngFromCam;
                    handler.Send(data_png);

                    //Sending JSON
                    Dictionary<string, string> dict_data = new Dictionary<string, string>
                    {
                        ["ID"] = 0.ToString(),
                        ["CurrentSpeed"] = Math.Round(car_controller.CurrentSpeed, 1).ToString(),
                        ["CurrentSteering"] = Math.Round(car_controller.CurrentSteering, 1).ToString()
                    };
                    string json = MiniJSON.Json.Serialize(dict_data);
                    Debug.Log(json);
                    byte[] data_json = Encoding.UTF8.GetBytes(json);
                    handler.Send(data_json);
}

Answer 1

[jcmvbkbc]

Что делать если данные при передаче через сокеты сливаются?

При работе с потоковыми протоколами так и должно быть. Если приложение работает с сообщениями -- приложение должно само организовать себе фрейминг в потоке данных.

Recieve

receive

Comments

[Тимофей Болгарин]

А каким образом можно это сделать? Я вообще думал что раз там TCP протокол, то система сама позаботится о нормальной доставке.

[jcmvbkbc]

система сама позаботится о нормальной доставке

Тимофей Болгарин, система и заботится о нормальной доставке. У вас просто другое ожидание "нормальности".

А каким образом можно это сделать?

Масса вариантов. Общая идея -- обозначать границы пакетов данных в самих данных. Например передавая размер пакета данных: TLV. Или разделяя пакеты символом, который не встречается в пакетах.

[Тимофей Болгарин]

jcmvbkbc, а если обязательно чередовать прием данных и отправку, не делать последовательных отправок. То есть после каждого принятого пакета отправлять ответ типа ОК. Это сработает же тоже?

[jcmvbkbc]

Тимофей Болгарин, не так важно, как отправлять данные, важно как принимать.

а если обязательно чередовать прием данных и отправку, не делать последовательных отправок. То есть после каждого принятого пакета отправлять ответ типа ОК

Когда вы поймёте, что в TCP нет "пакетов", вам станет гораздо лучше. За один вызов read/receive можно получить любое количество принятых данных, нет никаких гарантий, что оно будет равно размеру данных, переданных в send/write.

[Сергей]

Тимофей Болгарин аналогия для TCP канала:
это две трубы, в которых водичка течет в разных направлениях.
в одном слева направо, в друго справа налево.
на концах трубы есть такие водоприемники (бассейны, буфферы), куда приложения "сливают" свои данные.
данные там группируются как-то и отправляются пакетами (порциями) в трубы на другой конец, там тоже свой бассейн есть. Вы можете вынимать из этого бассейна сколько угодно воды (данных). Т.о. то что отправляется приложением не факт что будет передано так же и теми же порциями.