255 lines
10 KiB
C#
255 lines
10 KiB
C#
using Common;
|
||
using Commonlib;
|
||
using LogCap.Common;
|
||
using LogCap.Entity;
|
||
using Microsoft.Extensions.Caching.Memory;
|
||
using Microsoft.VisualBasic;
|
||
using MQTTnet;
|
||
using MQTTnet.Packets;
|
||
using MQTTnet.Protocol;
|
||
using NetMQ;
|
||
using NetMQ.Sockets;
|
||
using Newtonsoft.Json;
|
||
using Newtonsoft.Json.Linq;
|
||
using RestSharp;
|
||
using RestSharp.Authenticators.OAuth2;
|
||
using System.Collections;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using System.Timers;
|
||
|
||
namespace LogCap
|
||
{
|
||
public class Program
|
||
{
|
||
|
||
public static MemoryCache Cache = new MemoryCache(new MemoryCacheOptions { });
|
||
public static IMqttClient mqttClient { get; set; }
|
||
|
||
public static DateTime CurrentTime { get; set; }
|
||
|
||
public static int CurrentWangKaBianHao = 0;
|
||
public static void Main(string[] args)
|
||
{
|
||
|
||
var NQQ = DateTime.Now.ToString("mmss");
|
||
//var server = new ResponseSocket("@tcp://127.0.0.1:5556");
|
||
//while (true)
|
||
//{
|
||
// string frame = server.ReceiveFrameString();
|
||
// Console.WriteLine("Server received frame={0}", frame);
|
||
//}
|
||
//Console.ReadLine();
|
||
//string SSS = Guid.NewGuid().ToString("N");
|
||
//CurrentTime = DateTime.Now;
|
||
|
||
// var authenticator = new OAuth2AuthorizationRequestHeaderAuthenticator(
|
||
//"eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiI2NGZjYjhjMS1jZDZjLTRkMTktOTc3My05YzkxYmZhNjQ2YWQiLCJpYXQiOjE3NDEyNDczNDAsImV4cCI6MTc0MTI1ODE0MCwic2NoZW1hIjoibnhnXzcwNzA1OTEzX2VhcXoiLCJ1c2VyIjoiYWYwNzg3YTQtMmM2NC00NWRiLWEzMjktNzg0ZGYwZWRjOGZjIiwiZGVmYXVsdF9wcm9wZXJ0eSI6IjA3MTY3M2IzLWQ4OTMtNDQwYi1iM2YwLTY0YTBkOTY0ZWIyOSIsInRvX3JlZnJlc2giOnRydWUsInR5cGUiOiJhY2Nlc3MiLCJpbml0X2Vwb2NoIjoxNzQxMjQ3MzQwLCJtZWRpdW1fY29kZSI6IldFQiJ9.4k2GE08J3MZQIgRKOx5dYmeL1vSnqDSC11MLpkDNjqQ", "token");
|
||
// var options = new RestClientOptions("https://api.fcs1cloud.com")
|
||
// {
|
||
// //Authenticator = authenticator
|
||
|
||
// };
|
||
// var client = new RestClient(options);
|
||
|
||
// //string str = Newtonsoft.Json.JsonConvert.SerializeObject(mm);
|
||
// //Console.WriteLine("发送MQTT的数据为：" + str);
|
||
// var request1 = new RestRequest("/api-secure/job/request", Method.Post);
|
||
// request1.AddHeader("token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiI2NGZjYjhjMS1jZDZjLTRkMTktOTc3My05YzkxYmZhNjQ2YWQiLCJpYXQiOjE3NDEyNDczNDAsImV4cCI6MTc0MTI1ODE0MCwic2NoZW1hIjoibnhnXzcwNzA1OTEzX2VhcXoiLCJ1c2VyIjoiYWYwNzg3YTQtMmM2NC00NWRiLWEzMjktNzg0ZGYwZWRjOGZjIiwiZGVmYXVsdF9wcm9wZXJ0eSI6IjA3MTY3M2IzLWQ4OTMtNDQwYi1iM2YwLTY0YTBkOTY0ZWIyOSIsInRvX3JlZnJlc2giOnRydWUsInR5cGUiOiJhY2Nlc3MiLCJpbml0X2Vwb2NoIjoxNzQxMjQ3MzQwLCJtZWRpdW1fY29kZSI6IldFQiJ9.4k2GE08J3MZQIgRKOx5dYmeL1vSnqDSC11MLpkDNjqQ");
|
||
|
||
// //注意方法是POST
|
||
// //两个参数名字必须是 topic 和payload ，区分大小写的
|
||
// //Console.WriteLine("Topic: " + debug_log_report_mqtt_topic);
|
||
|
||
|
||
var list = CSRedisCacheHelper.Get<List<Monitor_Host>>(CacheKey.Key);
|
||
Cache.Set<List<Monitor_Host>>(CacheKey.Key, list);
|
||
|
||
//端点监控
|
||
var QQQ = CSRedisCacheHelper.Get<List<MonitorEndPoint>>(CacheKey.MonitorEndPointList);
|
||
Cache.Set<List<MonitorEndPoint>>(CacheKey.MonitorEndPointList, QQQ);
|
||
|
||
_ = Start_MqttClient();
|
||
System.Timers.Timer timer = new System.Timers.Timer();
|
||
|
||
timer.Elapsed += Timer_Elapsed;
|
||
timer.Interval = 10000;
|
||
timer.Enabled = true;
|
||
timer.Start();
|
||
|
||
System.Timers.Timer timer1 = new System.Timers.Timer();
|
||
timer1.Elapsed += Timer1_Elapsed;
|
||
|
||
timer1.Interval = 60000;
|
||
timer1.Enabled = true;
|
||
timer1.Start();
|
||
|
||
PubRepository.GetDeviceList();
|
||
|
||
Console.WriteLine("选择你要监控的网卡");
|
||
//string whitchone = Console.ReadLine();
|
||
|
||
string whitchone = "3";
|
||
int.TryParse(whitchone, out CurrentWangKaBianHao);
|
||
|
||
|
||
PubRepository.StartMonitor(CurrentWangKaBianHao);
|
||
Console.WriteLine("正在监控中");
|
||
Console.WriteLine("……………………………………………………………………………………………………………………………………………………………………………………");
|
||
Console.WriteLine("按回车键就结束");
|
||
string? nnn = Console.ReadLine();
|
||
PubRepository.StopMonitor();
|
||
timer.Dispose();
|
||
}
|
||
|
||
private static async void Timer1_Elapsed(object? sender, ElapsedEventArgs e)
|
||
{
|
||
try
|
||
{
|
||
Console.WriteLine("现在的数量是："+LogExecute.TotalCountGlobal);
|
||
long lla= Interlocked.Read(ref LogExecute.TotalCountGlobal);
|
||
CSRedisCacheHelper.Publish("wireshark-cap-udp-totalcount",lla.ToString());
|
||
Interlocked.Exchange(ref LogExecute.TotalCountGlobal, 0);
|
||
}
|
||
catch (Exception)
|
||
{
|
||
|
||
}
|
||
}
|
||
|
||
private static async Task MqttClient_DisconnectedAsync(MqttClientDisconnectedEventArgs arg)
|
||
{
|
||
Console.WriteLine("断线重连了");
|
||
await Task.Delay(3000);
|
||
await Start_MqttClient();
|
||
}
|
||
|
||
private static Task MqttClient_ApplicationMessageReceivedAsync(MqttApplicationMessageReceivedEventArgs arg)
|
||
{
|
||
try
|
||
{
|
||
var str = arg.ApplicationMessage.Payload;
|
||
|
||
string nnn = Encoding.UTF8.GetString(str);
|
||
Monitor_Host? vvv = JsonConvert.DeserializeObject<Monitor_Host>(nnn);
|
||
|
||
if (vvv != null)
|
||
{
|
||
string Key = string.Format("{0}_{1}", CacheKey.RoomIP_Port_Prefix, vvv.Key_HostNumber);
|
||
|
||
var takeMM = Program.Cache.Get<MonitorRedis>(Key);
|
||
if (takeMM != null)
|
||
{
|
||
string IP = takeMM.WWW_IP;
|
||
int Port = takeMM.WWW_Port;
|
||
string KeyHeartBeat = string.Format("{0}_{1}_{2}", CacheKey.RoomIP_Port_Prefix, IP, Port);
|
||
Program.Cache.Remove(KeyHeartBeat);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine("MqttClient_ApplicationMessageReceivedAsync: " + ex.Message);
|
||
}
|
||
return Task.CompletedTask;
|
||
}
|
||
|
||
private static async void Timer_Elapsed(object? sender, ElapsedEventArgs e)
|
||
{
|
||
|
||
try
|
||
{
|
||
Console.WriteLine("定时任务");
|
||
var list = CSRedisCacheHelper.Get<List<Monitor_Host>>(CacheKey.Key);
|
||
Cache.Set<List<Monitor_Host>>(CacheKey.Key, list);
|
||
if (list != null && list.Count != 0)
|
||
{
|
||
TimeSpan span = DateTime.Now - Program.CurrentTime;
|
||
if (span.TotalSeconds >= 35)
|
||
{
|
||
PubRepository.StopMonitor();
|
||
PubRepository.StartMonitor(CurrentWangKaBianHao);
|
||
}
|
||
}
|
||
|
||
//端点监控
|
||
var QQQ = CSRedisCacheHelper.Get<List<MonitorEndPoint>>(CacheKey.MonitorEndPointList);
|
||
Cache.Set<List<MonitorEndPoint>>(CacheKey.MonitorEndPointList, QQQ);
|
||
|
||
var hhh = await mqttClient.PublishStringAsync("/blw/heart/logcap", "heartbeat");
|
||
if (hhh.IsSuccess == false)
|
||
{
|
||
await Start_MqttClient();
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine("timer_elapsed: " + ex.Message);
|
||
}
|
||
}
|
||
|
||
async public static Task Start_MqttClient()
|
||
{
|
||
|
||
try
|
||
{
|
||
var mqttFactory = new MqttClientFactory();
|
||
|
||
string? ip = ReadConfig.Instance.MQTT_ServerIP;
|
||
int? port = ReadConfig.Instance.MQTT_ServerPort;
|
||
string? username = ReadConfig.Instance.MQTT_User;
|
||
string? pwd = ReadConfig.Instance.MQTT_PassWord;
|
||
|
||
//long lid = Tools.ToUnixTimestampBySeconds(DateTime.Now);
|
||
|
||
string lid = Guid.NewGuid().ToString("N");
|
||
|
||
string ID = $"logmonitor_{lid}";
|
||
mqttClient = mqttFactory.CreateMqttClient();
|
||
var mqttClientOptions = new MqttClientOptionsBuilder()
|
||
.WithClientId(ID)
|
||
.WithTcpServer(ip, port)
|
||
.WithCredentials(username, pwd)
|
||
.WithProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500)
|
||
.Build();
|
||
|
||
mqttClient.ApplicationMessageReceivedAsync += MqttClient_ApplicationMessageReceivedAsync;
|
||
mqttClient.DisconnectedAsync += MqttClient_DisconnectedAsync;
|
||
await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
|
||
|
||
//var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder()
|
||
// .WithTopicFilter("blw/logmonitor/delete/report")
|
||
// .Build();
|
||
|
||
//var nnn = new MqttTopicFilterBuilder().WithTopic("blw/logmonitor/delete/report");
|
||
|
||
var subscribeOptions = new MqttClientSubscribeOptions();
|
||
var topicFilter = new MqttTopicFilter
|
||
{
|
||
Topic = "blw/logmonitor/delete/report"
|
||
};
|
||
subscribeOptions.TopicFilters.Add(topicFilter);
|
||
await mqttClient.SubscribeAsync(subscribeOptions, CancellationToken.None);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine("Start_MqttClient: " + ex.Message);
|
||
}
|
||
}
|
||
}
|
||
|
||
public class GGH
|
||
{
|
||
public List<string> location_uuid { get; set; }
|
||
public List<GGJ> service_items { get; set; }
|
||
public string remark { get; set; }
|
||
public string assigned_to { get; set; }
|
||
public int user_type { get; set; }
|
||
}
|
||
public class GGJ
|
||
{
|
||
public string item_uuid { get; set; }
|
||
public int quantity { get; set; }
|
||
}
|
||
}
|