NewLife/NewLife.MQTT

v2.0.2025.0415
智能大石头 authored at 2025-04-15 09:33:13
7ac4881
Tree
1 Parent(s) 37c0f62
Summary: 6 changed files with 8 additions and 14 deletions.
Modified +1 -1
Modified +1 -7
Modified +2 -2
Modified +2 -2
Modified +1 -1
Modified +1 -1
Modified +1 -1
diff --git a/NewLife.MQTT/MqttClient.cs b/NewLife.MQTT/MqttClient.cs
index 6efeb61..9ac83ee 100644
--- a/NewLife.MQTT/MqttClient.cs
+++ b/NewLife.MQTT/MqttClient.cs
@@ -429,7 +429,7 @@ public class MqttClient : DisposeBase
     {
         var message = new DisconnectMessage();
 
-        await SendAsync(message, true, cancellationToken).ConfigureAwait(false);
+        await SendAsync(message, false, cancellationToken).ConfigureAwait(false);
 
         var e = new EventArgs();
         Disconnected?.Invoke(this, e);
Modified +1 -7
diff --git a/NewLife.MQTT/MqttServer.cs b/NewLife.MQTT/MqttServer.cs
index 9f38a8a..848d764 100644
--- a/NewLife.MQTT/MqttServer.cs
+++ b/NewLife.MQTT/MqttServer.cs
@@ -208,12 +208,6 @@ public class MqttSession : NetSession<MqttServer>
         // 父级 OnReceive 触发事件,调用 NetServer.OnReceive
         base.OnReceive(e);
 
-        if (msg != null && msg.Type == MqttType.Disconnect)
-        {
-            // 等一会,等断开响应到达客户端
-            Thread.Sleep(500);
-
-            Dispose();
-        }
+        if (msg != null && msg.Type == MqttType.Disconnect) Dispose();
     }
 }
\ No newline at end of file
Modified +2 -2
diff --git a/NewLife.MQTT/NewLife.MQTT.csproj b/NewLife.MQTT/NewLife.MQTT.csproj
index 7bf620e..f3b4a2b 100644
--- a/NewLife.MQTT/NewLife.MQTT.csproj
+++ b/NewLife.MQTT/NewLife.MQTT.csproj
@@ -67,8 +67,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.4.2025.301" />
-    <PackageReference Include="NewLife.Remoting" Version="3.3.2025.301" />
+    <PackageReference Include="NewLife.Core" Version="11.4.2025.401" />
+    <PackageReference Include="NewLife.Remoting" Version="3.3.2025.401" />
   </ItemGroup>
 
   <ItemGroup>
Modified +2 -2
diff --git a/NewLife.MqttServer/NewLife.MqttServer.csproj b/NewLife.MqttServer/NewLife.MqttServer.csproj
index 38c2419..e58dbef 100644
--- a/NewLife.MqttServer/NewLife.MqttServer.csproj
+++ b/NewLife.MqttServer/NewLife.MqttServer.csproj
@@ -21,8 +21,8 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.4.2025.301" />
-    <PackageReference Include="NewLife.Stardust" Version="3.3.2025.301" />
+    <PackageReference Include="NewLife.Core" Version="11.4.2025.401" />
+    <PackageReference Include="NewLife.Stardust" Version="3.3.2025.401" />
   </ItemGroup>
 
   <ItemGroup>
Modified +1 -1
diff --git a/Test/Test.csproj b/Test/Test.csproj
index 2b78e31..a2fdd1d 100644
--- a/Test/Test.csproj
+++ b/Test/Test.csproj
@@ -16,7 +16,7 @@
     <LangVersion>latest</LangVersion>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.4.2025.301" />
+    <PackageReference Include="NewLife.Core" Version="11.4.2025.401" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\NewLife.MQTT\NewLife.MQTT.csproj" />
Modified +1 -1
diff --git a/XUnitTestClient/XUnitTestClient.csproj b/XUnitTestClient/XUnitTestClient.csproj
index 75dcc67..a763fad 100644
--- a/XUnitTestClient/XUnitTestClient.csproj
+++ b/XUnitTestClient/XUnitTestClient.csproj
@@ -10,7 +10,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.13.0" />
-    <PackageReference Include="NewLife.Core" Version="11.4.2025.301" />
+    <PackageReference Include="NewLife.Core" Version="11.4.2025.401" />
     <PackageReference Include="NewLife.UnitTest" Version="1.0.2025.101" />
     <PackageReference Include="xunit" Version="2.9.3" />
     <PackageReference Include="xunit.runner.visualstudio" Version="3.0.2">