继上篇《GGTalk 开源即时通讯系统源码剖析之:聊天消息防错漏机制》介绍了 GGTalk 对消息的可靠性,即消息的不丢失和不重复做了一系列优化处理,以保证不会错漏消息。这篇我们来剖析 GGTalk 新增的远程磁盘功能其对应的源码实现。
在之前的博文《实现远程磁盘:像访问自己的电脑硬盘一样访问对方的电脑硬盘 》,我们通过一个Demo介绍了访问远程磁盘如何实现。最近,我们已经在GGTalk开源即时通讯IM的最新版中增加访问好友磁盘的功能:在一对一的对话窗口,请求方可以发起访问对方磁盘的请求,如果对方同意,则请求方就可以通过远程磁盘的窗口来操作对方的磁盘了。现在我们来看看GGTalk的远程磁盘这一功能具体是如何实现的,大家可以先下载GGTalk的最新源码,然后对照源码,更容易理解本文的内容。
一. 定义消息协议
在远程磁盘请求方和应答方相互通信之前,我们先定义好远程磁盘这一功能需要用到的消息协议。- /// <summary>
- /// 交互媒体的类型。
- /// </summary>
- public enum CommunicateMediaType
- {
- Video = 0,
- Audio,
- RemoteHelp,
- RemoteControl,
- RemoteDisk,
- GroupVideo
- }
复制代码 在交互媒体的类型枚举上,我们增加了 远程磁盘(RemoteDisk)这个类型。
再结合原先的 CommunicateType 枚举,我们就可以组合出远程磁盘相关的业务通信:请求、应答(同意或拒绝)、中断等。- /// <summary>
- /// 交互的类型。比如 请求视频会话,同意视频会话,拒绝视频会话,终止视频会话
- /// </summary>
- public enum CommunicateType
- {
- Request = 0,
- Agree,
- Reject,
- Terminate,
- Busy
- }
复制代码 有了上面的铺垫,我们就可以来实现整个远程磁盘功能的业务流程了。
二. 远程磁盘请求方实现
首先,使用VS 2022 打开 GGTalk 解决方案,找到GGTalk 客户端项目(Windows版):
我们在一对一的聊天窗口 FriendChatForm (在Forms文件夹下)上增加“请求访问对方磁盘”的按钮,如下图所示:
点击该按钮时,将执行如下动作:- public void RequestControlFriendDisk()
- {
- //如果自己掉线,则直接返回。
- if (this.resourceCenter.ClientGlobalCache.CurrentUser.UserStatus == UserStatus.OffLine)
- {
- return;
- }
- this.resourceCenter.ClientOutter.<strong>SendMediaCommunicate</strong>(this.currentFriend.ID, CommunicateMediaType.RemoteDisk, CommunicateType.Request, null);
- NDiskOutter diskOutter = new NDiskOutter(this.resourceCenter.RapidPassiveEngine, this.resourceCenter.NDiskPassiveHandler);
- this.remoteDiskForm = new RemoteDiskForm(this.currentFriend.ID,ClientType.DotNET,this.currentFriend.DisplayName, diskOutter, this.resourceCenter.RapidPassiveEngine.FileOutter, this.resourceCenter.CurrentUserID);
- this.remoteDiskForm.RemoteDiskRequestCancelled += new CbGeneric(remoteDiskForm_RemoteDiskRequestCancelled);
- this.remoteDiskForm.RemoteDiskEnded += new CbGeneric<bool>(remoteDiskForm_RemoteDiskEnded);
- this.remoteDiskForm.Show();
- }
复制代码 (1)客户端通过调用 IClientOutter 的 SendMediaCommunicate 方法,来实现与远程磁盘功能相关的业务通信。
(2)通过 CommunicateMediaType.RemoteDisk 和 CommunicateType.Request 来表名这次交互发送的是一个远程磁盘请求。
(3)在等待对方应答期间,使用 RemoteDiskForm 来显示正在等待对方回复。如下图所示:
(4)如果对方同意了远程磁盘请求,那么RemoteDiskForm 将改变状态,请求方就能通过该窗体来操作对方的磁盘,如下图所示:
关于 RemoteDiskForm 的具体实现细节,可以参考 《实现远程磁盘:像访问自己的电脑硬盘一样访问对方的电脑硬盘 》。
三. 远程磁盘应答方实现
当应答方收到跟远程磁盘相关的业务消息时,会进入到 RemoteDiskManager的 HandleRemoteDisk 方法,如下代码所示:- public void HandleRemoteDisk(CommunicateType communicateType, string tag)
- {
- if (communicateType == CommunicateType.Request)
- {
- this.OnRemoteDiskRequestReceived();
- this.ownerForm.FlashWindow();
- return;
- }
- if (communicateType == CommunicateType.Agree)
- {
- this.OnRemoteDiskAnswerReceived(true);
- this.ownerForm.FlashWindow();
- return;
- }
- if (communicateType == CommunicateType.Reject)
- {
- this.OnRemoteDiskAnswerReceived(false);
- this.ownerForm.FlashWindow();
- return;
- }
- if (communicateType == CommunicateType.Terminate)
- {
- if (tag == "owner")
- {
- this.OnOwnerTerminateRemoteDisk();
- }
- else
- {
- this.OnGuestCloseRemoteDisk();
- }
- this.ownerForm.FlashWindow();
- return;
- }
- }
复制代码 (1)在 OnRemoteDiskRequestReceived 方法中,会在窗体的右侧,显示远程磁盘请求,如下截图:
(2)当应答方点击“接受”或“拒绝”按钮时,也将通过调用 IClientOutter 的 SendMediaCommunicate 方法(位于RemoteDiskManager类),来将回复消息发送给请求方。- void remoteDiskRequestPanel_RemoteRequestAnswerd(bool agree)
- {
- this.ownerForm.RemoveDisplayedPanel(this.Title_Disk);
- this.resourceCenter.ClientOutter.SendMediaCommunicate(this.currentFriend.ID, CommunicateMediaType.RemoteDisk, agree ? CommunicateType.Agree : CommunicateType.Reject, null);
- string showText = string.Format("您{0}了对方的磁盘访问请求。", agree ? "同意" : "拒绝");
- this.ownerForm.AppendSysMessage(showText);
- if (agree)
- {
- this.remoteDiskHandlePanel.OnAgree();
- this.ownerForm.AddDisplayedPanel(this.Title_Disk, this.remoteDiskHandlePanel);
- }
- }
复制代码 (3)如果点击“接受”按钮,则聊天窗体右侧将会出现“远程磁盘的控制面板”,以随时可以收回远程磁盘控制权。
(4)在对方控制自己磁盘的过程中,应答方点击上方的“终止”按钮,即可结束控制。这是给对方发送一个“终止控制”的 CommunicateType.Terminate 消息:- void remoteDiskHandlePanel_RemoteDiskTerminated()
- {
- this.ownerForm.RemoveDisplayedPanel(this.Title_Disk);
- this.resourceCenter.ClientOutter.SendMediaCommunicate(this.currentFriend.ID, CommunicateMediaType.RemoteDisk, CommunicateType.Terminate, "owner");
- string showText = "您关闭了磁盘共享。";
- this.ownerForm.AppendSysMessage(showText);
- }
复制代码 四. 结语
以上就是关于 GGTalk 远程磁盘功能的设计与实现的核心了。在某些办公场景中,远程磁盘这个功能还是很有用的,所以,GGTalk 即时通讯就实现该功能,方便那些有需要的人。
如果你觉得还不错,请点赞支持啊!下篇再见!
若需下载GGTalk最新源码,请移不到 GGTalk 源码下载中心 ,谢谢 。
来源:程序园用户自行投稿发布,如果侵权,请联系站长删除
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作! |