增加 获取客户端和 sess 的方法

Author: maikebing

ExampleClient/ExampleClient.csproj

@@ -9,4 +9,8 @@
     <PackageReference Include="MQTTnet.Extensions.ManagedClient" Version="4.0.1.184" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\Source\MQTTnet.AspNetCore.Routing.csproj" />
+  </ItemGroup>
+
 </Project>

ExampleServer/ExampleServer.csproj

@@ -5,7 +5,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <ProjectReference Include="..\Source\MQTTnet.AspNetCore.AttributeRouting.csproj" />
+    <ProjectReference Include="..\Source\MQTTnet.AspNetCore.Routing.csproj" />
   </ItemGroup>
 
 

Source/MQTTnet.AspNetCore.AttributeRouting.csproj

@@ -4,6 +4,7 @@
 using MQTTnet.AspNetCore.AttributeRouting.Attributes;
 using MQTTnet.AspNetCore.AttributeRouting.Routing;
 using MQTTnet.Server;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace MQTTnet.AspNetCore.AttributeRouting
@@ -26,6 +27,24 @@ public abstract class MqttBaseController
         /// </summary>
         public MqttServer Server => ControllerContext.MqttServer;
 
+        public string ClientId => MqttContext.ClientId;
+        public async Task<MqttClientStatus> GetClientStatusAsync()
+        {
+            var clients = await Server.GetClientsAsync();
+            return clients.FirstOrDefault(c => c.Id == MqttContext.ClientId);
+        }
+        public async Task<MqttSessionStatus> GetSessionAsync()
+        {
+            var client = await GetClientStatusAsync();
+            return client?.Session;
+        }
+
+        public async Task<T> GetSessionDataAsync<T>(string key)
+        {
+            var client = await GetClientStatusAsync();
+            return (T)(client?.Session.Items[key]);
+        }
+
         /// <summary>
         /// ControllerContext is set by controller activator. If this class is instantiated directly, it will be null.
         /// </summary>