MsgCache更新

HybirdFrameworkDriver/Common/MsgCache.cs

@@ -36,12 +36,48 @@ public class MsgCache<T, TReq, TResp>
     {
         _dictionary.Remove(MsgKey + key, out var value);
     }
-    
-    
 }
 
 public class MsgPair<TReq, TResp>
 {
-    public TReq? Req { get; set; }
+    private readonly ManualResetEvent _lock = new(false);
-    public TResp? Resp { get; set; }
+    private TReq? _req;
+
+    public TReq? Req
+    {
+        get => _req;
+        set
+        {
+            _req = value;
+            ClearResp();
+        }
+    }
+
+    private TResp? _resp;
+
+    public void ClearResp()
+    {
+        _resp = default;
+    }
+
+    public void SetResp(TResp? resp)
+    {
+        _resp = resp;
+        _lock.Set();
+        _lock.Reset();
+    }
+
+    public TResp? GetResp(TimeSpan? timeSpan = default)
+    {
+        if (timeSpan != null)
+        {
+            _lock.WaitOne(timeSpan.Value);
+        }
+        else
+        {
+            _lock.WaitOne();
+        }
+
+        return _resp;
+    }
 }

Service/Cloud/Client/CloudClient.cs

@@ -347,7 +347,6 @@ public class CloudClient : IMqttClientConnectedHandler, IMqttApplicationMessageR
     public void SendVehicleCertification(VehicleCertification vehicleCertification)
     {
         this.CarAuth.Req = vehicleCertification;
-        this.CarAuth.Resp = null;
         this.Publish(vehicleCertification);
     }
 

Service/Cloud/Handler/CarAuthResHandler.cs

@@ -18,6 +18,6 @@ public class CarAuthResHandler : IBaseHandler
     public void Handle(string t)
     {
         VehicleCertificationResp? resp = JsonConvert.DeserializeObject<VehicleCertificationResp>(t);
-        CloudClientMgr.CloudClient.CarAuth.Resp = resp;
+        CloudClientMgr.CloudClient.CarAuth.SetResp(resp);
     }
 }