delphi使用IdTCPServer、TIdTCPClient收发消息

<think>我们正在处理一个关于在Delphi中使用IdTCPServer和TIdTCPClient进行消息收发的请求。用户需要示例代码。根据提供的引用，我们有两个示例片段：引用[1]展示了一个TIdTCPClient的基本用法：创建客户端，设置主机和端口，连接，然后可以发送请求或接收数据，最后断开连接。引用[2]展示了另一个TIdTCPClient的连接示例，设置主机和端口并连接。但是用户需要的是同时使用IdTCPServer和TIdTCPClient进行消息收发的示例。因此，我们需要提供两部分的代码：服务器端和客户端。服务器端使用IdTCPServer组件，客户端使用TIdTCPClient组件。我们将分别展示：1.服务器端设置：-放置一个TIdTCPServer组件到窗体上。-设置端口（默认为0，需要设置一个端口号，比如1234）。-激活服务器（设置Active为True，或在代码中调用Active:=True或DefaultPort设置后调用Bindings等）。2.服务器端需要处理的事件：-OnConnect：当客户端连接时触发。-OnDisconnect：当客户端断开时触发。-OnExecute：当客户端发送数据过来时，在这个事件中读取数据并处理，也可以发送回复。3.客户端设置：-放置一个TIdTCPClient组件到窗体上（或者动态创建）。-设置Host和Port（与服务器端口一致）。-调用Connect方法连接。4.客户端发送和接收：-使用WriteLn发送一行文本（如果发送的是字符串，且希望按行读取）。-使用ReadLn读取一行文本。注意：Indy组件默认使用TIdIOHandlerSocket作为IO处理程序，可以使用ReadLn和WriteLn进行基于行的通信，也可以使用ReadStream和WriteStream进行流式通信。我们将分别提供服务器端和客户端的简单示例代码。由于用户要求示例代码，我们将提供一个简单的消息收发示例：客户端发送一个字符串到服务器，服务器将收到的字符串反转然后发回给客户端。注意：实际开发中需要考虑编码、超时、异常处理等问题，这里为了简洁，只展示基本流程。服务器端代码（使用TIdTCPServer）：```unitServerForm;interfaceusesWindows,Messages,SysUtils,Variants,Classes,Graphics,Controls,Forms,Dialogs,IdContext,IdBaseComponent,IdComponent,IdTCPServer;typeTFormServer=class(TForm)IdTCPServer1:TIdTCPServer;procedureFormCreate(Sender:TObject);procedureIdTCPServer1Execute(AContext:TIdContext);private{Privatedeclarations}public{Publicdeclarations}end;varFormServer:TFormServer;implementation{$R*.dfm}procedureTFormServer.FormCreate(Sender:TObject);beginIdTCPServer1.DefaultPort:=1234;//设置端口IdTCPServer1.Active:=True;//激活服务器end;procedureTFormServer.IdTCPServer1Execute(AContext:TIdContext);vars:string;begin//从客户端读取一行s:=AContext.Connection.IOHandler.ReadLn;//反转字符串（简单示例）s:=ReverseString(s);//需要SysUtils中usesStrUtils，或者自己实现反转//将反转后的字符串发回AContext.Connection.IOHandler.WriteLn(s);end;end.```注意：ReverseString函数在StrUtils单元中，所以需要在uses中添加StrUtils。如果不想使用StrUtils，可以自己写一个反转函数。客户端代码（使用TIdTCPClient）：```unitClientForm;interfaceusesWindows,Messages,SysUtils,Variants,Classes,Graphics,Controls,Forms,Dialogs,IdBaseComponent,IdComponent,IdTCPConnection,IdTCPClient,StdCtrls;typeTFormClient=class(TForm)IdTCPClient1:TIdTCPClient;Button1:TButton;EditSend:TEdit;EditRecv:TEdit;procedureButton1Click(Sender:TObject);private{Privatedeclarations}public{Publicdeclarations}end;varFormClient:TFormClient;implementation{$R*.dfm}procedureTFormClient.Button1Click(Sender:TObject);vars:string;beginIdTCPClient1.Host:='127.0.0.1';//服务器地址IdTCPClient1.Port:=1234;//服务器端口tryIdTCPClient1.Connect;try//发送一行文本IdTCPClient1.IOHandler.WriteLn(EditSend.Text);//接收一行文本（服务器返回的反转字符串）s:=IdTCPClient1.IOHandler.ReadLn;EditRecv.Text:=s;finallyIdTCPClient1.Disconnect;end;exceptonE:ExceptiondoShowMessage('Error:'+E.Message);end;end;end.```以上代码中，服务器在创建窗体时激活，并监听1234端口。当有客户端连接并发送一行字符串时，服务器会反转该字符串并返回。客户端在点击按钮时，连接到服务器（假设服务器在本地），将EditSend中的文本发送，然后等待接收一行文本并显示在EditRecv中。注意：在实际应用中，服务器端的OnExecute事件处理函数应该在一个循环中读取，直到连接断开。但这里我们的示例只读取一行并回复一行，然后事件处理结束。实际上，OnExecute事件会不断被调用直到连接断开。所以如果客户端发送多条消息，服务器会处理多次。另外，如果客户端一次发送多行，服务器每次执行OnExecute会处理一行（因为ReadLn每次读取一行）。所以这个示例是行对行的通信。如果需要处理更复杂的情况，比如未知长度的数据，或者二进制数据，则需要使用其他方法。生成相关问题：根据这个主题，我们可以生成以下相关问题：1.如何处理多个客户端同时连接服务器？2.如何发送和接收二进制数据？3.如何实现心跳机制以保持连接？4.如何处理网络异常和超时？5.如何提高服务器性能（如使用线程池）？注意：在Delphi中，IdTCPServer默认是多线程的，每个客户端连接都会在一个单独的线程中处理（OnExecute事件在独立线程中运行），所以上述示例已经支持多客户端。但需要注意线程安全，比如访问VCL控件时需要同步。我们将按照要求生成相关问题。</think>以下是关于在Delphi中使用`IdTCPServer`和`TIdTCPClient`进行消息收发的完整示例代码及说明： ### 服务端代码 (IdTCPServer) ```delphi // 引用[2] unit ServerForm; interface uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, IdContext, IdBaseComponent, IdComponent, IdTCPServer, IdSync; type TFormServer = class(TForm) IdTCPServer1: TIdTCPServer; procedure IdTCPServer1Execute(AContext: TIdContext); procedure IdTCPServer1Connect(AContext: TIdContext); procedure IdTCPServer1Disconnect(AContext: TIdContext); procedure FormCreate(Sender: TObject); private procedure LogMessage(const Msg: string); public { Public declarations } end; var FormServer: TFormServer; implementation {$R *.dfm} procedure TFormServer.FormCreate(Sender: TObject); begin IdTCPServer1.DefaultPort := 1234; // 设置监听端口 IdTCPServer1.Active := True; // 启动服务器 LogMessage('服务器已启动，监听端口: ' + IntToStr(IdTCPServer1.DefaultPort)); end; procedure TFormServer.IdTCPServer1Connect(AContext: TIdContext); begin LogMessage('客户端连接: ' + AContext.Binding.PeerIP); end; procedure TFormServer.IdTCPServer1Disconnect(AContext: TIdContext); begin LogMessage('客户端断开: ' + AContext.Binding.PeerIP); end; procedure TFormServer.IdTCPServer1Execute(AContext: TIdContext); var ReceivedData: string; begin // 接收客户端消息（UTF-8编码） ReceivedData := AContext.Connection.IOHandler.ReadLn(IndyTextEncoding_UTF8); // 处理消息（示例：原样返回） LogMessage('收到消息: ' + ReceivedData); // 回复客户端 AContext.Connection.IOHandler.WriteLn('ECHO: ' + ReceivedData, IndyTextEncoding_UTF8); end; // 线程安全的日志记录 procedure TFormServer.LogMessage(const Msg: string); begin TIdSync.SynchronizeMethod(procedure begin Memo1.Lines.Add(FormatDateTime('hh:nn:ss', Now) + ' - ' + Msg); end); end; end; ``` ### 客户端代码 (TIdTCPClient) ```delphi // 引用[1][2] unit ClientForm; interface uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, IdBaseComponent, IdComponent, IdTCPConnection, IdTCPClient, StdCtrls; type TFormClient = class(TForm) IdTCPClient1: TIdTCPClient; ButtonSend: TButton; ButtonConnect: TButton; MemoLog: TMemo; EditMessage: TEdit; procedure ButtonConnectClick(Sender: TObject); procedure ButtonSendClick(Sender: TObject); private procedure LogMessage(const Msg: string); public { Public declarations } end; var FormClient: TFormClient; implementation {$R *.dfm} procedure TFormClient.ButtonConnectClick(Sender: TObject); begin IdTCPClient1.Host := '127.0.0.1'; // 服务器IP IdTCPClient1.Port := 1234; // 服务器端口 try IdTCPClient1.Connect; LogMessage('已连接到服务器'); except on E: Exception do LogMessage('连接失败: ' + E.Message); end; end; procedure TFormClient.ButtonSendClick(Sender: TObject); var Response: string; begin if not IdTCPClient1.Connected then begin LogMessage('请先连接服务器'); Exit; end; try // 发送消息（UTF-8编码） IdTCPClient1.IOHandler.WriteLn(EditMessage.Text, IndyTextEncoding_UTF8); // 接收响应 Response := IdTCPClient1.IOHandler.ReadLn(IndyTextEncoding_UTF8); LogMessage('服务器响应: ' + Response); except on E: Exception do LogMessage('通信错误: ' + E.Message); end; end; procedure TFormClient.LogMessage(const Msg: string); begin MemoLog.Lines.Add(FormatDateTime('hh:nn:ss', Now) + ' - ' + Msg); end; end; ``` ### 关键说明 1. **通信流程** - 客户端使用`WriteLn`发送文本消息 - 服务端通过`OnExecute`事件用`ReadLn`接收 - 服务端用`WriteLn`返回响应 - 客户端用`ReadLn`接收响应 2. **编码处理** 使用`IndyTextEncoding_UTF8`确保中文兼容性： ```delphi // 发送 IOHandler.WriteLn(Text, IndyTextEncoding_UTF8); // 接收 str := IOHandler.ReadLn(IndyTextEncoding_UTF8); ``` 3. **线程安全** 服务端日志通过`TIdSync.SynchronizeMethod`同步到主线程，避免多线程冲突[^1]。 4. **异常处理** 所有网络操作包含在`try..except`中，防止程序崩溃。 5. **连接管理** - `OnConnect/OnDisconnect`事件监控连接状态 - 端口可自定义（示例使用1234） ### 使用建议 1. 服务端需设置`IdTCPServer.Active := True`启动监听 2. 客户端先设置`Host`和`Port`再调用`Connect` 3. 实际部署时修改服务端IP为公网地址 4. 大数据传输建议使用`ReadStream/WriteStream`