齐套出库

common/Tnb.Common/Redis/RedisData.cs

@@ -2,23 +2,37 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
+using System.Threading.Channels;
 using System.Threading.Tasks;
+using Aspose.Cells.Drawing;
 using CSRedis;
 using JNPF;
 using JNPF.Common.Cache;
 using JNPF.DependencyInjection;
 using Microsoft.Extensions.Options;
 using Newtonsoft.Json;
+using static CSRedis.CSRedisClient;
 
 namespace Tnb.Common.Redis
 {
     public class RedisData : ISingleton
     {
         private static CSRedisClient _instance;
+        public delegate void rcvMsgHandler(string Channel, string Body);
+        public event rcvMsgHandler rcvMsg;
         public RedisData()
         {
             RedisOptions _RedisOptions = App.GetConfig<RedisOptions>("Redis", true);
             _instance = new CSRedis.CSRedisClient(string.Format(_RedisOptions.RedisConnectionString, _RedisOptions.ip, _RedisOptions.port, _RedisOptions.password));
+
+            _instance.Subscribe(("devdata_change", msg =>
+            {
+                if (rcvMsg != null)
+                {
+                    rcvMsg(msg.Channel, msg.Body);
+                }
+            }
+            ));
         }
 
         /// <summary>
@@ -264,5 +278,7 @@ namespace Tnb.Common.Redis
             }
             return default(T);
         }
+
+
     }
 }