Diocp学习笔记 3、服务端连接、发送、接收（以实际例子记录）（DELPHI 通讯框架）

服务器通过TDiocpCoderTcpServer类进行创建，并设置相应值

一、创建服务

varFTcpServer: TDiocpCoderTcpServer;  //声明全局变量
//创建服务
procedure TfrmServer.FormCreate(Sender: TObject);
beginFUILocker := TIocpLocker.Create('界面异步操作锁');// FOfflineMsgs := TObjectList<TOfflineInfo>.Create;FTcpServer := TDiocpCoderTcpServer.Create(Self);FTcpServer.CreateDataMonitor;  // 创建监视器(如不创建TFMMonitor创建后不能获取监控数据)FTcpServer.WorkerCount := 3;   //设置线程// register decoder and encoder classFTcpServer.RegisterCoderClass(TIOCPStreamDecoder, TIOCPStreamEncoder);  // 注册加解密流类FTcpServer.RegisterContextClass(TMyClientContext);  // 注册客户端Context 绑定接收事件等 自己创建的类(在这里设置好后，客户端地发送请求后，会调用TMyClientContext里面的DoContextAction)//FTcpServer.OnContextDisconnected := OnContextNotifyEvent;// 设置日志记录sfLogger.setAppender(TStringsAppender.Create(mmoMsg.Lines));sfLogger.AppendInMainThread := true;TFMMonitor.CreateAsChild(tsState, FTcpServer);  // 创建服务端运行监控 窗体
end;

二、启用服务

  FTcpServer.Port := 60544;   //设置端口FTcpServer.Active := true;  //启用服务

三、停止服务

  FTcpServer.SafeStop;

四、接收客户端消息

因为在注册服务端的时候通过FTcpServer.RegisterContextClass(TMyClientContext); 注册了类TMyClientContext为客户端通讯类，所以在类下重写DoContextAction 用来接收客户端传过来的数据，并进行处理操作

/// <summary>
/// 处理客户端传来的数据
/// </summary>
procedure TMyClientContext.DoContextAction(const pvObject: TObject);
varlvCMDObj: TSimpleMsgPack;
begin// 此方法已经在 TIOCPCoderClientContext.DoExecuteRequest 中处理了线程同步了lvCMDObj := TSimpleMsgPack.Create;trytryTMemoryStream(pvObject).Position := 0;//通过通讯传值操作将传过来对象转换为数据结构对象lvCMDObj.DecodeFromStream(TMemoryStream(pvObject));  // 解密消息//对消息进行处理操作，如返回此等操作都在这一步进行处理ChatExecute(lvCMDObj);  // 根据消息协议类型由对应的事件处理// 通知客户端本次调用是否成功if lvCMDObj.O['cmdIndex'] <> nil then  // 或 lvCMDObj.ForcePathObject('cmdIndex').AsString <> ''beginif lvCMDObj.O['result.code'] = nil thenlvCMDObj.I['result.code'] := 0;end;excepton E:Exception dobeginlvCMDObj.ForcePathObject('result.code').AsInteger := -1;lvCMDObj.ForcePathObject('result.msg').AsString := e.Message;sfLogger.logMessage('处理逻辑出现异常:'+ e.Message);{$IFDEF CONSOLE}writeln('处理逻辑出现异常:'+ e.Message);{$ENDIF}end;end;//对客户端进行回传if lvCMDObj.O['cmdIndex'] <> nil thenbeginTMemoryStream(pvObject).Clear;lvCMDObj.EncodeToStream(TMemoryStream(pvObject));  // 加密消息TMemoryStream(pvObject).Position := 0;Self.WriteObject(pvObject);  // 添加到SendingQueue回写对象end;finallylvCMDObj.Free;end;
end;

五、给客户端传消息

1》给所有客户端传消息
可以通过Self.Owner.GetOnlineContextList(lvList)函数获得所有会话，进行传递

procedure TMyClientContext.DispatchMsgPackToAll(AMsgPack: TSimpleMsgPack);
varlvMS:TMemoryStream;i:Integer;lvList:TList;lvContext:TIOCPCoderClientContext;
beginlvMS := TMemoryStream.Create;lvList := TList.Create;tryAMsgPack.EncodeToStream(lvMS);lvMS.Position := 0;// 通知所有在线的客户端有人上线或下线等行为Self.Owner.GetOnlineContextList(lvList);for i := 0 to lvList.Count - 1 dobeginlvContext := TIOCPCoderClientContext(lvList[i]);if lvContext <> Self thenbeginlvContext.LockContext('推送信息', nil);trylvContext.WriteObject(lvMS);finallylvContext.UnLockContext('推送信息', nil);end;end;end;finallylvMS.Free;lvList.Free;end;
end;

2>指定客户端传消息
因指定客户但只知道ID编号。需要通过会话查找到此会话号，在进行传递

查找

varvMsgPackTo: TSimpleMsgPack;vFromSession, vToSession: TChatSession;vToSession := TChatSession(ChatSessions.FindSession(vToUserID));
if vToSession <> nil then  // 接收用户在
beginvToContext := vToSession.Context;if vToContext <> nil thenbeginvMsgPackTo := TSimpleMsgPack.Create;tryvMsgPackTo.ForcePathObject('cmdIndex').AsInteger := 6;vMsgPackTo.ForcePathObject('userid').AsString := vFromUserID;vMsgPackTo.ForcePathObject('requestID').AsString :=AMsgPackFrom.ForcePathObject('requestID').AsString;vMsgPackTo.ForcePathObject('msg').AsString :=AMsgPackFrom.ForcePathObject('params.msg').AsString;SendMsgPack(vMsgPackTo, vToContext);finallyvMsgPackTo.Free;end;end;
end;

procedure TMyClientContext.SendMsgPack(AMsgPack: TSimpleMsgPack; pvContext: TObject);
varlvMS:TMemoryStream;
beginlvMS := TMemoryStream.Create;tryAMsgPack.EncodeToStream(lvMS);lvMS.Position := 0;TIOCPCoderClientContext(pvContext).WriteObject(lvMS);finallylvMS.Free;end;
end;

3>在接收时直接回写
因为在接收的时候SELF代表的就是客户端的Context所以直接发送就可以了

      TMemoryStream(pvObject).Clear;lvCMDObj.EncodeToStream(TMemoryStream(pvObject));  // 加密消息TMemoryStream(pvObject).Position := 0;Self.WriteObject(pvObject);  // 添加到SendingQueue回写对象

Diocp学习笔记 3、服务端连接、发送、接收（以实际例子记录）（DELPHI 通讯框架）相关推荐

Linux学习笔记文件服务Vsftp详细介绍
Linux学习笔记文件服务Vsftp详细介绍知识点: 1.FTP使用TCP连接和TCP端口 2.在进行通信时,FTP需要建立两个TCP连接: 一个用于控制信息,TCP端口号缺省为21 一个用于数据 ...
java学习笔记：里氏代换原则的两个例子
java学习笔记:里氏代换原则的两个例子 (根据里氏代换原则[能使用父类型的地方一定能使用子类型],抓取 ExampleA类型异常的catch块能够抓住try块中抛出的ExampleB类型的异常) p ...
Python学习笔记18：实操案例十五（记录用户登录日志，模拟淘宝客服自动回复）
Python学习笔记18:实操案例十五(记录用户登录日志,模拟淘宝客服自动回复) 网课传送门:https://www.bilibili.com/video/BV1Sw411Z779?p=168& ...
开源Unity服务端客户端（双端C#）网络通讯框架（Lidgren）[一]
开源Unity服务端客户端(双端C#)网络通讯框架(Lidgren)[一] 1. 简介 1.1 结识Lidgren的机缘巧合开发Unity的各位或多或少都可能在工作中遇到非客户端开发的一些内容.大型 ...
Dubbo -- 系统学习笔记 -- 示例 -- 服务分组
Dubbo -- 系统学习笔记 -- 目录示例想完整的运行起来,请参见:快速启动,这里只列出各种场景的配置方式服务分组当一个接口有多种实现时,可以用group区分. <dubbo:se ...
ElasticSearch学习笔记-ngram、中文拼音、简繁体搜索记录
ElasticSearch版本:elasticsearch-7.3.0 ElasticSearch相关插件安装可以参考: ElasticSearch学习笔记-插件安装记录_人生偌只如初见的博客-CSD ...
cocos2d-x初探学习笔记（2）--重要概念及Test例子结构
小满(bill man)个人原创,欢迎转载,转载请注明地址,小满(bill man)的专栏地址http://blog.csdn.net/bill_man 1.几个重要概念在cocos2d引擎中,有几 ...
【深入浅出通信原理-学习笔记】基带信号的发送和接收
基带信号的发送和接收在通信系统模型中的位置如下图所示数字信号想要在信道中传输,必须在发射机的基带部分进行脉冲成形,将数字信号转换成脉冲信号,脉冲信号到达接收机后,在基带部分进行采样判决,将数字信号恢 ...
学习笔记---Web服务、Remoting、WCF （上） --- Web服务
自从程序设计诞生起, 如何最大限度的重用代码, 减小编码的重复劳动就是程序员永恒不变的课题. 我们从学习面向对象开始, 先后引入了很多种共享代码的手段, 随着学习的不断深入就越发觉得程序设计的发展过程 ...