更改Redis 链接

PLC.Siemens/Communication/IsoSocket.cs

@@ -80,7 +80,7 @@ namespace PLC.Siemens.Communication
             }
             catch (Exception ex)
             {
-                OnMessage("Connect", "连接异常:{ex.Message}");
+                OnMessage("Connect", $"连接异常:{ex.Message}");
                 return false;
             }
             finally

Projects/永冠OPP/WCS.Service/ProtocolProxy.cs

@@ -97,6 +97,7 @@ namespace WCS.Service
         private static RedisClient Redis;
         public static RedisClient YG150Redis;
         public static RedisClient YGWMS150Redis;
+        public static RedisClient YGWCS150Redis;
 
         static ProtocolProxy()
         {
@@ -116,6 +117,17 @@ namespace WCS.Service
 
             YG150Redis = new RedisClient("192.168.249.150,password=123456,database=1");
             YGWMS150Redis = new RedisClient("192.168.249.150,password=123456,database=0");
+            YGWCS150Redis = new RedisClient("192.168.249.150,password=123456,database=10");
+            YGWCS150Redis.Serialize = obj =>
+            {
+                var bytes = MessagePackSerializer.Serialize(obj);
+                return bytes;
+            };
+            YGWCS150Redis.DeserializeRaw = (bytes, type) =>
+            {
+                var obj = MessagePackSerializer.Deserialize(type, bytes);
+                return obj;
+            };
         }
 
         //static ConcurrentDictionary<string, DeviceData> Datas = new ConcurrentDictionary<string, DeviceData>();
@@ -202,17 +214,20 @@ namespace WCS.Service
                 var sw = new Stopwatch();
                 sw.Start();
                 Redis.Set(nameof(DeviceDataPack), pack);
+                YGWCS150Redis.Set(nameof(DeviceDataPack), pack);
                 sw.Stop();
                 Console.ForegroundColor = ConsoleColor.Blue;
                 Console.WriteLine($"Redis耗时{sw.ElapsedMilliseconds}");
                 Console.ResetColor();
 
                 Redis.RPush("Packs", pack);
+                YGWCS150Redis.RPush("Packs", pack);
 
                 var len = Redis.LLen("Packs");
                 if (len > 150000)
                 {
                     Redis.LTrim("Packs", 20000, len);
+                    YGWCS150Redis.LTrim("Packs", 20000, len);
                 }
 
                 foreach (var data in AllDatas)