Главная страница | Контакты | Случайная страница Автомобили Астрономия Биология География Дом и сад Другие языки Другое Информатика История Культура Литература Логика Математика Медицина Металлургия Механика Образование Охрана труда Педагогика Политика Право Психология Религия Риторика Социология Спорт Строительство Технология Туризм Физика Философия Финансы Химия Черчение Экология Экономика Электроника

Потоковые протоколы

Большинство протоколов с установлением соединения являются потоковы­ми. Важно учитывать, что при использовании любой функции отправки или приема данных через потоковый сокет нет гарантии, что вы прочитаете или запишете весь запрошенный объем данных. Скажем, требуется отправить 2048 байт из символьного буфера функцией send:

char sendbuff[2048];

int nBytes = 2048;

// Заполнение буфера sendbuff 2048 байтами данных

// Присвоение s значения действительного потокового сокета соединения

ret = send(s, sendbuff, nBytes, 0);

Возможно, функция send сообщит об отправке менее 2048 байт. Перемен­ная ret будет содержать количество переданных байт, поскольку система вы­деляет определенное количество буферного пространства на отправку и прием сообщений для каждого сокета. При отправке данных внутренние бу­феры удерживают их до момента отправки непосредственно по проводу. Причиной неполной отправки может быть, например, передача большого количества данных, при этом все буферы слишком быстро заполнятся.

В TCP/IP также существует так называемый размер окна. Принимающая сторона регулирует его, указывая количество данных, которое способна при­нять. При переполнении данными получатель может задать нулевой размер окна, чтобы справиться с поступившими данными. Это приведет к приоста­новке отправки данных, пока размер окна не станет больше 0. В нашем слу­чае размер буфера может оказаться равным 1024 байтам, следовательно, по­требуется повторно отправить оставшиеся 1024 байта. Отправку всего содер­жимого буфера обеспечит следующий фрагмент программы:

char sendbuff[2048];

int nBytes = 2048, nLeft, idx;

// Заполнение буфера sendbuff 2048 байтами данных

// Присвоение s значения действительного потокового сокета соединения

nLeft = nBytes;

idx = 0;

while (nLeft > 0)

{

ret = send(s, &sendbuff[idx], nLeft, 0);

if (ret == SOCKET_ERROR)

{

// Ошибка

}

nLeft -= ret;

idx += ret;

Все, сказанное далее справедливо и для приема данных на потоковом сокете, но для нас это не очень важно. Приложение не знает, сколько дан­ных оно в очередной раз прочтет на потоковом сокете. Если вам нужно от­править дискретные сообщения по потоковому протоколу, это не составит труда. Например, если у всех сообщений одинаковый размер (512 байт), то прочитать их можно так:

char recvbuff[1024];

int ret, nLeft, idx;

while (nLeft > 0)

{

ret = recv(s, &recvbuff[idx], nLeft, 0);

if (ret == SOCKET_ERROR)

{

// Ошибка

}

idx += ret;

nLeft -= ret;

}

Ситуация несколько усложнится, если размер сообщений будет варьиро­ваться. Тогда потребуется реализовать собственный протокол, сообщающий получателю о размере поступающего сообщения. Пусть первые 4 байта со­общения указывают его размер в виде целого числа. Преобразовав их в чис­ло при чтении, приемник узнает длину сообщения.