LASAPlatform/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs

using Infrastructure.CloudSdk.mqttmessagecenter;

namespace OpenAuth.WebApi.Model.mqtt
{
    public class MqttHostedService : IHostedService
    {
        private readonly IServiceProvider _serviceProvider;

        public MqttHostedService(IServiceProvider serviceProvider)
        {
            _serviceProvider = serviceProvider;
        }

        public async Task StartAsync(CancellationToken cancellationToken)
        {
            using var scope = _serviceProvider.CreateScope();
            var handlers = scope.ServiceProvider.GetServices<IMqttMessageHandler>();

            var mqttCenter = new MqttMessageCenter(
                handlers,
                server: "175.27.168.120",
                port: 6011,
                clientId: "mqtt_client_1581",
                username: "sdhc",
                password: ""
            );

            await mqttCenter.ConnectAndSubscribeAsync(
            // "thing/product/8UUXN5400A079H/osd",
             "thing/product/1581F8HGX254V00A0BUY/osd"
            // "thing/product/8UUXN5400A079H/services",
            //"thing/product/8UUXN5400A079H/services_reply"
            //"thing/product/8UUXN5400A079H/requests",
            //"thing/product/8UUXN5400A079H/services_reply"
            //"thing/product/8UUXN5400A079H/events"
            );
        }

        public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
    }
}