android - 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

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

Answer 2

好的，事实证明这很简单，我所做的是创建一个子类并扩展 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));