Android paho发布大延迟

Question

我试图用android编写一个应用程序来发布mqtt消息。我使用一个AsyncTask向我的代理发布，但有时我会有很大的延迟，我想是因为每次发布之前我都要连接到代理

@Override
protected Void doInBackground(String... params) {

    try {
        settings = new AppSettings(context);

        if (!settings.getBroker().isEmpty()) {

            client = new MqttClient(settings.getBroker(), MQTTService.ANDROID_ID, new MemoryPersistence());

            if (!settings.getUsername().isEmpty() || settings.getPassword().isEmpty()) {
                MqttConnectOptions options = new MqttConnectOptions();
                options.setUserName(settings.getUsername());
                options.setPassword(settings.getPassword().toCharArray());
                client.setCallback(new MQTTPushCallback(context));
                client.connect(options);
            } else {
                client.setCallback(new MQTTPushCallback(context));
                client.connect();
            }

            if (client.isConnected()) {
                client.publish(settings.getTopic(), new MqttMessage(params[0].getBytes()));
            } else {
                Log.d(TAG, "Client is not connected to the mqtt service");
            }

        } else {
            Log.d(TAG, "Broker URL unavailable !");
        }

    } catch (MqttException e) {
        e.printStackTrace();
    }

    return null;
}

我的问题是，是否有更好的方法来做到这一点，也许在服务中保持连接的活力？

诚挚的问候,

保罗。

Answer 1

好的，结果很简单，我所做的就是创建一个子类并扩展BroadcastReceiver

public class PublishBroadcast extends BroadcastReceiver{
    @Override
    public void onReceive(Context context, Intent intent) {
        Log.d(TAG , "onReceive");
        if((client != null) && (client.isConnected())){
            String Payload = intent.getStringExtra(EXTRA_MESSAGE);
            MqttMessage message = new MqttMessage(Payload.getBytes());
            try {
                client.publish(TOPIC ,message);
            } catch (MqttException e) {
                e.printStackTrace();
            }
        }
    }
}

比在onCreate()为我服务时，我已经注册了接收者

LocalBroadcastManager.getInstance(getApplicationContext()).registerReceiver(new PublishBroadcast() ,
            new IntentFilter(ACTION_PUBLISH));

Answer 2

泛美卫生组织网站(https://eclipse.org/paho/clients/android/)上有一个Android服务，您确实应该使用它来保持连接的打开和活动，然后只发布数据。