1.更新808模块代码

2.增加请求原包数据属性

src/JT808.DotNetty.sln

@@ -1,7 +1,7 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 16
-VisualStudioVersion = 16.0.28407.52
+# Visual Studio 15
+VisualStudioVersion = 15.0.28307.168
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "JT808.DotNetty", "JT808.DotNetty\JT808.DotNetty.csproj", "{80C7F67E-6B7C-4178-8726-ADD3695622DD}"
 EndProject

src/JT808.DotNetty/Handlers/JT808ServerHandler.cs

@@ -50,6 +50,9 @@ namespace JT808.DotNetty.Handlers
             try
             {
                 jT808SourcePackageDispatcher?.SendAsync(msg);
+                //在压力大的情况下可以只解析到头部
+                //然后根据具体的消息Id通过队列去进行消费
+                //JT808HeaderPackage jT808HeaderPackage = JT808Serializer.Deserialize<JT808HeaderPackage>(msg);
                 JT808Package jT808Package = JT808Serializer.Deserialize(msg);
                 jT808AtomicCounterService.MsgSuccessIncrement();
                 if (logger.IsEnabled(LogLevel.Debug))
@@ -60,7 +63,8 @@ namespace JT808.DotNetty.Handlers
                 Func<JT808Request, JT808Response> handlerFunc;
                 if (handler.HandlerDict.TryGetValue(jT808Package.Header.MsgId, out handlerFunc))
                 {
-                    JT808Response jT808Response = handlerFunc(new JT808Request(jT808Package));
+                    //JT808Response jT808Response = handlerFunc(new JT808Request(jT808HeaderPackage, msg));
+                    JT808Response jT808Response = handlerFunc(new JT808Request(jT808Package, msg));
                     if (jT808Response != null)
                     {
                         if (!jT808TransmitAddressFilterService.ContainsKey(ctx.Channel.RemoteAddress))

src/JT808.DotNetty/Metadata/JT808Request.cs

@@ -9,13 +9,17 @@ namespace JT808.DotNetty.Metadata
     {
         public JT808Package Package { get; set; }
 
+        public byte[] OriginalPackage { get;}
+
         public JT808Request()
         {
 
         }
-        public JT808Request(JT808Package package)
+
+        public JT808Request(JT808Package package, byte[] originalPackage)
         {
             Package = package;
+            OriginalPackage = originalPackage;
         }
     }
 }

src/JT808.Protocol

@@ -1 +1 @@
-Subproject commit 98d718a8d76527201c036f5f63157a21c594c88f
+Subproject commit 5c8215dcad9fb833743bd58431b8021647474c21