admin/JiShe.CollectBus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

增加TCP 客户端主动关闭监听

Browse Source
This commit is contained in:
zenghongyao 2025-05-18 17:18:31 +08:00
parent 9603b02532
commit 070173af4f
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/JiShe.CollectBus.Application/Plugins/TcpMonitor.cs
View File

@ -16,7 +16,7 @@ using Volo.Abp.Domain.Repositories;
namespace JiShe.CollectBus.Plugins namespace JiShe.CollectBus.Plugins
{ {
public partial class TcpMonitor : PluginBase, ITransientDependency, ITcpReceivedPlugin, ITcpConnectingPlugin, ITcpConnectedPlugin, ITcpClosedPlugin public partial class TcpMonitor : PluginBase, ITransientDependency, ITcpReceivedPlugin, ITcpConnectingPlugin, ITcpConnectedPlugin, ITcpClosedPlugin, ITcpClosingPlugin
{ {
private readonly IProducerService _producerService; private readonly IProducerService _producerService;
private readonly ILogger<TcpMonitor> _logger; private readonly ILogger<TcpMonitor> _logger;
@ -115,5 +115,11 @@ namespace JiShe.CollectBus.Plugins
await e.InvokeNext(); await e.InvokeNext();
} }
public Task OnTcpClosing(ITcpSession client, ClosingEventArgs e)
{
var tcpSessionClient = (ITcpSessionClient)client;
_logger.LogWarning($"[TCP] ID:{tcpSessionClient.Id} IP:{client.GetIPPort()}终端主动关闭");
return Task.CompletedTask;
}
} }
} }