使用 TIdTCPServer 同时发送和接收

Send and receive simultaneously with TIdTCPServer

始终建议在 TIdTCPServerOnExecute 事件处理程序中执行所有发送/接收任务,但我不明白以下内容:

如何等待输入的特定序列,同时将一些数据发送到同一个客户端?我不需要命令-响应序列,但我需要:

例如,如果我们正在等待 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;

重要的是,当使用同一连接发送未经请求的数据和响应数据时,不要重叠传出消息,否则您会破坏协议。最好只有一个线程来完成所有发送,以便在发送另一条消息之前完整发送一条消息。只要确保您设计的协议允许在客户端发送命令之后和收到响应之前发送未经请求的数据。每条消息都应描述它是什么类型的消息,以便客户端可以检测到响应并将其与较早的命令匹配,同时按原样处理未经请求的数据。

您可以通过几种不同的方式处理发送:

  • 使用单独的线程进行读取和发送。例如,让 OnExecute 线程处理所有读取,并使用另一个工作线程处理所有发送。如果 OnExecute 收到需要发送响应的入站命令,将响应数据传递给发送线程(以线程安全的方式),以便它可以在安全的情况下在未经请求的消息之间发送响应。

  • OnExecute 线程处理读取和发送。根据需要持续发送未经请求的传出数据,并使用 IOHandler.InputBufferIsEmpty()IOHandler.CheckForSourceOnData() 方法定期检查入站数据以检测何时需要读取入站消息。

  • 否则,就像 Jerry Dodge 在评论中建议的那样,只需使用单独的连接,一个用于命令响应数据,一个用于未经请求的数据。