From 2b4e179cf9485d713c3ac3cff1b08f9fa543f585 Mon Sep 17 00:00:00 2001 From: huangxianguo Date: Fri, 12 Jul 2024 16:22:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=BF=83=E8=B7=B3=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- MasstransferExporter/Program.cs | 3 ++- MasstransferExporter/StatExporter/HeartbeatExporter.cs | 10 +++++++--- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/MasstransferExporter/Program.cs b/MasstransferExporter/Program.cs index 18cf2d3..349542a 100644 --- a/MasstransferExporter/Program.cs +++ b/MasstransferExporter/Program.cs @@ -1,5 +1,6 @@ using MasstransferCommunicate.Mqtt.Client; using MasstransferExporter.DataExporter; +using MasstransferExporter.Stat; using MasstransferInfrastructure.Mqtt.Model; class Program @@ -15,7 +16,7 @@ class Program await MessageQueueHelper.InitConnect(options); - await SystemParamsService.SystemParamsExporter(); + HeartbeatExporter.HeartBeat(); Console.WriteLine("按任意键退出"); diff --git a/MasstransferExporter/StatExporter/HeartbeatExporter.cs b/MasstransferExporter/StatExporter/HeartbeatExporter.cs index d7ceaef..a23f4de 100644 --- a/MasstransferExporter/StatExporter/HeartbeatExporter.cs +++ b/MasstransferExporter/StatExporter/HeartbeatExporter.cs @@ -1,4 +1,6 @@ -using MasstransferCommon.Scheduler; +using MasstransferCommon.Model.Constant; +using MasstransferCommon.Scheduler; +using MasstransferCommunicate.Mqtt.Client; namespace MasstransferExporter.Stat; @@ -15,8 +17,10 @@ public class HeartbeatExporter JobScheduler.AddTask("HeartbeatExporter#StartHeartBeat", HeartBeat, 10000); } - private static void HeartBeat() + public static async void HeartBeat() { - + var data = new Dictionary(); + data["timestamp"] = DateTime.Now; + await MessageQueueHelper.Publish(Topics.HeartBeat, data); } } \ No newline at end of file