处理mqtt取上下文信息的问题

Author: maikebing

Source/Routing/MqttBaseController.cs

@@ -1,9 +1,16 @@
 // Copyright (c) Atlas Lift Tech Inc. All rights reserved.
 
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using MQTTnet;
+using MQTTnet.AspNetCore.AttributeRouting;
 using MQTTnet.AspNetCore.AttributeRouting.Attributes;
 using MQTTnet.AspNetCore.AttributeRouting.Routing;
 using MQTTnet.Server;
+using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 
@@ -80,5 +87,15 @@ public virtual Task BadMessage()
             MqttContext.ProcessPublish = false;
             return Task.CompletedTask;
         }
+
+        public T GetSessionItem<T>(string key)
+        {
+            return (T)MqttContext.SessionItems[key] ;
+        }
+
+        public T GetSessionItem<T>()
+        {
+            return (T)MqttContext.SessionItems[nameof(T)];
+        }
     }
 }