93 lines
3.5 KiB
C#
93 lines
3.5 KiB
C#
using Infrastructure.CloudSdk.mqttmessagecenter;
|
|
using NPOI.SS.Formula.Functions;
|
|
using NuGet.Packaging;
|
|
using OpenAuth.App.ServiceApp;
|
|
using System.Security.Cryptography;
|
|
|
|
namespace OpenAuth.WebApi.Model.mqtt
|
|
{
|
|
public class MqttHostedService : IHostedService
|
|
{
|
|
private readonly IServiceProvider _serviceProvider;
|
|
private readonly MqttMessageCenter _mqttCenter;
|
|
private readonly AirportMaintenanceApp _app;
|
|
|
|
|
|
public MqttHostedService(IServiceProvider serviceProvider, MqttMessageCenter mqttCenter, AirportMaintenanceApp app)
|
|
{
|
|
_serviceProvider = serviceProvider;
|
|
_mqttCenter = mqttCenter;
|
|
_app = app;
|
|
}
|
|
|
|
public async Task StartAsync(CancellationToken cancellationToken)
|
|
{
|
|
using var scope = _serviceProvider.CreateScope();
|
|
var handlers = scope.ServiceProvider.GetServices<IMqttMessageHandler>();
|
|
// 创建配置构建器
|
|
var builder = new ConfigurationBuilder()
|
|
.SetBasePath(Directory.GetCurrentDirectory())
|
|
.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
|
|
.AddJsonFile(
|
|
$"appsettings.{Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Development"}.json",
|
|
optional: true)
|
|
.AddEnvironmentVariables();
|
|
// 构建配置
|
|
var configuration = builder.Build();
|
|
// 读取连接字符串
|
|
var serverIp = configuration["MQTT:Server"];
|
|
var port = configuration["MQTT:Port"];
|
|
var username = configuration["MQTT:UserName"];
|
|
var password = configuration["MQTT:Password"];
|
|
|
|
await _mqttCenter.InitializeAsync(
|
|
handlers,
|
|
server: serverIp,
|
|
port: int.Parse(port),
|
|
clientId: Guid.NewGuid().ToString(),
|
|
username: username,
|
|
password: password
|
|
);
|
|
////查询网关，订阅主题
|
|
//var topics = new List<string>();
|
|
//var gatewayList = await _app.GetGatewaysnList();
|
|
|
|
//foreach (var gateway in gatewayList)
|
|
//{
|
|
// topics.AddRange(new[]
|
|
// {
|
|
// $"thing/product/{gateway}/osd",
|
|
// $"thing/product/{gateway}/events",
|
|
// $"thing/product/{gateway}/requests",
|
|
// $"thing/product/{gateway}/services_reply",
|
|
// //$"thing/product/{gateway}/drc/up",
|
|
// //$"thing/product/{gateway}/drc/down",
|
|
// $"sys/product/{gateway}/status"
|
|
// });
|
|
//}
|
|
//var snList = await _app.GetUavSn();
|
|
|
|
//foreach (var sn in snList)
|
|
//{
|
|
// topics.AddRange(new[]
|
|
// {
|
|
// // $"thing/product/1581F8HGX254V00A0BUY/osd",
|
|
// $"thing/product/{sn}/osd"
|
|
// });
|
|
//}
|
|
string[] topicList =
|
|
{
|
|
"thing/product/+/services_reply",
|
|
"thing/product/+/events",
|
|
"thing/product/+/requests",
|
|
"thing/product/+/osd",
|
|
"sys/product/+/status",
|
|
"thing/product/+/control-operation"
|
|
};
|
|
await _mqttCenter.SubscribeAsync(topicList);
|
|
}
|
|
|
|
public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
|
|
}
|
|
}
|