难道要获得客户端ip吗 要用两对服务客户端
解决方案 »
- 在安装fastReport控件出现的问题,请大家帮帮忙
- 用for xml auto 得到的数据怎么使用?
- 请教下,如何把a.exe应用程序设置在windows server 2003的任务栏里,让他自己到早上8点就启动呢?
- 30分在线等待(马上结帐):怎么打开制定的excel文件?小问题啊!
- 如何做一个最最简单的输入法.输入某个指定的字符
- 请问ADO高手,怎么样捕获ADO异常错误的错误号。
- 如何遍历文件并加入TreeView?
- (up没分!100分给第一个能解决我问题的人)怎样把矩形的TPanel,TPageControl变成圆角矩形?请提供控件或代码或方法。
- 关于delphi若干个问题的补充
- 大侠TechnoFantasy安在
- 新手求助,设计登陆问题
- DELPHI 带不带原程序
在客户端声明TClientModule1的单元文件uClientModule中:
1、声明一个从TDBXCallback继承下来的对象(用于回叫参数值),并实现复载的步骤。type
TInitCallback = class(TDBXCallback)
function Execute(const Arg: TJSONValue): TJSONValue; override;
end; TProgCallback = class(TDBXCallback)
function Execute(const Arg: TJSONValue): TJSONValue; override;
end; 2、初始化创建该对象Initialization // 初始化 创建
InitCallback := TInitCallback.Create;
ProgCallback := TProgCallback.Create; 3、实现声明的方法function TProgCallback.Execute(const Arg: TJSONValue): TJSONValue;
begin
with MainFrm do
begin
ProgressBar1.Position := TJSONNumber(Arg).AsInt;
Button5.Enabled := (TJSONNumber(Arg).AsInt = ProgressBar1.Max);
end;
//刷新屏幕
Application.ProcessMessages;
Result := TJSONNull.Create; // 回传Null值
end;function TInitCallback.Execute(const Arg: TJSONValue): TJSONValue;
begin
with MainFrm do
begin
ProgressBar1.Max := TJSONNumber(Arg).AsInt;
ProgressBar1.Step := 5;
Edit1.Text := '总时长:' + TJSONNumber(Arg).ToString + '秒';
Button5.Enabled := False;
end;
Result := TJSONNull.Create;
end; 4、调用回叫方法
procedure TMainFrm.Button5Click(Sender: TObject);
begin
ClientModule1.ServerMethods1Client.LongTimeRunFunc(InitCallback, ProgCallback);
end; 二、服务器端实现步骤
在服务器端声明TServerMethods1的单元文件uServerMethods中:
1、编写一个带回叫机制的方法
在方法的形参中,带入客户端的回叫参数:function TServerMethods1.LongTimeRunFunc(InitCallback, ProgCallback: TDBXCallback): boolean;
var Max: Integer;
I: Integer;
begin
Max := Random(120) + 1;
InitCallback.Execute(TJSONNumber.Create(Max)).Free; // 将Max值通过JSON格式,通过InitCallback执行回叫后,释放该对象
for I := 0 to Max do
begin
ProgCallback.Execute(TJSONNumber.Create(I)).Free; // 将I值通过JSON格式,通过ProgCallback执行回叫后,释放该对象
sleep(1000);
end;
Result := True;
end; 2、声明该方法 public
{ Public declarations }
function LongTimeRunFunc(InitCallback, ProgCallback: TDBXCallback): boolean; 三、客户端声明服务器端输入方法的对象
服务器端声明的方法(对象),需要在客户端中声明,才能使得二者之间实现数据传递。
1、执行服务器端程序。
2、在客户端的ClientModule1的单元,通过鼠标右键点击SQLConnection1,选择“Generate DataSnap client classses”项目。 四、运行机制
客户端声明的TProgCallback是继承TDBXCallback的对象,它复载虚方法Execute,在服务器端运行,接受一个TJSONValue的参数,并且回传一个TJSONValue的结果值。TDBXCallback的回叫机制很有意思:服务器端在回叫客户端的方法时,可以将需要回传缎带客户端的值或对象,以TJSONValue的形式,当作虚方法Execute的参数回传缎带客户端,而客户端的方法,在被回叫执行完毕后,也可以将执行结果,以TJSONValue的形式,回传给服务器端。
(1)TDBXCallback机制;
(2)TDServer.BroadcastMessage方法;
(3)TDSClientCallbackChanneManager1.RegisterCallback方法;
三、回叫的方式
1、服务器端回叫所有(同一信道)客户端
2、客户端回叫(同一信道)的其它客户端
3、客户端可以注册多个信道 一、服务器端对回叫信道的设置
1、服务器端回叫信道的注册
编程时,将相关的回叫信道字符,确定下来,便于代码中识别调用。
const DEMOChannel='DemoChannel'; 2、服务器端对客户端的回叫
服务器端使用 TDServer组件的BroadcastMessage方法回叫所有注册的客户端。
TDServer组件重载了二个的BroadcastMessage方法
(1)使用二参数
function BroadcastMessage(const ChannelName:String; const Msg: TJSONValue; const ArgType:Integer=TDBXCallback.ArgJason):boolean; overload;
第1参数ChannelName指定通道中所有的回叫客户端;
第2参数Meg回传;
功能:通过Meg传递信息给带ChannelNamer指定的全部客户端。 (2)使用三参数
function BroadcastMessage(const ChannelName:String; const CallbackID:String; const Msg: TJSONValue; const ArgType:Integer=TDBXCallback.ArgJason):boolean; overload;
第1参数ChannelName指定通道中所有的回叫客户端;
第2参数CallbackID指定客户端的识别码;
第3参数Meg回传;
功能:通过Meg传递信息给带ChannelNamer中,指定的CallbackID客户端。 实例:例如在服务器端的TMemo1.onChange事件中:
procedure TSMainFrm.mmMessageChange(Sender: TObject);
var vMessage:TJSONString;
begin
vMessage := TJSONString.Create(mmMessage.Lines.Text);
ServerContainer1.DSServer1.BroadcastMessage(DEMOChannel, vMessage);
end; 3、服务器端对客户端注册的回叫通道的搜索
(1)搜索注册回叫通道的客户端ID,通过DSServer1.GetAllChannelClientId方法实现,代码如下:procedure TForm1.btnListAllClientIdsClick(Sender: TObject);
var
aIdList : TList<String>;
sId : String;
begin
aIdList := ServerContainer5.DSServer1.GetAllChannelClientId(DEMOChannel);
try
for sId in aIdList do
lbAllClientIds.Items.Add(sId);
finally
aIdList.Free;
end;
end; (2)搜索注册回叫通道客户端的回叫ID ,通过DSServer1.GetAllChannelCallbackId方法实现,代码如下:procedure TForm1.btnListAllCallbackIdsClick(Sender: TObject);
var
aIdList : TList<String>;
sId : String;
begin
aIdList := ServerContainer5.DSServer1.GetAllChannelCallbackId(DEMOChannel);
try
for sId in aIdList do
lbAllCallbackIds.Items.Add(sId);
finally
aIdList.Free;
end;
end; 二、客户端对回叫信道的设置
1、客户端注册
客户端注册回叫信道,由TDSClientCallbackChannelManager1.RegisterCallback方法实现;执行语句如下:
TDSClientCallbackChanneManager1.RegisterCallback(Combobox1.Text, TDemoCallback.Create);
现在我们看一看,客户端向服务器端注册回叫信道时,上述代码包含了注册回叫通道的四个要素:
(1)回叫通道ID,TDSClientCallbackChanneManager.ChannelNament属性值;相关字符应与服务器注册的“回叫信道”字符一致。
(2)客户端ID,TDSClientCallbackChanneManager.ManagerID属性值;每个客户端应明确一个唯一的识别码。
(3)回叫ID ,由TDSClientCallbackChanneManager1.RegisterCallback方法的第1个参数;
(4)回叫方法,由TDSClientCallbackChanneManager1.RegisterCallback第2个参数带入,创建TDemoCallback继承的方法,该对象复载Execute方法,就是用于回叫识别。
2、客户端与客户端之间的回叫,使用TDSAdminClient类别的NotifyCallback方法
XE在DSProxy单元,增加TDSAdminClient类别,强化回叫功能。其中TDSAdminClient类别的NotifyCallback方法用于客户端之间的回叫,可以回叫指定回叫通道中的特定客户端(客户端ID)或回叫识别(回叫ID)的客户端。声明如下:function NotifyCallback(ChannelName:string; ClientID:string;CallbackID:string;Msg:TJSONValue; out Respones :TJSONValue):Boolean; NotifyCallback方法的参数含意:
(1)ChannelName,回叫通道名称;
(2)ClientID,客户端识别;
(3)CallbackID,回叫识别;
(4)Msg,传递信息;
(5)Respones,被叫客户端的回传信息。
实例如下:
procedure TfmMainForm.btnBroadcastToClientClick(Sender: TObject);
var
LClient: TDSAdminClient;
LMessage: TJSONString;
LResponse: TJSONValue;
LConnection: TDBXConnection;
begin
LConnection := scnnCallbackServer.DBXConnection;
LClient := TDSAdminClient.Create(LConnection, False);
try
LMessage := TJSONString.Create(Format('呼叫通道:%s,客户端识别:%s,回叫识别:%s,回叫信息:%s',
[DemoChannelManager.ChannelName, cbClientIds.Text, cbCallbackIds.Text, mmChannelCallbacks.Text]));
try
LClient.NotifyCallback(DemoChannelManager.ChannelName, cbClientIds.Text, cbCallbackIds.Text, LMessage, LResponse);
try
if LResponse <> nil then
edtResponse.Text := Format('客户端响应:%s', [LResponse.ToString])
else
edtResponse.Text := Format('客户端响应:%s', ['nil']);
finally
LResponse.Free;
end;
finally
LMessage.Free;
end;
finally
LClient.Free;
end;
end;上述代码均XE6 编译通过:回叫功能的服务器、客户端实例二个例子:
(1)服务器与客户端之间的回叫演示
(2)服务器与客户端之间,客户端与客户端之间回叫演示。
包含学习体会,以及服务器、客户端调试方法,下载地址:
http://download.csdn.net/detail/lyhoo163/7385107
设置一下DefalutPort;在OnExecute中处理数据(里面有个AThread.参数,AThread.Connection.ReadLn())就可以了客户端:IdTCPClient
设置一下host,port即可
clt.Connect();--连接
clt.WriteLn(MSG);--发送信息
clt.Disconnect;--关闭连接