Отправлять и получать одновременно с TIdTCPServer - PullRequest
Новая
       55

Отправлять и получать одновременно с TIdTCPServer

1 голос
/ 12 апреля 2019

Всегда рекомендуется выполнять все задачи отправки / получения в OnExecute обработчике событий TIdTCPServer, но я не понимаю следующее:

Как дождаться определенной последовательности на входе и одновременно отправить некоторые данные одному клиенту? Мне не нужна последовательность команд-ответов, но мне нужно:

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

Например, если мы ждем CR-LF: 

procedure TSocketServer._serverExecute(AContext: TIdContext);
var
  msg: string;
begin
  msg := AContext.Connection.IOHandler.ReadLn();
  //Here we are only if CRLF was detected.
  //How to send while we are waiting?
  _log(msg);
end;

1 Ответ

5 голосов
/ 12 апреля 2019

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

Существует несколько различных способов обработки отправки:

  • использовать отдельные темы для чтения и отправки. Например, поток OnExecute обрабатывает все чтение и использует другой рабочий поток для обработки всей отправки. Если OnExecute получает входящую команду, которая должна отправить ответ, передайте данные ответа в поток отправки (потокобезопасным способом), чтобы он мог отправлять ответ, когда это безопасно, между нежелательными сообщениями.

  • имеет поток обработки потока OnExecute для чтения и отправки. При необходимости непрерывно отправляйте исходящие незапрошенные данные и периодически проверяйте входящие данные, используя методы IOHandler.InputBufferIsEmpty() и IOHandler.CheckForSourceOnData(), чтобы определить, когда необходимо прочитать входящее сообщение.

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

...