YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-24 22:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

Disconnected Endpoint

Browse Source
This commit is contained in:
Wang Chunlong
2021-03-29 16:00:37 +08:00
parent d4440f3be1
commit cf8ea872d3
3 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientSessionsManager.cs
+4 -2
View File
@@ -1,4 +1,4 @@
using MQTTnet.Adapter; using MQTTnet.Adapter;
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using MQTTnet.Exceptions; using MQTTnet.Exceptions;
using MQTTnet.Formatter; using MQTTnet.Formatter;
@@ -237,11 +237,13 @@ namespace MQTTnet.Server
} }
} }
var clientEndpoint = channelAdapter.Endpoint;
await SafeCleanupChannelAsync(channelAdapter).ConfigureAwait(false); await SafeCleanupChannelAsync(channelAdapter).ConfigureAwait(false);
if (clientId != null) if (clientId != null)
{ {
await _eventDispatcher.SafeNotifyClientDisconnectedAsync(clientId, disconnectType).ConfigureAwait(false); await _eventDispatcher.SafeNotifyClientDisconnectedAsync(clientId, disconnectType, clientEndpoint).ConfigureAwait(false);
} }
} }
Source/MQTTnet/Server/MqttServerClientDisconnectedEventArgs.cs
+5 -2
View File
@@ -1,13 +1,14 @@
using System; using System;
namespace MQTTnet.Server namespace MQTTnet.Server
{ {
public class MqttServerClientDisconnectedEventArgs : EventArgs public class MqttServerClientDisconnectedEventArgs : EventArgs
{ {
public MqttServerClientDisconnectedEventArgs(string clientId, MqttClientDisconnectType disconnectType) public MqttServerClientDisconnectedEventArgs(string clientId, MqttClientDisconnectType disconnectType, string endpoint)
{ {
ClientId = clientId ?? throw new ArgumentNullException(nameof(clientId)); ClientId = clientId ?? throw new ArgumentNullException(nameof(clientId));
DisconnectType = disconnectType; DisconnectType = disconnectType;
Endpoint = endpoint;
} }
/// <summary> /// <summary>
@@ -17,5 +18,7 @@ namespace MQTTnet.Server
public string ClientId { get; } public string ClientId { get; }
public MqttClientDisconnectType DisconnectType { get; } public MqttClientDisconnectType DisconnectType { get; }
public string Endpoint { get; set; }
} }
} }
Source/MQTTnet/Server/MqttServerEventDispatcher.cs
+3 -3
View File
@@ -1,4 +1,4 @@
using MQTTnet.Client.Receiving; using MQTTnet.Client.Receiving;
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using System; using System;
using System.Threading.Tasks; using System.Threading.Tasks;
@@ -44,7 +44,7 @@ namespace MQTTnet.Server
} }
} }
public async Task SafeNotifyClientDisconnectedAsync(string clientId, MqttClientDisconnectType disconnectType) public async Task SafeNotifyClientDisconnectedAsync(string clientId, MqttClientDisconnectType disconnectType, string clientEndpoint)
{ {
try try
{ {
@@ -54,7 +54,7 @@ namespace MQTTnet.Server
return; return;
} }
await handler.HandleClientDisconnectedAsync(new MqttServerClientDisconnectedEventArgs(clientId, disconnectType)).ConfigureAwait(false); await handler.HandleClientDisconnectedAsync(new MqttServerClientDisconnectedEventArgs(clientId, disconnectType, clientEndpoint)).ConfigureAwait(false);
} }
catch (Exception exception) catch (Exception exception)
{ {