服务关闭OnHandleIntent mqtt

Question

我有一个后台服务，它初始化system.net.mqtt库，并等待来自mqtt的消息。我有一个ptoblem的OnHandleIntent inizize图书馆和关闭服务！！在开机启动时，又没有接收到消息，为什么？？

 

[BroadcastReceiver(Label = "StartReceiver",  Enabled = true)]
[IntentFilter(new[] { Intent.ActionBootCompleted })]
public class StartReceiver : BroadcastReceiver
{
    public override void OnReceive(Context context, Intent intent)
    {
        Toast.MakeText(context, "i got it " , ToastLength.Long).Show();

        if (intent.Action == Intent.ActionBootCompleted)
        {
            var serviceIntent = new Intent(context, typeof(ServiceTermoCoperta));
            serviceIntent.AddFlags(ActivityFlags.NewTask);
            context.StartService(serviceIntent);
        }
    }
}

[Service(Exported = true, Enabled = true)]
public class ServiceTermoCoperta : IntentService
{
    public IMqttClient clientMQTT;


    [return: GeneratedEnum]
    public override StartCommandResult OnStartCommand(Intent intent, [GeneratedEnum] StartCommandFlags flags, int startId)
    {
        base.OnStartCommand( intent,  flags, startId);
        return StartCommandResult.Sticky;
    }

    protected override async void OnHandleIntent(Intent intent)
    {

        var mqttConfig = new MqttConfiguration
        {
            Port = 1883,
            MaximumQualityOfService = MqttQualityOfService.ExactlyOnce,
            KeepAliveSecs = 60,
            //WaitTimeoutSecs = 50,
            //ConnectionTimeoutSecs = 50,
            AllowWildcardsInTopicFilters = true
        };

        clientMQTT = await MqttClient.CreateAsync("iot.pushetta.com", mqttConfig);


        new Handler(Looper.MainLooper).Post(() => {

            if (clientMQTT != null)
            {
                clientMQTT.ConnectAsync(new MqttClientCredentials("pusmdm476u47r", "xxxxxx", "aaaaaa")).Wait();

                clientMQTT.SubscribeAsync("/pushetta.com/channels/tteste", MqttQualityOfService.AtLeastOnce).Wait();

                clientMQTT.MessageStream.Subscribe(msg =>
                {
                    string bs = msg.Topic + " " + Encoding.Default.GetString(msg.Payload);

                    //Send Data 

                    Intent localIntent = new Intent(Constants.BROADCAST_ACTION).PutExtra(Constants.EXTENDED_DATA_STATUS, bs);
                    // Broadcasts the Intent to receivers in this app.
                    SendBroadcast(localIntent);
                });
            }
        });
    }
}

Answer 1

intentservice属于计算服务，您可以使用它来完成需要很长时间的工作。

>

intentservice将打开另一个不同于UI线程的工作线程来完成工作。

工作完成后，intentservice将自动停止。

所以我建议您使用服务来实现您的目标。