ReSQL.ru
     
powered by simpleCommunicator - 2.0.59     © 2025 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / C++ [игнор отключен] [закрыт для гостей] / Сокеты в си
43 сообщений из 43, показаны все 2 страниц
  все  
Сокеты в си
    #39086404
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Добрый день.

У меня возник вопрос по сокетам в си. Как правильно написать, если сокет за один раз не сможет принять объём передаваемых данных
rc = recv(sock, &buf_lin2, BufferLength,0 ); наверно уже будет не совсем верно?
...
Рейтинг: 0 / 0
26.10.2015, 09:41
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086476
Фотография mayton
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
mayton
Участник
Код: plaintext
1.
do{ rc=recv(....) } while(..)
...
Рейтинг: 0 / 0
26.10.2015, 10:31
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086479
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
Проверять по содержимому все пришло или нет. Формат передачи должен предусматривать указание где конкретно расположены данные, т.к. TCP-соединение просто передает поток байт.
Например передаешь сначала размер блока данных, затем сами данные. При получении читаешь размер, затем данные, затем проверяешь все ли данные пришли или еще есть не принятые. Если есть непринятые - ждешь недостающее.
...
Рейтинг: 0 / 0
26.10.2015, 10:33
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086564
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Сделал так, но почему -то не работает первое чтение read отрабатывает а при 2 чтение вылетает из цикла не доходя даже до if(rc < 0)

Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
  while(totalcnt < BufferLength)
                                                                	{
                                                                           rc = read(sock, &buf_lin2[totalcnt], (BufferLength - totalcnt));
                                                                   	   if(rc < 0)
                                                                           {
                                                                               perror("Server-read() error");
                                                                               if (flagpervogchten==0)
                                                                               flagoshib=2;
                                                                               break;
                                                                            }
                                                                           else if (rc == 0)
                                                                           {
                                                                        	   if (flagpervogchten==0)
                                                                        	   flagoshib=2;
                                                                               break;
                                                                           }
                                                                           else
                                                                           {
                                                                               totalcnt += rc;
                                                                               flagpervogchten=1;
                                                                               printf("Server-read() is OK\n");
                                                                           }
                                                                           }
                                                                          if (flagoshib==1)
                                                                           obrabwialonretr(buf_lin2, sock);



Да тут за раз всё передалось, но если не за раз как же здесь сделать?
...
Рейтинг: 0 / 0
26.10.2015, 11:21
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086609
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кДобрый день.

У меня возник вопрос по сокетам в си. Как правильно написать, если сокет за один раз не сможет принять объём передаваемых данных
rc = recv(sock, &buf_lin2, BufferLength,0 ); наверно уже будет не совсем верно?

0)для начала нужно напомнить, что если сокет не udp, то он потоковый. в нем нет сообщений и блоков.

1) сокеты - это файлы, можно просто читать read ом. посимвольно, построчно. это кстати не будет медленнее.
2) если за один recv не получилось принять, можно еще раз вызвать recv.
...
Рейтинг: 0 / 0
26.10.2015, 11:43
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086616
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кСделал так, но почему -то не работает первое чтение read отрабатывает а при 2 чтение вылетает из цикла не доходя даже до if(rc < 0)

Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
  while(totalcnt < BufferLength)
                                                                	{
                                                                           rc = read(sock, &buf_lin2[totalcnt], (BufferLength - totalcnt));
                                                                   	   if(rc < 0)
                                                                           {
                                                                               perror("Server-read() error");
                                                                               if (flagpervogchten==0)
                                                                               flagoshib=2;
                                                                               break;
                                                                            }
                                                                           else if (rc == 0)
                                                                           {
                                                                        	   if (flagpervogchten==0)
                                                                        	   flagoshib=2;
                                                                               break;
                                                                           }
                                                                           else
                                                                           {
                                                                               totalcnt += rc;
                                                                               flagpervogchten=1;
                                                                               printf("Server-read() is OK\n");
                                                                           }
                                                                           }
                                                                          if (flagoshib==1)
                                                                           obrabwialonretr(buf_lin2, sock);



Да тут за раз всё передалось, но если не за раз как же здесь сделать?


если вылетает,то это наверное защита памяти, там ничто не может больше проводить к выходу из цикла.
...
Рейтинг: 0 / 0
26.10.2015, 11:47
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086626
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Так вот и непонятно что может быть, и ошибок не выдаёт то ведь просто выход происходит из цикла и процедуры
char buf_lin2[50000];
int BufferLength=50000;
Может как -то по другому написать? Есть правильнее запись этого безобразия?
...
Рейтинг: 0 / 0
26.10.2015, 11:56
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086631
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Нет я ошибся не выход происходит а в цикле while ждёт дальше прихода данных, я не знаю только сколько данных ко мне должно прийти, обычно приходит пакет, который может состоять и 204 байт или кратному быть этому размеру, и обычно вконце 204 байтом идёт символ
strokdan[203] char 64 '@'
strokdan[407] char 64 '@'
...
Рейтинг: 0 / 0
26.10.2015, 12:02
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086703
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кНет я ошибся не выход происходит а в цикле while ждёт дальше прихода данных, я не знаю только сколько данных ко мне должно прийти, обычно приходит пакет, который может состоять и 204 байт или кратному быть этому размеру, и обычно вконце 204 байтом идёт символ
strokdan[203] char 64 '@'
strokdan[407] char 64 '@'

Ну я так и думал.
Но тут я ж говорю, тебе никто не поможет, ты должен сам понимать, когда и что ты должен получить.
Это в TCP определяется протоколами высшего уровня -- HTTP, POP3 и так далее.

Лучший выход -- не читать блоками, а читать посимвольно.
Если там не мегабаты данных, то на производительности не скажется.
Ну и можно сочетать -- знаешь, что должен получить большой блок данных -- читай большой блок (я бы читал всё же read-ом),
не знаешь -- читай посимвольно, построчно.
...
Рейтинг: 0 / 0
26.10.2015, 12:43
| Ответить | Цитировать | Написать  
Сокеты в си
    #39086805
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Спасибо.
Попробую вот так:
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
if(read(sock, &ch, 1)<0) perror("read");
                                printf("Server-read() is OK\n");
                                while( ch != EOF) {
                                	buf_lin2[totalcnt]=ch;
                                	totalcnt++;
                                        if(read(sock, &ch, 1)<0) perror("read");
                                }
                                obrabwialonretr(buf_lin2, sock);
...
Рейтинг: 0 / 0
26.10.2015, 13:42
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087448
kolobok0
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
kolobok0
Участник
t111к,

Про потоковый подход - уже прозвучало. Обычно в обработчик TCP передают длину. И сам обработчик тупо читает необходимую длину.

Например передали заголовок фиксированной длины - в нём указана длина полезных данных следуемый за ним.

Либо читаете по символьно и как только пришла фраза "ЛЕНИН ЖИВ!!!" то понимаете что дальше у вас идут данные длиной в 1 мегабайт....

Ну и т.д..
(круглый)
...
Рейтинг: 0 / 0
26.10.2015, 23:17
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087537
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
t111кПопробую вот так:
...
Тут как минимум надо добавить проверки:
1. выхода за пределы buf_lin2
2. обрыва соединения
...
Рейтинг: 0 / 0
27.10.2015, 07:42
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087545
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Добрый день.
И как это всё учесть? Если можно на конкретном примере, который я привожу. Приведённое выше не подходит так как я получаю набор байтов среди которых может быть и 0. Потом во входящих данных передаются пакеты размер которых я знаю там в байтах их размер и обычно это 204 байта, но мне неизвестно сколько пакетов приходит по 204 байтов, проблема ещё в том, что не передаётся размер общих входящих данных или символы окончания приёма данных.
Пока остановился на таком, больше не знаю, что в данном случае можно ещё сделать. Да, тоже может попасть такой случай что будет кратно 204 и остаток от деления 0, но не всё передал.
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
 flagoshib=1;
                               	flagpervogchten=0;
                               	totalcnt=0;
                                while(totalcnt < BufferLength)
                                {
                                  rc =  recv(sock, &buf_lin2[totalcnt], (BufferLength - totalcnt),0);
                                                                          if(rc < 0)
                                                                           {
                                                                               perror("Server-read() error");
                                                                               if (flagpervogchten==0)
                                                                               flagoshib=2;
                                                                               break;
                                                                           }
                                                                           else if (rc == 0)
                                                                           {
                                                                       	   if (flagpervogchten==0)
                                                                       	   flagoshib=2;
                                                                           break;
                                                                           }
                                                                           else
                                                                           {
                                                                           totalcnt += rc;
                                                                           flagpervogchten=1;
                                                                            printf("Server-read() is OK\n");
                                                                            int v1;
                                                                            v1=totalcnt%204;
                                                                            if (v1==0)
                                                                            break;
                                                                           }
                                                                           }
                                                                          if (flagoshib==1)
                                                                           obrabwialonretr(buf_lin2, sock);
...
Рейтинг: 0 / 0
27.10.2015, 08:03
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087553
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
Может еще быть случай когда придет два сообщения вместе.
t111кво входящих данных передаются пакеты размер которых я знаю там в байтах их размер и обычно это 204 байта, но мне неизвестно сколько пакетов приходит по 204 байтов, проблема ещё в том, что не передаётся размер общих входящих данных или символы окончания приёма данных.
В такой постановке задача нерешаема.
Сформулируй и четко опиши формат передачи. Без слова "обычно", т.к. оно тут означает что иногда может прийти неожидаемый набор данных и все сглючит.

Если каждый пакет 204 байта, то читай в буфер размером 204 байта. Буфер наполнился - пакет получен, обрабатываем, ждем следующий.

PS Если есть возможность править код на второй стороне (которая отправляет), то меняй формат отправки. Например 4 байта размер данных, затем данные. Так будет намного проще.
...
Рейтинг: 0 / 0
27.10.2015, 08:41
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087618
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Будем ориентироваться, что всегда приходят 204. Только сколько таких пакетов по 204 байтов предаётся неизвестно. Я взял BufferLength=50000, с запасом, Менять передающую программу я не могу, не у нас она формируется это WialonRetranslator по этому протоколу к нам поступают данные. Часто приходят 1 пакет по 204 байт, бывает несколько пакетов по 204 байтов. Промежуток при пересылках данных большой, накапливать больше 50000 он может долго, лучше сразу бы обработать, как пришли данные.
А вот если так сделать. Будет ли этот кусочек программы правильно отрабатывать?
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
 char ch[1]="";
                                int prokon;
                                 totalcnt=0;
                                rc=read(sock, &ch, 1);
                                if (rc<=0)
                                	printf("Сервер не прочитал\n");
                                else
                                {
                                printf("Сервер прочитал\n");
                                prokon=ch[0];
                                while(prokon!= EOF)
                                {
                                       	buf_lin2[totalcnt]=ch[0];
                                	totalcnt++;
                                        rc=read(sock, &ch, 1);
                                	 prokon=ch[0];
                                	 if (rc<=0)
                                        break;
                                }
                                obrabwialonretr(buf_lin2, sock);
...
Рейтинг: 0 / 0
27.10.2015, 09:35
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087655
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
t111кБудем ориентироваться, что всегда приходят 204. Только сколько таких пакетов по 204 байтов предаётся неизвестно. Я взял BufferLength=50000, с запасом
Зачем этот запас? Что мешает сделать BufferLength=204 ? Получил сообщение - сразу обработал. Жди следующее. Если оно уже есть, то сразу обработаешь, если нет, то код будет стоять на recv() пока не придет очередное или соединение не порвется.

Если ждать не надо, то c помощью select() можно проверить есть что читать из сокета или нет.
...
Рейтинг: 0 / 0
27.10.2015, 10:06
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087676
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
Так попробуй
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
#define PACKET_SIZE 204

while(true) {
   int rc;
   char buf[PACKET_SIZE];
   int total = 0;
   while(total < PACKET_SIZE) {
       rc =  recv(sock, &buf[total], PACKET_SIZE - total,0);
       if(rc < 0) {
             perror("Server-read() error");
             break;
       }
   }
   if(rc < 0) break;
   printf("Server-read() is OK\n");
   obrabwialonretr(buf, sock);
}
...
Рейтинг: 0 / 0
27.10.2015, 10:19
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087685
Фотография Изопропил
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Изопропил
Участник
Dima T,

косяк - recv может вернуть 0 при закрытии сокета передающей стороной
...
Рейтинг: 0 / 0
27.10.2015, 10:25
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087700
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
Точно, не силен в TCP, списал у t111к
тогда заменить на
Код: plaintext
1.
if(rc <= 0) ...


Если не путаю, при открытом соединении recv() никогда 0 не вернет, т.е. будет висеть и ждать данные, если с настройками сокета не баловаться.
...
Рейтинг: 0 / 0
27.10.2015, 10:33
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087897
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
Dima TМожет еще быть случай когда придет два сообщения вместе.
t111кво входящих данных передаются пакеты размер которых я знаю там в байтах их размер и обычно это 204 байта, но мне неизвестно сколько пакетов приходит по 204 байтов, проблема ещё в том, что не передаётся размер общих входящих данных или символы окончания приёма данных.
В такой постановке задача нерешаема.
Сформулируй и четко опиши формат передачи. Без слова "обычно", т.к. оно тут означает что иногда может прийти неожидаемый набор данных и все сглючит.

Если каждый пакет 204 байта, то читай в буфер размером 204 байта. Буфер наполнился - пакет получен, обрабатываем, ждем следующий.

PS Если есть возможность править код на второй стороне (которая отправляет), то меняй формат отправки. Например 4 байта размер данных, затем данные. Так будет намного проще.

Я только ещё раз хочу напомнить, что никаких "сообщений" и "пакетов" в TCP нет. Приведённые тут эти слова -- это так, для обозначение посылок в общем смысле.
...
Рейтинг: 0 / 0
27.10.2015, 12:49
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087917
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111к,

Здесь ошибка:

Код: plaintext
1.
2.
3.
4.
5.
6.
char ch[1];
rc=read(sock, &ch, 1);
if (rc<=0)
  ; // ...
prokon=ch[0];
while(prokon!= EOF)



EOF - не уместится в char.
read никогда не формирует EOF. Это ты перепутал с getc
...
Рейтинг: 0 / 0
27.10.2015, 12:58
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087937
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Да нет я разместил EOF в int
int prokon;
...
prokon=ch[0];
while(prokon!= EOF)
...
Рейтинг: 0 / 0
27.10.2015, 13:06
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087944
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кДа нет я разместил EOF в int
int prokon;
...
prokon=ch[0];
while(prokon!= EOF)

Ну до этого-то он должен появитсья как-то в ch[0] ...

К тому же на кой тебе фиг массив из заведомо одного элемента, не подскажешь ?
(ну это так, просто чтобы поржать).
...
Рейтинг: 0 / 0
27.10.2015, 13:12
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087945
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Да спасибо. Да действительно, если я только знаю сколько байт приходит в одном пакете первые 4 байта пакета (204 байт), попробую только по одному пакету принимать и обрабатывать. Пробую сейчас так, надеюсь правильно будет работать.
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
 float d1;
                                    int chetbiet,nomerbite,nomzapbite, kolbite,r1blok1,i1,c,totalcnt ;
                                    char rasmbl1[4]="";
                                    while (1)
                                    {
                                    rc=recv(sock, &rasmbl1, 4,0);
                                    if (rc<=0)
                                    {
                                   printf("Сервер не прочитал\n");
                                    break;
                                    }
                                    kolbite=0;
                                    for (i1=0;i1<4;i1++ )
                                    {
                                    c=rasmbl1[i1];
                                    if (c<0)
                                    c=c+256;
                                    d1=Power(256,i1);
                                    kolbite=kolbite+c*d1;
                                    }
                                    memcpy(buf_lin2,rasmbl1,4);
                                    totalcnt=0;
                                    while(totalcnt < kolbite)
                                    {
                                    rc=recv(sock, &buf_lin2[4+totalcnt], kolbite - totalcnt,0);
                                    if (rc<=0)
                                    {
                                    printf("Сервер не прочитал\n");
                                    break;
                                    }
                                    totalcnt+=rc;
                                    }
                                    if (totalcnt== kolbite)
                                    obrabwialonretr(buf_lin2, sock);
...
Рейтинг: 0 / 0
27.10.2015, 13:12
| Ответить | Цитировать | Написать  
Сокеты в си
    #39087955
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Да если передающая сторона будет отсылать EOF можно было бы его ловить, но наверно передающая сторона и не посылает его
rc=read(sock, &ch, 1);
prokon=ch[0];
Да можно наверно char ch; и вот объявить одно символьную переменную и обращаться к ней
prokon=ch;
...
Рейтинг: 0 / 0
27.10.2015, 13:20
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088151
Фотография Anatoly Moskovsky
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Anatoly Moskovsky
Участник
t111кДа если передающая сторона будет отсылать EOF можно было бы его ловить, но наверно передающая сторона и не посылает его
rc=read(sock, &ch, 1);
Когда rc == 0 это и есть EOF.
Если rc < 0 это ошибки всякие.

Касательно чтения когда длина известна. Напишите функцию read_all() которая принимает те же параметры но читает ровно заданное кол-во байтов (в цикле).
Такой функцией намного удобнее и проще пользоваться чем вводить явные циклы в алгоритм, который по сути линейный.
...
Рейтинг: 0 / 0
27.10.2015, 15:38
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088278
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
t111кДа спасибо. Да действительно, если я только знаю сколько байт приходит в одном пакете первые 4 байта пакета (204 байт), попробую только по одному пакету принимать и обрабатывать.
Все таки размер приходит?

Если так, то ты слишком много написал лишнего. Не надо высшей математики, можно так
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
int chetbiet,nomerbite,nomzapbite, kolbite,r1blok1,i1,c,totalcnt ;
while (1) {
   rc=recv(sock, buf_lin2, 4,0);
   if (rc<=0) break;
   memcpy(&kolbite, buf_lin2, 4);
   if (kolbite > sizeof(buf_lin2) - 4) {
      printf("Недостаточный размер буфера\n");
      break;
   }
   totalcnt = 0;
   while(totalcnt < kolbite) {
       rc=recv(sock, &buf_lin2[4+totalcnt], kolbite - totalcnt, 0);
       if (rc<=0) break;
       totalcnt += rc;
   }
   if (rc<=0) break;
   obrabwialonretr(buf_lin2, sock);
}
if(rc<=0) printf("Сервер не прочитал\n");



PS В коде отступы не забывай делать. Читать невозможно.
...
Рейтинг: 0 / 0
27.10.2015, 17:00
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088320
Dima T
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dima T
Участник
Лучше все в одном цикле читать. Возможно что 4 байта размера не придут вместе, тогда твой и мой предыдущий вариант сглючат.
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
int chetbiet,nomerbite,nomzapbite, kolbite,r1blok1,i1,c,totalcnt ;
while (1) {
   totalcnt = 0;
   kolbite = 4; // сначала читаем размер
   while(totalcnt < kolbite) {
       rc=recv(sock, &buf_lin2[totalcnt], kolbite - totalcnt, 0);
       if (rc<=0) {
          printf("Сервер не прочитал\n");
          break;
       }
       totalcnt += rc;
       if (totalcnt == 4) { // прочитали размер
          memcpy(&kolbite, buf_lin2, 4); 
          kolbite += 4; // получаем размер всего блока данных
          if (kolbite > sizeof(buf_lin2)) {
             printf("Недостаточный размер буфера\n");
             break;
          }
       }
   }
   if (rc<=0 || kolbite > sizeof(buf_lin2) || kolbite <= 0) break;
   obrabwialonretr(buf_lin2, sock);
}


PS Код не запускал.
...
Рейтинг: 0 / 0
27.10.2015, 17:50
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088451
kolobok0
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
kolobok0
Участник
t111к...если я только знаю сколько байт приходит в одном пакете первые 4 байта пакета (204 байт), попробую только по одному пакету принимать и обрабатывать.....

Для тех кто на собаку говорит "корова" и ждёт молока под хвостом:

в TCP протоколе НЕТ пакетов.
Как только из своего лексикона уберёте эти термины - так сразу всё получится, гарантирую.
Вы мульён тысяча третий, кто наступает на грабельки открыто лежащие... и как мантру наступая на грабли повторяете - tcp+пакты :(
пока не обойдёте грабли - так и будут ошибки. можно ещё подпорочки лепить - тут уже ближе к людям в белых халатах тогда получается, чем программирование.

(круглый)
...
Рейтинг: 0 / 0
27.10.2015, 21:54
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088542
Фотография Изопропил
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Изопропил
Участник
kolobok0,

забей, горбатого могила исправит
...
Рейтинг: 0 / 0
28.10.2015, 01:29
| Ответить | Цитировать | Написать  
Сокеты в си
    #39088593
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Да спасибо. Вроде подходит. Только я добавил после obrabwialonretr - break, чтобы вышел из цикла, далее нужно закрыть сокет и заново его открыть в цикле, если не выходить из цикла и не закрывать сокет и далее открывать и ждать следующего приёма данных, то неправильно работает приёмная часть кода.
Код: plaintext
1.
2.
3.
4.
5.
6.
.......
obrabwialonretr(buf_lin2, sock);
break;
 }
close(sock);
 }
...
Рейтинг: 0 / 0
28.10.2015, 07:48
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089445
чччД
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
чччД
Участник
t111к,

если сервер тоже ты пишешь - используй протокол, ориентированный на сообщения, не на байты. Например, ZeroMQ

 
Пример сервера
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
//  Hello World server

#include <zmq.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>

int main (void)
{
    //  Socket to talk to clients
    void *context = zmq_ctx_new ();
    void *responder = zmq_socket (context, ZMQ_REP);
    int rc = zmq_bind (responder, "tcp://*:5555");
    assert (rc == 0);

    while (1) {
        char buffer [10];
        zmq_recv (responder, buffer, 10, 0);
        printf ("Received Hello\n");
        sleep (1);          //  Do some 'work'
        zmq_send (responder, "World", 5, 0);
    }
    return 0;
}





 
Пример клиента
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
//  Hello World client
#include <zmq.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>

int main (void)
{
    printf ("Connecting to hello world server…\n");
    void *context = zmq_ctx_new ();
    void *requester = zmq_socket (context, ZMQ_REQ);
    zmq_connect (requester, "tcp://localhost:5555");

    int request_nbr;
    for (request_nbr = 0; request_nbr != 10; request_nbr++) {
        char buffer [10];
        printf ("Sending Hello %d…\n", request_nbr);
        zmq_send (requester, "Hello", 5, 0);
        zmq_recv (requester, buffer, 10, 0);
        printf ("Received World %d\n", request_nbr);
    }
    zmq_close (requester);
    zmq_ctx_destroy (context);
    return 0;
}



Библиотека ZeroMQ - понятная, надежная и быстрая. Кроме того, что она ориентирована на сообщения, в ней масса вкусностей (типа встроенной очереди сообщений и автоматического реконнекта при обрыве соединения).
И, хотя написана на С и для С, я, дельфятник использую её с удовольствием.
...
Рейтинг: 0 / 0
29.10.2015, 01:23
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089449
ДохтаР
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ДохтаР
Участник
Когда то пользовался но быстро не на гуглил
в функции getsocopt ( в Linux & SCO , про винду не скажу, не знаю)
есть параметр , который возвращает
количество байт находящихся
находящиеся в SO_RCVBUF
буфере, готовые для чтения приложением на момент вызова.
...
Рейтинг: 0 / 0
29.10.2015, 01:52
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089490
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Спасибо. Да пока стандартного сокетного приёма хватит, пока без дополнительных библиотек (ZeroMQ) обойдусь, но буду иметь ввиду , к тому же я пишу только серверную часть, данные передаются по формату протокола WialonRetranslator.
...
Рейтинг: 0 / 0
29.10.2015, 08:26
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089638
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кДа если передающая сторона будет отсылать EOF можно было бы его ловить, но наверно передающая сторона и не посылает его


Нет, конечно же не посылает.
Ты вообще в курсе, что такое EOF ?
Он тут вообще ни при чём.
...
Рейтинг: 0 / 0
29.10.2015, 10:30
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089643
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
kolobok0t111к...если я только знаю сколько байт приходит в одном пакете первые 4 байта пакета (204 байт), попробую только по одному пакету принимать и обрабатывать.....

Для тех кто на собаку говорит "корова" и ждёт молока под хвостом:

в TCP протоколе НЕТ пакетов.
Как только из своего лексикона уберёте эти термины - так сразу всё получится, гарантирую.
Вы мульён тысяча третий, кто наступает на грабельки открыто лежащие... и как мантру наступая на грабли повторяете - tcp+пакты :(
пока не обойдёте грабли - так и будут ошибки. можно ещё подпорочки лепить - тут уже ближе к людям в белых халатах тогда получается, чем программирование.

(круглый)


kolobok0, ты всё очень правильно написал, но только грабелек-то вообще-то и нет никаких.
Я имею в виду, что это не недостаток спецификации протокола TCP, там как раз всё чётко обозначено.
Это виртуальные грабли, которые себе придумывают программисты, не умеющие читать документацию,
но по лбу их бьют они реально.
...
Рейтинг: 0 / 0
29.10.2015, 10:33
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089652
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
ДохтаРКогда то пользовался но быстро не на гуглил
в функции getsocopt ( в Linux & SCO , про винду не скажу, не знаю)
есть параметр , который возвращает
количество байт находящихся
находящиеся в SO_RCVBUF
буфере, готовые для чтения приложением на момент вызова.

И как это относится к предмету разговора ?
((подсказка -- никак))
...
Рейтинг: 0 / 0
29.10.2015, 10:35
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089660
Фотография MasterZiv
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
MasterZiv
Участник
t111кСпасибо. Да пока стандартного сокетного приёма хватит, пока без дополнительных библиотек (ZeroMQ) обойдусь, но буду иметь ввиду , к тому же я пишу только серверную часть, данные передаются по формату протокола WialonRetranslator.

Тогда вообще не понятно, в чём там у тебя проблемы.

WialonRetranslatorОписание протокола WialonRetranslator 1.0
Входящие данные
.
Все данные приходят в бинарном формате по TCP протоколу и представляют собой пакет следующего формата:
Размер(байт) Тип поля Описание поля
4 Целое число Размер пакета
-
...
Рейтинг: 0 / 0
29.10.2015, 10:39
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089731
t111к
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
t111к
Гость
Да начал выдумывать, что может несколько пакетов данных WialonRetranslator нужно сразу принять за раз, а нужно было сделать приём одного пакета данных WialonRetranslator так как размер только одного пакета данных его нам и известен. Ну вроде сделал этот вариант, он приведён выше с моими небольшими изменениями о которых я написал.
...
Рейтинг: 0 / 0
29.10.2015, 11:10
| Ответить | Цитировать | Написать  
Сокеты в си
    #39089817
ДохтаР
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ДохтаР
Участник
t111кДа начал выдумывать, что может несколько пакетов данных WialonRetranslator нужно сразу принять за раз, а нужно было сделать приём одного пакета данных WialonRetranslator так как размер только одного пакета данных его нам и известен. Ну вроде сделал этот вариант, он приведён выше с моими небольшими изменениями о которых я написал.


Это решается буфером размером около N средних пакетов.
и массив описатель структур содержащих
смещение в буфере и размер прочитанного из сокета.

функция которая читает буфер берет все подряд, не глядя на границы
блоков полученных по сети, удаляя уже обработанные
блоки из массива описателя,
когда буфер заканчивается , не обработанный блок переносится
в начало буфера функцией memcpy и редактируется массив описатель.

приблизительно так....
...
Рейтинг: 0 / 0
29.10.2015, 11:51
| Ответить | Цитировать | Написать  
Сокеты в си
    #39090144
Фотография Изопропил
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Изопропил
Участник
ДохтаР,

зачем так сложно?
...
Рейтинг: 0 / 0
29.10.2015, 14:58
| Ответить | Цитировать | Написать  
Сокеты в си
    #39091054
ДохтаР
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ДохтаР
Участник
ИзопропилДохтаР,

зачем так сложно?

Предложите проще.

Я предложил такой вариант потому что это универсально и масштабируемо
позволяет вынести работу с сокетами в отдельный с и h
файлы и тягать между проектами, избавить от переключения
контекста в голове программиста межу прикладной и сестемной
логикой и (или) посадить еще одного програмиста на проект , так что бы
они не толкались попами внутри одного кода.
...
Рейтинг: 0 / 0
30.10.2015, 13:20
| Ответить | Цитировать | Написать  
Сокеты в си
    #39091944
kolobok0
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
kolobok0
Участник
ДохтаР,

Если учесть, что под некоторыми осями и(или) библиотеками прикрывающих сокеты именно так и делается (кванты приходящей информации от аппаратуры держаться в кольцевом буфере) - то выглядит Ваше предложение как минимум странно.

Может быть стоит использовать опыт ранее накопленный? У юниксистов например - стандартная механизация: функция вычитывания из сокета известной длины данных, с формированием входного пользовательского буфера. (подсказка: вам никто не мешает гнать перед данными их длину, тогда тип длины данных - даёт величину вычитывания кол-ва байт на длину. например 4 байта)

(круглый)
...
Рейтинг: 0 / 0
01.11.2015, 00:21
| Ответить | Цитировать | Написать  
43 сообщений из 43, показаны все 2 страниц
  все  
Форумы / C++ [игнор отключен] [закрыт для гостей] / Сокеты в си
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]