Гость
Войти | Профиль | Очистить
Целевая тема:
Создать новую тему:
Автор:
Действия ...
Форумы / Delphi [игнор отключен] [закрыт для гостей] / Передача разных файлов через Socket в неблокирующем режиме / 5 сообщений из 5, страница 1 из 1
04.04.2019, 00:01
    #39796044
OxY63rus
OxY63rus
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Передача разных файлов через Socket в неблокирующем режиме
Здравствуйте! Знаю, вопрос избит, но всё же прошу помощи.

Компонент TServerSocket/TClientSocket
Сокеты в неблокирующем режиме

Клиент отправляет:
Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
    Buffer: array [0 .. 4095] of byte;
    LenBuf: int64;

      FileStream:=TFileStream.Create(OriginalName, fmOpenRead);
      FileStream.Position:=0;
      while FileStream.Position< FileStream.Size do
      begin
        LenBuf:=FileStream.Read(Buffer,SizeOf(Buffer));
        Client.Socket.SendBuf(Buffer,LenBuf);
        Application.ProcessMessages;
      end;
      FileStream.Free;



Сервер принимает:
Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
      Buffer: Pointer;

      len:= Socket.ReceiveLength;
      GetMem(Buffer, len);
      datalen:=Socket.ReceiveBuf(Buffer^,len);          //datalen- сколько локально пришло
      FileStream.Write(Buffer^,datalen);
      DataSize:=DataSize+datalen;                           //DataSize - сколько уже записано глобально
      FreeMem(Buffer);
      if DataSize=Size then                                       // Size - заранее известное глобальное "сколько всего надо"
      begin
        FileStream.Free;
        Socket.Close;
      end;



В итоге небольшие (~до 3 Мб) файлы принимаются нормально, далее начинаются проблемы.

Я пробовал даже просто прочитать пришедшую длину ReceiveLength и считать буфер в никуда. Это для того чтобы просто просуммировать все ReceiveLength при срабатывании события прихода данных. В итоге сумма всех ReceiveLength меньше чем длина ожидаемого файла.

В какую сторону подумать?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.04.2019, 00:20
    #39796050
Foxpc
Foxpc
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Передача разных файлов через Socket в неблокирующем режиме
юзай SendStream передавая в него TFileStream а принимаешь через ReceiveBuf. Логично же
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.04.2019, 00:24
    #39796052
Foxpc
Foxpc
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Передача разных файлов через Socket в неблокирующем режиме
г.ы
http://www.delphisources.ru/pages/faq/base/file_tserversocket_to_tclientsocket.html
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.04.2019, 01:00
    #39796056
X-Cite
X-Cite
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Передача разных файлов через Socket в неблокирующем режиме
Ну вот в лоб.. 200 Мб передает без проблем...

Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
procedure TForm3.Button1Click(Sender: TObject);
begin
  ClientSocket1.Socket.SendStream(TFileStream.Create('e:\200mb.zip', fmOpenRead));
end;

procedure TForm3.FormCreate(Sender: TObject);
begin           ReportMemoryLeaksOnShutdown := True;
  ServerSocket1.Open;
  ClientSocket1.Open;
end;

procedure TForm3.ServerSocket1ClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
begin
  var fs := TFile.Open('e:\200mb_NEW.zip', TFileMode.fmOpenOrCreate);
  fs.Seek(0, TSeekOrigin.soEnd);
  var sz := Socket.ReceiveLength;
  var Buf: TBytes;
  SetLength(Buf, sz);
  sz := Socket.ReceiveBuf(Buf[0], sz);
  fs.WriteData(Buf, sz);
  fs.Free;
end;
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.04.2019, 10:33
    #39796226
OxY63rus
OxY63rus
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Передача разных файлов через Socket в неблокирующем режиме
Спасибо большое всем откликнувшимся.
Приём файла, как оказалось, шёл нормально. Намудрил с буферной передачей. С помощью SendStream всё заработало. Но всё-таки хочу запилить прогрессбар, поэтому буду разбираться.

А пока факультативный вопрос на соображение, кому интересно:
у меня есть свой TObject, содержащий все необходимые для передачи файла проперти. Также в нём же содержится TClientSocket и TFileStream. В конструкторе моего объекта это всё создаётся динамически. Механизм такой. Вызываем
MyObject.OriginalName:='testfile.tmp';
MyObject.Send

По этой команде ClientSocket цепляется к заранее известному хосту и в событии OnConnect отправляет всю необходимую инфу приёмнику. Приёмник отвечает одобрением текстовой строкой. В событии OnRead я ловлю эту строку, перевожу флаг моего объекта в режим Receiving:=True и начинаю отправлять файл. Когда приёмник принял весь файл он закрывает соединение. В событии OnDisconnect я хочу дестроить свой объект, но не получается. По отладчику вижу, что всё содержимое освобождается нормально, но потом управление возвращается в OnDisconnect, а собственно сокет я уже убил и лювлю исключение. Что посоветуете?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / Delphi [игнор отключен] [закрыт для гостей] / Передача разных файлов через Socket в неблокирующем режиме / 5 сообщений из 5, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение  
Полит. конфиден.  
созд. / загр.: 486ms
Закрыть
start [/forum/topic.php?fid=58&mobile=1&tid=2039621]:
 0ms
get settings:
 8ms
get forum list:
 19ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 173ms
get topic data:
 11ms
get forum data:
 3ms
get page messages:
 52ms
get tp. blocked users:
 1ms
others: 213ms
total:  486ms
x
x
Закрыть


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