分享
 
 
 

用Indy组件开发Socket应用程序

王朝other·作者佚名  2008-06-01
窄屏简体版  字體: |||超大  

笔者在前一段的工作中,需要开发一套简单的网络数据传输程序。由于平时常用Delphi做点开发,故此次也不例外。Delphi 7中带有两套TCP Socket组件:Indy Socket组件(IdTCPClient和IdTCPServer)和Delphi原生的TCP Socket组件(ClientSocket和ServerSocket)。

但是,Borland已宣称ClientSocket和ServerSocket组件即将被废弃,建议用相应的Indy组件来代替。因此,笔者使用了Indy。本文在对Indy进行简要介绍的基础上,创建了一组简单的TCP Socket数据传输应用来演示了Indy的使用方法。

开放源代码的Internet组件集——Internet Direct(Indy)Internet Direct(Indy)是一组开放源代码的Internet组件,涵盖了几乎所有流行的Internet协议。Indy用Delphi编写,被包含在Delphi 6,Kylix 1和C++ Builder 6及以上各个版本的Borland开发环境中。Indy曾经叫做WinShoes(双关于WinSock——Windows的Socket库),是由Chad Z. Hower领导的一群开发者构建的,可以从Indy的站点www.nevrona.com/indy上找到更多的信息并下载其新版本。到笔者撰写本文时为止,Indy的最新稳定版是9.0.14,Indy 10也进入了Beta测试阶段。

Delphi 7中所带的是Indy 9。在其的组件面板上,一共安装有100多个Indy组件。使用这些组件你可以开发基于各种协议的TCP客户和服务器应用程序,并处理相关的编码和安全问题。你可以通过前缀Id来识别Indy组件。

Indy是阻塞式(Blocking)的

当你使用Winsock开发网络应用程序时,从Socket中读取数据或者向Socket写入数据都是异步发生的,这样就不会阻断程序中其它代码的执行。在收到数据时,Winsock会向应用程序发送相应的消息。这种访问方式被称作非阻塞式连接,它要求你对事件作出响应,设置状态机,并通常还需要一个等待循环。

与通常的Winsock编程方法不同的是,Indy使用了阻塞式Socket调用方式。阻塞式访问更像是文件存取。当你读取数据,或是写入数据时,读取和写入函数将一直等到相应的操作完成后才返回。比如说,发起网络连接只需调用Connect方法并等待它返回,假如该方法执行成功,在结束时就直接返回,假如未能成功执行,则会抛出相应的异常。同文件访问不同的是,Socket调用可能会需要更长的时间,因为要读写的数据可能不会立即就能预备好(在很大程度上依靠于网络带宽)。

阻塞式Socket并非恶魔(Evil)

长期以来,阻塞式Socket都遭到了毫无理由的攻击。其实阻塞式Socket并非如通常所说的那样可怕。这还要从Winsock的发展说起。

当Socket被从Unix移植到Windows时,一个严重的问题立即就出现了。Unix支持fork,客户程序和服务器都能够fork新的进程,并启动这些进程,从而能够很方便地使用阻塞式Socket。而Windows 3.x既不支持fork也不支持多线程,当使用阻塞式Socket时,用户界面就会被“锁住”而无法响应用户输入。

为克服Windows 3.x的这一缺陷,微软在Winsock中加入了异步扩展,以使Winsock不会“锁住”应用程序的主线程(也是唯一的线程)。然而,这需要了一种完全不同的编程方式。于是有些人为了掩饰这一弱点,就开始强烈地诽谤阻塞式Socket。

当Win32出现的时候,它能够很好地支持线程。但是既成的观念已经很难更改,并且说出去的话也无法收回,因此对阻塞式Socket的诽谤继续存在着。

事实上,阻塞式Socket仍然是Unix实现Socket的唯一方式,并且它工作得很好。

阻塞式Socket的优点

归结起来,在Windows上使用阻塞式Socket开发应用程序具有如下优点:

编程简单——阻塞式Socket应用程序很轻易编写。所有的用户代码都写在同一个地方,并且顺序执行。

轻易向Unix移植——由于Unix也使用阻塞式Socket,编写可移植的代码就变得比较轻易。Indy就是利用这一点来实现其多平台支持而又单一源代码的设计。

很好地利用了线程技术——阻塞式Socket是顺序执行的,其固有的封装特性使得它能够很轻易地使用到线程中。

阻塞式Socket的缺点

事物都具有两面性,阻塞式Socket也不例外。它的一个主要的缺点就是使客户程序的用户界面“冻结”。当在程序的主线程中进行阻塞式Socket调用时,由于要等待Socket调用完成并返回,这段时间就不能处理用户界面消息,使得Update、Repaint以及其它消息得不到及时响应,从而导致用户界面被“冻结”。

更多内容请看Wlan组网----家庭专题专题,或 使用TIdAntiFreeze对抗“冻结”

Indy使用一个非凡的组件TIdAntiFreeze来透明地解决客户程序用户界面“冻结”的问题。TIdAntiFreeze在Indy内部定时中断对栈的调用,并在中断期间调用application.PRocessMessages方法处理消息,而外部的Indy调用继续保存阻塞状态,就似乎TIdAntiFreeze对象不存在一样。你只要在程序中的任意地方添加一个TIdAntiFreeze对象,就能在客户程序中利用到阻塞式Socket的所有优点而避开它的一些显著缺点。

Indy使用了线程技术

阻塞式Socekt通常都采用线程技术,Indy也是如此。从最底层开始,Indy的设计都是线程化的。因此用Indy创建服务器和客户程序跟在Unix下十分相似,并且Delphi的快速开发环境和Indy对WinSock的良好封装使得应用程序创建更加轻易。

Indy服务器模型

一个典型的Unix服务器有一个或多个监听进程,它们不停地监听进入的客户连接请求。对于每一个需要服务的客户,都fork一个新进程来处理该客户的所有事务。这样一个进程只处理一个客户连接,编程就变得十分轻易。

Indy服务器工作原理同Unix服务器十分类似,只是Windows不像Unix那样支持fork,而是支持线程,因此Indy服务器为每一个客户连接分配一个线程。

图1显示了Indy服务器的工作原理。Indy服务器组件创建一个同应用程序主线程分离的监听线程来监听客户连接请求,对于接受的每一个客户,都创建一个新的线程来为该客户提供服务,所有与这一客户相关的事务都由该线程来处理。

图1 Indy服务器工作原理

使用组件TIdThreadMgrPool,Indy还支持线程池。

更多内容请看Wlan组网----家庭专题专题,或 线程与Indy客户程序

Indy客户端组件并未使用线程。但是在一些高级的客户程序中,程序员可以在自定义的线程中使用Indy客户端组件,以使用户界面更加友好。

简单的Indy应用示例

下面将创建一个简单的TCP客户程序和一个简单的TCP服务器来演示Indy的基本使用方法。客户程序使用TCP协议同服务器连接,并向服务器发送用户所输入数据。服务器支持两条命令:DATA和QUIT。在DATA命令后跟随要发送的数据,并用空格将命令字DATA和数据分隔开。

表单布局

建立一个项目组,添加一个客户程序项目和一个服务器项目。客户程序和服务器程序的表单布局如同2和图3所示。客户程序表单上放置了TIdTCPClient组件,服务器程序表单上放置了TIdTCPServer组件。为防止客户程序“冻结”,还在其表单上放置TIdAntiFreeze组件。

图2 简单的TCP客户程序表单

图3 简单的TCP服务器程序表单

客户程序和服务器程序的表单上都放置有TListBox组件,用来显示通信记录。

客户程序代码

客户程序片断如代码列表1所示。

代码列表1

procedure TFormMain.BTnConnectClick(Sender: TObject);

begin

IdTCPClient.Host := EdtHost.Text;

IdTCPClient.Port := StrToInt(EdtPort.Text);

LbLog.Items.Add('正在连接 ' + EdtHost.Text + '...');

with IdTCPClient do

begin

try

Connect(5000);

try

LbLog.Items.Add(ReadLn());

BtnConnect.Enabled := False;

BtnSend.Enabled := True;

BtnDisconnect.Enabled := True;

except

LbLog.Items.Add('远程主机无响应!');

IdTCPClient.Disconnect();

end;//end try

except

LbLog.Items.Add('无法建立到' + EdtHost.Text + '的连接!');

end;//end try

end;//end with

end;

procedure TFormMain.BtnSendClick(Sender: TObject);

begin

LbLog.Items.Add('DATA ' + EdtData.Text);

with IdTCPClient do

begin

try

WriteLn('DATA ' + EdtData.Text);

LbLog.Items.Add(ReadLn())

except

LbLog.Items.Add('发送数据失败!');

IdTCPClient.Disconnect();

LbLog.Items.Add('同主机 ' + EdtHost.Text + ' 的连接已断开!');

BtnConnect.Enabled := True;

BtnSend.Enabled := False;

BtnDisconnect.Enabled := False;

end;//end try

end;//end with

end;

procedure TFormMain.BtnDisconnectClick(Sender: TObject);

var

Received: string;

begin

LbLog.Items.Add('QUIT');

try

IdTCPClient.WriteLn('QUIT');

finally

IdTCPClient.Disconnect();

LbLog.Items.Add('同主机 ' + EdtHost.Text + ' 的连接已断开!');

BtnConnect.Enabled := True;

BtnSend.Enabled := False;

BtnDisconnect.Enabled := False;

end;//end try

end;

在“连接”按钮事件响应过程中,首先根据用户输入设置IdTCPClient的主机和端口,并调用IdTCPClient的Connect方法向服务器发出连接请求。然后调用ReadLn方法读取服务器应答数据。

在“发送”按钮事件响应过程中,调用WriteLn方法写DATA命令,向服务器发送数据。

在“断开”按钮事件响应过程中,向服务器发送QUIT命令,并调用Disconnect方法断开连接。

程序中还包含有通信信息记录和异常处理的代码。

更多内容请看Wlan组网----家庭专题专题,或

服务器程序代码

服务器程序片断如代码列表2所示。

代码列表2

procedure TFormMain.BtnStartClick(Sender: TObject);

begin

IdTCPServer.DefaultPort := StrToInt(EdtPort.Text);

IdTCPServer.Active := True;

BtnStart.Enabled := False;

BtnStop.Enabled := True;

LbLog.Items.Add('服务器已成功启动!');

end;

procedure TFormMain.BtnStopClick(Sender: TObject);

begin

IdTCPServer.Active := False;

BtnStart.Enabled := True;

BtnStop.Enabled := False;

LbLog.Items.Add('服务器已成功停止!');

end;

procedure TFormMain.IdTCPServerConnect(AThread: TIdPeerThread);

begin

LbLog.Items.Add('来自主机 '

+ AThread.Connection.Socket.Binding.Peerip

+ ' 的连接请求已被接纳!');

AThread.Connection.WriteLn('100: 欢迎连接到简单TCP服务器!');

end;

procedure TFormMain.IdTCPServerExecute(AThread: TIdPeerThread);

var

sCommand: string;

begin

with AThread.Connection do

begin

sCommand := ReadLn();

FLogEntry := sCommand + ' 来自于主机 '

+ AThread.Connection.Socket.Binding.PeerIP;

AThread.Synchronize(AddLogEntry);

if AnsiStartsText('DATA ', sCommand) then

begin

FReceived := RightStr(sCommand, Length(sCommand)-5);

WriteLn('200: 数据接收成功!');

AThread.Synchronize(DisplayData);

end

else if SameText(sCommand, 'QUIT') then begin

FLogEntry := '断开同主机 '

+ AThread.Connection.Socket.Binding.PeerIP

+ ' 的连接!';

AThread.Synchronize(AddLogEntry);

Disconnect;

end

else begin

WriteLn('500: 无法识别的命令!');

FLogEntry := '无法识别命令:' + sCommand;

AThread.Synchronize(AddLogEntry);

end;//endif

end;

end;

procedure TFormMain.DisplayData();

begin

EdtData.Text := FReceived;

end;

procedure TFormMain.AddLogEntry();

begin

LbLog.Items.Add(FLogEntry);

end;

“启动”按钮设置IdTCPServer 的Active属性为True来启动服务器,“停止”按钮设置Active属性为False来关闭服务器。

IdTCPServerConnect方法作为IdTCPServer 的OnCorrect事件响应过程,向客户端发送欢迎信息。OnCorrect事件在一个客户连接请求被接受时发生,为该连接创建的线程AThread被作为参数传递给IdTCPServerConnect方法。

IdTCPServerExecute方法是IdTCPServer 的OnExecute事件响应过程。OnExecute事件在TIdPeerThread对象试图执行其Run方法时发生。OnExecute事件与通常的事件有所不同,其响应过程是在某个线程上下文中执行的,参数AThread就是调用它的线程。这一点很重要,它意味着可能有多个OnExecute事件响应过程被同时执行。在连接被断开或中断前,OnExecute事件响应过程会被反复执行。

在IdTCPServerExecute方法中,首先读入一条指令,然后对指令进行判别。假如是DATA指令,就解出数据并显示它。假如收到的是QUIT指令,则断开连接。需要非凡指出的是,由于IdTCPServerExecute方法在某一线程上下文中执行,因此显示数据和添加事件记录都是将相应的方法传递给Synchronize调用来完成的。

运行程序

运行客户端和服务器程序,按如下流程进行操作:

1. 按服务器程序的“启动”按钮启动服务器;

2. 按客户程序的“连接”按钮,建立同服务器的连接;

3. 在客户程序的待发送数据编辑框中输入“Hello, Indy!”,并按“发送”按钮发送数据;

4. 按客户程序的“断开”按钮,断开同服务器的连接;

5. 按服务器程序的“停止”按钮停止服务器。

程序运行的结果如图4和图5所示。

图4 简单的TCP客户

图5 简单的TCP服务器

更多内容请看Wlan组网----家庭专题专题,

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有