Необходима помощь в понимании сокетов

[Antony41]

Ребят помогите разобраться! что то я совсем не пойму...
Вот Вы мне объясните. Мне необходимо принимать поток байт преобразовывать их в определенном порядке и писать эти данные в базу данных.

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

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

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

[Stilet]

Правильно ли я думаю

Неа. Хочешь добрый совет? - Используй INDY.

[Antony41]

Не знаю, но чем то меня Indy пугают, вобще я как то писал приложение на чистом winsock с поддержкой асинхронного расширения, но я делал, как то не совсем я считаю правильно. Хотелось бы понять именно глубину сути на чистом winsocket API.

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

While not Terminated Do Begin
        res := Integer( GetMessage(Msg, 0, 0, 0 ));
        If (res = -1 )or (res = 0) then
          exit  //
        else begin
          TranslateMessage( Msg );
          DispatchMessage( Msg );
        end;

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

[Stilet]

Я понимаю так для того чтобы не блокировался интерфейс главного потока, необходимо выполнять операцию приема данных в отдельном потоке

Блокирование потока производится при ожидании при чтении функцией recv() и прослушке функцией accept(), если мне память не изменяет. Компенсировать это можно доппотоком. Так же можно использовать примерно такую схему:

while true do begin
 if select(Тут устновка таймаута прослушки) then 
   accept(...);
 Application.ProcessMessages();
end;

А при использовании recv() цикл примерно такого содержания:

var buf:array[1..FPBufferSize] of byte; ReadedSize,BytesInSocket:Cardinal;
begin
 Result:=0; Data.Clear; Data.Position:=0;
 repeat
    if ioctlsocket(AcceptedSocket,FIONREAD,BytesInSocket)<>SOCKET_ERROR then begin
     if BytesInSocket>0 then begin
      FillChar(buf,Sizeof(buf),0);
      ReadedSize:=fprecv(AcceptedSocket,@buf,sizeof(buf),0);
      Result:=Result+ReadedSize;
      Data.Write(buf,ReadedSize);
     end;
    end;
 until (BytesInSocket=0);
end;

Где Data - TStream какой-то.

Эти два механизма позволят соблюдать неблокирующий режим в любом потоке.

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

Никакой связи никакие окна к потокам и тем более сокетам не имеют.
Я к примеру предпочитаю описать TThread, в которых и запускаю циклы, подобные описанным выше.

Короче хрень какая то, я просто запутался

Вот потому и возьми Индейку, там все это уже реализовано - тамошние события ничего не блокируют (а если блокируют, всегда можно кинуть компонент idAntifreeze).

[Antony41]

такая как я считал простая задача так тяжело дается. Я уж подумываю на C# и .NET перейти, хотя api он есть апи... Stilet на счет INDY все равно какие то сомнения в сторону их косяков, боюсь столкнусь с какой то ошибкой, и кирдык грабли, где то я на это уже натыкался, вот ты сам что бы выбрал? я все таки хочу понять как использовать асинхронный сокет в потоках, или запись в базу нужно в потоках использовать, чтоб одновременно можно было принимать разные потоки байт по разным протоколам (не путать с TCP UDP), расшифровать и записать в БД

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

[Stilet]

Я уж подумываю на C# и .NET перейти

Ну вполне хороший выбор.

боюсь столкнусь с какой то ошибкой, и кирдык грабли

Ты уже кирдык-грабли столкнулся )))
Какая разница, во что упереться? Все равно придется какие-то проблемы решать чем бы не пользовался.

вот ты сам что бы выбрал?

Я и инди и сокеты использую. Они у меня так вот удобно сочетаются в проектах.

вышеприведенный пример как я понимаю это блокирующий сокет

Почему блокирующий? Там же проверка на доступность данных в сокете есть. Он ниче не блокирует.

На сколько я читал такой метод не очень хорошо распоряжается ресурсами компа, тоесть заряжает проц даже когда ни каких данных не поступает

Бред какой-то... Ты где сие крамольство читал?

[Antony41]

хорошо спасибо Stilet попробую на инди набросать, пошел изучать

[Antony41]

Не хотелось бы создавать новую тему...
В общем прочитал я про инди, и накидал сервак.
Есть сервер который постоянно транслирует данные по собственному протоколу, порядок примерно такой:
подключение...
непрерывный поток данных начат
кол-во пакетов (Int)(4 байта)
пакет№1
длина серийного номера(Byte)(1 байт)
серийный номер (string)(N байт)
и тд.
пакет№2
длина серийного номера(Int)
серийный номер (string)(N байт)
и тд.
пакет№3
длина серийного номера(Int)
серийный номер (string)(N байт)
и тд.
и тд.
Снова кол-во пакетов
пакет№1
длина серийного номера(Byte)(1 байт)
серийный номер (string)(N байт)
и тд.
пакет№2
длина серийного номера(Int)
серийный номер (string)(N байт)
и тд.
пакет№3
длина серийного номера(Int)
серийный номер (string)(N байт)
и тд.
и тд.

Далее идет ответ от сервера приема данных Hex $55 (тот который я пишу), если подтверждения нет, то сервер трансляции разрывает соединение и поторяет попытку отправки данных.

В общем мне нужно чтоб сервак приема данных был устойчив к сбоям и можно было примать одновременно несколько ретрансляций.

Понимаю, что работа идет в потоках, но ни как не могу понять что я сделал не так. Вываливается страшнейший AV.

Призываю к помощи и просьба ткнуть носом в свой косяк.
Привожу весь код так как ограничения форума не позволяют вставить более 5000 символов.
[/CODE]

[Antony41]

в момент приема данных всё ок, но когда я принудительно останавливаю передачу потока данных на сервере ретрансляции, то на сервере приема вываливается Connection Closed Gracefully и затем AV

[come-on]

Используйте try блоки