38 lines
1.2 KiB
C#
38 lines
1.2 KiB
C#
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/8UUXN5400A079H/services",
|
|
"thing/product/8UUXN5400A079H/events1"
|
|
);
|
|
}
|
|
|
|
public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
|
|
}
|
|
}
|