//------------------------------------------------------------------------------ // 此代码版权(除特别声明或在XREF结尾的命名空间的代码)归作者本人若汝棋茗所有 // 源代码使用协议遵循本仓库的开源协议及附加协议,若本仓库没有设置,则按MIT开源协议授权 // CSDN博客:https://blog.csdn.net/qq_40374647 // 哔哩哔哩视频:https://space.bilibili.com/94253567 // Gitee源代码仓库:https://gitee.com/RRQM_Home // Github源代码仓库:https://github.com/RRQM // API首页:https://www.yuque.com/rrqm/touchsocket/index // 交流QQ群:234762506 // 感谢您的下载和使用 //------------------------------------------------------------------------------ //------------------------------------------------------------------------------ using System.Threading.Tasks; using TouchSocket.Core; namespace TouchSocket.Sockets { /// /// 插件实现基类 /// public abstract class TcpPluginBase : TcpPluginBase { } /// /// 插件实现基类 /// public abstract class TcpPluginBase : PluginBase, ITcpPlugin, IConfigPlugin { void IConnectedPlugin.OnConnected(object client, TouchSocketEventArgs e) { OnConnected((TClient)client, e); } Task IConnectedPlugin.OnConnectedAsync(object client, TouchSocketEventArgs e) { return OnConnectedAsync((TClient)client, e); } void IConnectingPlugin.OnConnecting(object client, OperationEventArgs e) { OnConnecting((TClient)client, e); } Task IConnectingPlugin.OnConnectingAsync(object client, OperationEventArgs e) { return OnConnectingAsync((TClient)client, e); } void IDisconnectedPlguin.OnDisconnected(object client, DisconnectEventArgs e) { OnDisconnected((TClient)client, e); } Task IDisconnectedPlguin.OnDisconnectedAsync(object client, DisconnectEventArgs e) { return OnDisconnectedAsync((TClient)client, e); } void IDisconnectingPlugin.OnDisconnecting(object client, DisconnectEventArgs e) { this.OnDisconnecting((TClient)client, e); } Task IDisconnectingPlugin.OnDisconnectingAsync(object client, DisconnectEventArgs e) { return this.OnDisconnectingAsync((TClient)client, e); } void ITcpPlugin.OnIDChanged(ITcpClientBase client, IDChangedEventArgs e) { OnIDChanged((TClient)client, e); } Task ITcpPlugin.OnIDChangedAsync(ITcpClientBase client, IDChangedEventArgs e) { return OnIDChangedAsync((TClient)client, e); } void IConfigPlugin.OnLoadedConfig(object sender, ConfigEventArgs e) { OnLoadedConfig(sender, e); } Task IConfigPlugin.OnLoadedConfigAsync(object sender, ConfigEventArgs e) { return OnLoadedConfigAsync(sender, e); } void IConfigPlugin.OnLoadingConfig(object sender, ConfigEventArgs e) { OnLoadingConfig(sender, e); } Task IConfigPlugin.OnLoadingConfigAsync(object sender, ConfigEventArgs e) { return OnLoadingConfigAsync(sender, e); } void ITcpPlugin.OnReceivedData(ITcpClientBase client, ReceivedDataEventArgs e) { OnReceivedData((TClient)client, e); } Task ITcpPlugin.OnReceivedDataAsync(ITcpClientBase client, ReceivedDataEventArgs e) { return OnReceivedDataAsync((TClient)client, e); } void ITcpPlugin.OnReceivingData(ITcpClientBase client, ByteBlockEventArgs e) { OnReceivingData((TClient)client, e); } Task ITcpPlugin.OnReceivingDataAsync(ITcpClientBase client, ByteBlockEventArgs e) { return OnReceivingDataAsync((TClient)client, e); } void ITcpPlugin.OnSendingData(ITcpClientBase client, SendingEventArgs e) { OnSending((TClient)client, e); } Task ITcpPlugin.OnSendingDataAsync(ITcpClientBase client, SendingEventArgs e) { return OnSendingDataAsync((TClient)client, e); } #region 虚函数实现 /// /// 成功建立连接 /// /// /// protected virtual void OnConnected(TClient client, TouchSocketEventArgs e) { } /// /// 客户端连接成功后触发 /// /// /// /// protected virtual Task OnConnectedAsync(TClient client, TouchSocketEventArgs e) { return EasyTask.CompletedTask; } /// /// 在请求连接时 /// /// /// protected virtual void OnConnecting(TClient client, OperationEventArgs e) { } /// /// 在即将完成连接时触发。 /// /// /// /// protected virtual Task OnConnectingAsync(TClient client, OperationEventArgs e) { return EasyTask.CompletedTask; } /// /// 在断开连接时 /// /// /// protected virtual void OnDisconnected(TClient client, DisconnectEventArgs e) { } /// /// 会话断开后触发 /// /// /// /// protected virtual Task OnDisconnectedAsync(TClient client, DisconnectEventArgs e) { return EasyTask.CompletedTask; } /// protected virtual void OnDisconnecting(TClient client, DisconnectEventArgs e) { } /// protected virtual Task OnDisconnectingAsync(TClient client, DisconnectEventArgs e) { return EasyTask.CompletedTask; } /// /// 当Client的ID被更改后触发 /// /// /// protected virtual void OnIDChanged(TClient client, TouchSocketEventArgs e) { } /// /// 当Client的ID被更改后触发 /// /// /// /// protected virtual Task OnIDChangedAsync(TClient client, TouchSocketEventArgs e) { return EasyTask.CompletedTask; } /// /// 当载入配置时 /// /// /// protected virtual void OnLoadedConfig(object sender, ConfigEventArgs e) { } /// /// 当完成配置载入时 /// /// /// /// protected virtual Task OnLoadedConfigAsync(object sender, ConfigEventArgs e) { return EasyTask.CompletedTask; } /// /// 当完成配置载入时 /// /// /// protected virtual void OnLoadingConfig(object sender, ConfigEventArgs e) { } /// /// 当载入配置时 /// /// /// /// protected virtual Task OnLoadingConfigAsync(object sender, ConfigEventArgs e) { return EasyTask.CompletedTask; } /// /// 在收到数据时触发 /// /// 客户端 /// 参数,当设置e.Handled=true时,终止向下传递 protected virtual void OnReceivedData(TClient client, ReceivedDataEventArgs e) { } /// /// 在收到数据时触发 /// /// /// /// protected virtual Task OnReceivedDataAsync(TClient client, ReceivedDataEventArgs e) { return EasyTask.CompletedTask; } /// /// 在刚收到数据时触发,即在适配器之前。 /// /// 客户端 /// 参数 protected virtual void OnReceivingData(TClient client, ByteBlockEventArgs e) { } /// /// 在刚收到数据时触发,即在适配器之前。 /// /// /// /// protected virtual Task OnReceivingDataAsync(TClient client, ByteBlockEventArgs e) { return EasyTask.CompletedTask; } /// /// 当即将发送数据时,调用该方法在适配器之后,接下来即会发送数据。 /// /// 客户端 /// 参数,当设置e.IsPermitOperation=false时,中断发送。 protected virtual void OnSending(TClient client, SendingEventArgs e) { } /// /// 当即将发送数据时,调用该方法在适配器之后,接下来即会发送数据。 /// /// /// /// protected virtual Task OnSendingDataAsync(TClient client, SendingEventArgs e) { return EasyTask.CompletedTask; } #endregion 虚函数实现 } }