From 4c686e6b5706880fbaf6919c024c0a324c9b4506 Mon Sep 17 00:00:00 2001 From: XuJiacheng Date: Tue, 25 Nov 2025 17:30:36 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E5=88=9D=E5=A7=8B=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- BLWLogProduce/Models/WaiBuJianKong.cs | 10 +++++ BLWLogProduce/Para_copy.yaml | 25 +++++++++++ BLWLogProduce/Services/KafkaProduce.cs | 59 ++++++++++++++++++++++++++ BLWLogProduce/Services/MyTimer.cs | 14 +++++- BLWLogServer.sln | 54 ----------------------- ConsoleApp2/ConsoleApp2.csproj | 1 - 6 files changed, 107 insertions(+), 56 deletions(-) diff --git a/BLWLogProduce/Models/WaiBuJianKong.cs b/BLWLogProduce/Models/WaiBuJianKong.cs index 68404bb..3671ca6 100644 --- a/BLWLogProduce/Models/WaiBuJianKong.cs +++ b/BLWLogProduce/Models/WaiBuJianKong.cs @@ -36,6 +36,8 @@ namespace BLWLogProduce.Models public static string UDPPackage_TianMaoQueryAll = "UDPPackage_TianMaoQueryAll"; public static string UDPPackage_TianMaoCONTROL = "UDPPackage_TianMaoCONTROL"; + + public static string TotalErrorPackageReceiveCount = "TotalErrorPackageReceiveCount"; } public class grafana_data { @@ -57,5 +59,13 @@ namespace BLWLogProduce.Models public string? XD_Ctr_D { get; set; } = "0"; public string? XD_Ctr_C { get; set; } = "0"; public string? Hivi_Ctr { get; set; } = "0"; + public int? Process_Error { get; set; } = 0; + public int? Process_TH1 { get; set; } = 0; + public int? Process_TH2 { get; set; } = 0; + public int? Process_TH3 { get; set; } = 0; + public int? Process_TH4 { get; set; } = 0; + public int? Process_TH5 { get; set; } = 0; + + public string? TotalErrorPackageReceiveCount { get; set; } = "0" ; } } diff --git a/BLWLogProduce/Para_copy.yaml b/BLWLogProduce/Para_copy.yaml index 845e256..18892eb 100644 --- a/BLWLogProduce/Para_copy.yaml +++ b/BLWLogProduce/Para_copy.yaml @@ -58,3 +58,28 @@ Hivi_Ctr {14} # HELP UDP_Cnt_Wireshark Total UDP packets captured and analyzed by Wireshark. # TYPE UDP_Cnt_Wireshark gauge UDP_Cnt_Wireshark {15} + +# HELP Process_Error counte. +# TYPE Process_Error gauge +Process_Error {21} + +# HELP Process_TH1 counte. +# TYPE Process_TH1 gauge +Process_TH1 {16} + +# HELP Process_TH2 counte. +# TYPE Process_TH2 gauge +Process_TH2 {17} + +# HELP Process_TH3 counte. +# TYPE Process_TH3 gauge +Process_TH3 {18} + +# HELP Process_TH4 counte. +# TYPE Process_TH4 gauge +Process_TH4 {19} + +# HELP Process_TH5 counte. +# TYPE Process_TH5 gauge +Process_TH5 {20} + diff --git a/BLWLogProduce/Services/KafkaProduce.cs b/BLWLogProduce/Services/KafkaProduce.cs index f63cfc6..7fe12eb 100644 --- a/BLWLogProduce/Services/KafkaProduce.cs +++ b/BLWLogProduce/Services/KafkaProduce.cs @@ -70,6 +70,60 @@ namespace BLWLogProduce.Services } })); + + ///udp 采集数据 + var xiaofei_fenxi = ("udp_package_consumer", new Action(async (args) => + { + try + { + string data = args.Body; + string[] aaa = data.Split("#"); + if (aaa.Length != 2) + { + return; + } + string key = aaa[0]; + string valuedata = aaa[1]; + if (key.Equals("task1")) + { + var ts = WaiBuJianKong.data.Process_TH1; + int? count = ts + 1; + WaiBuJianKong.data.Process_TH1 = count; + } + else if (key.Equals("task2")) + { + var ts = WaiBuJianKong.data.Process_TH2; + int? count = ts + 1; + WaiBuJianKong.data.Process_TH2 = count; + } + else if (key.Equals("task3")) + { + var ts = WaiBuJianKong.data.Process_TH3; + int? count = ts + 1; + WaiBuJianKong.data.Process_TH3 = count; + } + else if (key.Equals("task4")) + { + var ts = WaiBuJianKong.data.Process_TH4; + int? count = ts + 1; + WaiBuJianKong.data.Process_TH4= count; + } + else if (key.Equals("task5")) + { + var ts = WaiBuJianKong.data.Process_TH5; + int? count = ts + 1; + WaiBuJianKong.data.Process_TH5 = count; + } + else + { + + } + } + catch (Exception) + { + + } + })); ///udp 采集数据 var DingYue = ("redis-udppackage", new Action(async (args) => { @@ -152,6 +206,10 @@ namespace BLWLogProduce.Services { WaiBuJianKong.data.TM_Ctr_C = countsa; } + else if (usa.CommandType.Equals(WaiBuJianKong.TotalErrorPackageReceiveCount)) + { + WaiBuJianKong.data.TotalErrorPackageReceiveCount = countsa; + } } @@ -640,6 +698,7 @@ namespace BLWLogProduce.Services CSRedisCacheHelper.redis3.Subscribe(wireshark); + CSRedisCacheHelper.redis3.Subscribe(xiaofei_fenxi); //这两个是统计 CSRedisCacheHelper.redis3.Subscribe(DingYue); diff --git a/BLWLogProduce/Services/MyTimer.cs b/BLWLogProduce/Services/MyTimer.cs index 7d5a45e..73d38f5 100644 --- a/BLWLogProduce/Services/MyTimer.cs +++ b/BLWLogProduce/Services/MyTimer.cs @@ -39,7 +39,13 @@ namespace BLWLogProduce.Services .Replace("{8}", df.WebUser) .Replace("{9}", df.Energy) .Replace("{10}", df.RCU_OE) - .Replace("{15}",df.WireShark_UDPCapCount); + .Replace("{15}", df.WireShark_UDPCapCount) + .Replace("{16}", df.Process_TH1.ToString()) + .Replace("{17}", df.Process_TH2.ToString()) + .Replace("{18}", df.Process_TH3.ToString()) + .Replace("{19}", df.Process_TH4.ToString()) + .Replace("{20}", df.Process_TH5.ToString()) + .Replace("{21}", df.TotalErrorPackageReceiveCount); int a = 0; int b = 0; @@ -65,6 +71,12 @@ namespace BLWLogProduce.Services WanBuJianKong(NewStringData, "1.txt"); File.WriteAllText("2.txt", NewStringData, Encoding.UTF8); Console.WriteLine("here"); + WaiBuJianKong.data.Process_Error = 0; + WaiBuJianKong.data.Process_TH1 = 0; + WaiBuJianKong.data.Process_TH2 = 0; + WaiBuJianKong.data.Process_TH3 = 0; + WaiBuJianKong.data.Process_TH4 = 0; + WaiBuJianKong.data.Process_TH5 = 0; } catch (Exception ex) { diff --git a/BLWLogServer.sln b/BLWLogServer.sln index 0ed1f42..2c6999e 100644 --- a/BLWLogServer.sln +++ b/BLWLogServer.sln @@ -17,12 +17,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "心跳维持", "心跳维 EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "UseSQLQueryData", "UseSQLQueryData\UseSQLQueryData.csproj", "{10F5F2CB-A414-43DB-A99A-68081F2800FC}" EndProject -Project("{F2A71F9B-5D33-465A-A702-920D77279786}") = "guolv", "guolv\guolv.fsproj", "{37EE528E-A087-424D-B8B9-5DDC33FBD48A}" -EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsoleApp2", "ConsoleApp2\ConsoleApp2.csproj", "{07B30240-4F9E-429F-A379-41CB26755B37}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsoleApp3", "ConsoleApp3\ConsoleApp3.csproj", "{03733DB0-C0EC-40DA-8EB3-8C792D6937A4}" -EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "回收", "回收\回收.csproj", "{72F978EB-70A1-44EC-9C20-668626CC554A}" EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DAL", "DAL\DAL.csproj", "{CBBE945C-3CA3-4718-99CD-EEA4C8A9C2D1}" @@ -31,28 +27,14 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "duoge", "duoge\duoge.csproj EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Faster", "Faster\Faster.csproj", "{F2695AB4-03C7-4F5F-B040-F9443730F082}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyNLua", "MyNLua\MyNLua.csproj", "{088CF6E8-C26C-44E1-9874-ABC7EF627AF8}" -EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyErl", "MyErl\MyErl.csproj", "{191BC89F-2A03-4422-A2A0-327016B6971F}" -EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "消费", "消费\消费.csproj", "{9E50411B-77D4-4675-8F3A-F6245E51F9A8}" EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "mypwsh", "mypwsh\mypwsh.csproj", "{FAEDFC96-E7AE-46EF-91BE-9587CE98DA65}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ApiService", "ApiService\ApiService.csproj", "{9E3EF7AE-7049-44F2-82C8-C30FE97C172F}" -EndProject -Project("{F2A71F9B-5D33-465A-A702-920D77279786}") = "FDemo", "FDemo\FDemo.fsproj", "{69FEBEBD-5BC4-4DFE-8622-0C1CF49B6652}" -EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyFaster", "MyFaster\MyFaster.csproj", "{A10993F0-828F-4ADF-A226-49C438D83FA7}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FasterClient", "FasterClient\FasterClient.csproj", "{C88D6C3D-46C9-4382-A3D3-A933CCFB8748}" -EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyFunctioncache", "MyFunctioncache\MyFunctioncache.csproj", "{5E42AFEC-5EFC-4001-AAA0-88ADFC2F1890}" EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FanShe", "FanShe\FanShe.csproj", "{8186F600-16FE-4169-8609-31ECB6685FBF}" -EndProject -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WebApplication1", "WebApplication1\WebApplication1.csproj", "{8D19D452-2287-401B-A46A-2768B17010F7}" -EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -87,18 +69,10 @@ Global {10F5F2CB-A414-43DB-A99A-68081F2800FC}.Debug|Any CPU.Build.0 = Debug|Any CPU {10F5F2CB-A414-43DB-A99A-68081F2800FC}.Release|Any CPU.ActiveCfg = Release|Any CPU {10F5F2CB-A414-43DB-A99A-68081F2800FC}.Release|Any CPU.Build.0 = Release|Any CPU - {37EE528E-A087-424D-B8B9-5DDC33FBD48A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {37EE528E-A087-424D-B8B9-5DDC33FBD48A}.Debug|Any CPU.Build.0 = Debug|Any CPU - {37EE528E-A087-424D-B8B9-5DDC33FBD48A}.Release|Any CPU.ActiveCfg = Release|Any CPU - {37EE528E-A087-424D-B8B9-5DDC33FBD48A}.Release|Any CPU.Build.0 = Release|Any CPU {07B30240-4F9E-429F-A379-41CB26755B37}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {07B30240-4F9E-429F-A379-41CB26755B37}.Debug|Any CPU.Build.0 = Debug|Any CPU {07B30240-4F9E-429F-A379-41CB26755B37}.Release|Any CPU.ActiveCfg = Release|Any CPU {07B30240-4F9E-429F-A379-41CB26755B37}.Release|Any CPU.Build.0 = Release|Any CPU - {03733DB0-C0EC-40DA-8EB3-8C792D6937A4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {03733DB0-C0EC-40DA-8EB3-8C792D6937A4}.Debug|Any CPU.Build.0 = Debug|Any CPU - {03733DB0-C0EC-40DA-8EB3-8C792D6937A4}.Release|Any CPU.ActiveCfg = Release|Any CPU - {03733DB0-C0EC-40DA-8EB3-8C792D6937A4}.Release|Any CPU.Build.0 = Release|Any CPU {72F978EB-70A1-44EC-9C20-668626CC554A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {72F978EB-70A1-44EC-9C20-668626CC554A}.Debug|Any CPU.Build.0 = Debug|Any CPU {72F978EB-70A1-44EC-9C20-668626CC554A}.Release|Any CPU.ActiveCfg = Release|Any CPU @@ -115,14 +89,6 @@ Global {F2695AB4-03C7-4F5F-B040-F9443730F082}.Debug|Any CPU.Build.0 = Debug|Any CPU {F2695AB4-03C7-4F5F-B040-F9443730F082}.Release|Any CPU.ActiveCfg = Release|Any CPU {F2695AB4-03C7-4F5F-B040-F9443730F082}.Release|Any CPU.Build.0 = Release|Any CPU - {088CF6E8-C26C-44E1-9874-ABC7EF627AF8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {088CF6E8-C26C-44E1-9874-ABC7EF627AF8}.Debug|Any CPU.Build.0 = Debug|Any CPU - {088CF6E8-C26C-44E1-9874-ABC7EF627AF8}.Release|Any CPU.ActiveCfg = Release|Any CPU - {088CF6E8-C26C-44E1-9874-ABC7EF627AF8}.Release|Any CPU.Build.0 = Release|Any CPU - {191BC89F-2A03-4422-A2A0-327016B6971F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {191BC89F-2A03-4422-A2A0-327016B6971F}.Debug|Any CPU.Build.0 = Debug|Any CPU - {191BC89F-2A03-4422-A2A0-327016B6971F}.Release|Any CPU.ActiveCfg = Release|Any CPU - {191BC89F-2A03-4422-A2A0-327016B6971F}.Release|Any CPU.Build.0 = Release|Any CPU {9E50411B-77D4-4675-8F3A-F6245E51F9A8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {9E50411B-77D4-4675-8F3A-F6245E51F9A8}.Debug|Any CPU.Build.0 = Debug|Any CPU {9E50411B-77D4-4675-8F3A-F6245E51F9A8}.Release|Any CPU.ActiveCfg = Release|Any CPU @@ -131,34 +97,14 @@ Global {FAEDFC96-E7AE-46EF-91BE-9587CE98DA65}.Debug|Any CPU.Build.0 = Debug|Any CPU {FAEDFC96-E7AE-46EF-91BE-9587CE98DA65}.Release|Any CPU.ActiveCfg = Release|Any CPU {FAEDFC96-E7AE-46EF-91BE-9587CE98DA65}.Release|Any CPU.Build.0 = Release|Any CPU - {9E3EF7AE-7049-44F2-82C8-C30FE97C172F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {9E3EF7AE-7049-44F2-82C8-C30FE97C172F}.Debug|Any CPU.Build.0 = Debug|Any CPU - {9E3EF7AE-7049-44F2-82C8-C30FE97C172F}.Release|Any CPU.ActiveCfg = Release|Any CPU - {9E3EF7AE-7049-44F2-82C8-C30FE97C172F}.Release|Any CPU.Build.0 = Release|Any CPU - {69FEBEBD-5BC4-4DFE-8622-0C1CF49B6652}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {69FEBEBD-5BC4-4DFE-8622-0C1CF49B6652}.Debug|Any CPU.Build.0 = Debug|Any CPU - {69FEBEBD-5BC4-4DFE-8622-0C1CF49B6652}.Release|Any CPU.ActiveCfg = Release|Any CPU - {69FEBEBD-5BC4-4DFE-8622-0C1CF49B6652}.Release|Any CPU.Build.0 = Release|Any CPU {A10993F0-828F-4ADF-A226-49C438D83FA7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {A10993F0-828F-4ADF-A226-49C438D83FA7}.Debug|Any CPU.Build.0 = Debug|Any CPU {A10993F0-828F-4ADF-A226-49C438D83FA7}.Release|Any CPU.ActiveCfg = Release|Any CPU {A10993F0-828F-4ADF-A226-49C438D83FA7}.Release|Any CPU.Build.0 = Release|Any CPU - {C88D6C3D-46C9-4382-A3D3-A933CCFB8748}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {C88D6C3D-46C9-4382-A3D3-A933CCFB8748}.Debug|Any CPU.Build.0 = Debug|Any CPU - {C88D6C3D-46C9-4382-A3D3-A933CCFB8748}.Release|Any CPU.ActiveCfg = Release|Any CPU - {C88D6C3D-46C9-4382-A3D3-A933CCFB8748}.Release|Any CPU.Build.0 = Release|Any CPU {5E42AFEC-5EFC-4001-AAA0-88ADFC2F1890}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {5E42AFEC-5EFC-4001-AAA0-88ADFC2F1890}.Debug|Any CPU.Build.0 = Debug|Any CPU {5E42AFEC-5EFC-4001-AAA0-88ADFC2F1890}.Release|Any CPU.ActiveCfg = Release|Any CPU {5E42AFEC-5EFC-4001-AAA0-88ADFC2F1890}.Release|Any CPU.Build.0 = Release|Any CPU - {8186F600-16FE-4169-8609-31ECB6685FBF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {8186F600-16FE-4169-8609-31ECB6685FBF}.Debug|Any CPU.Build.0 = Debug|Any CPU - {8186F600-16FE-4169-8609-31ECB6685FBF}.Release|Any CPU.ActiveCfg = Release|Any CPU - {8186F600-16FE-4169-8609-31ECB6685FBF}.Release|Any CPU.Build.0 = Release|Any CPU - {8D19D452-2287-401B-A46A-2768B17010F7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {8D19D452-2287-401B-A46A-2768B17010F7}.Debug|Any CPU.Build.0 = Debug|Any CPU - {8D19D452-2287-401B-A46A-2768B17010F7}.Release|Any CPU.ActiveCfg = Release|Any CPU - {8D19D452-2287-401B-A46A-2768B17010F7}.Release|Any CPU.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE diff --git a/ConsoleApp2/ConsoleApp2.csproj b/ConsoleApp2/ConsoleApp2.csproj index 030515f..52fbffe 100644 --- a/ConsoleApp2/ConsoleApp2.csproj +++ b/ConsoleApp2/ConsoleApp2.csproj @@ -15,7 +15,6 @@ -