再次：Android MQTT 无法创建客户端

Question

我正在尝试在 Android 中创建一个 MqttClient，使用 ADT 上的 Android 模拟器 (Nexus7)（Linux Fedora17 上的 Eclipse 3.8.0。 我发现这个问题回答了(Android MQTT unable to create client)，但它未能解决我的问题。

我创建了一个活动，允许用户进入存储 presistence 文件的目录，但无法避免捕获异常。 我尝试了“/mnt/sdcard/”、“/mnt/”、“/mnt/sdcard/tmp/”和类似的。

我需要注意 Eclipse 项目中 Android 模拟器中的特定设置吗？ 应用程序中是否包含任何使用权限？

我查看了引用的已回答问题中提到的各种 mqtt 资源，但我无法找到答案。

这是我的代码：

package com.storassa.android.mqttsample;

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttDefaultFilePersistence;

import android.os.Bundle;
import android.app.Activity;
import android.view.Menu;
import android.view.View;
import android.widget.AutoCompleteTextView;
import android.widget.Button;
import android.widget.TextView;

public class MqttSample extends Activity {

    Button okButton = null;
    AutoCompleteTextView inputTextView = null;
    TextView errorTextView = null;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_mqtt_sample);

        okButton = (Button)findViewById(R.id.okButton);
        inputTextView = (AutoCompleteTextView)findViewById(R.id.InputText);
        errorTextView = (TextView)findViewById(R.id.errorText);

        okButton.setOnClickListener(new View.OnClickListener() {

            @Override
            public void onClick(View arg0) {
                // TODO Auto-generated method stub
                try {
                    String dir = inputTextView.getText().toString();
                    MqttDefaultFilePersistence mdfp = new MqttDefaultFilePersistence(
                            dir);
                    MqttClient client = new MqttClient("tcp://127.0.0.1:1833",
                            "0001", mdfp);
                }
                catch (Exception e) {
                    String errorText = "";
                    for (StackTraceElement error : e.getStackTrace())
                        errorText += error.toString() + "\n";
                    errorTextView.setText(errorText);
                }
            }
        });


    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.activity_mqtt_sample, menu);
        return true;
    }

}

这是堆栈：

MqttException(0) at
org.eclipse.paho.client.mqttv3.MqttDefaultFilePersistence.open(MqttDefaultFilePersistence.java:74)
org.eclipse.paho.client.mqttv3.MqttClient.<init>(MqttClient.java:183)
com.storassa.android.mqttsample.MqttSample$1.onClick(MqttSample.java:38)
android.view.View.performClick(View.java:4202)
android.view.View$PerformClick.run(View.java:17340)
android.os.Handler.handleCallback(Handler.java:725)
android.os.Handler.dispatchMessage(Handler.java:92)
android.os.Looper.loop(Looper.java:137)
android.app.ActivityThread.main(ActivityThread.java:5039)
java.lang.reflect.Method.invokeNative(Native Method)
java.lang.reflect.Method.invoke(Method.java:511)
com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:793)
com.android.internal.os.ZygoteInit.main(ZygoteInit.java:560)
dalvik.system.NativeStart.main(Native Method)    

Answer 1

花了一整天的时间了解问题并在任何地方搜索它，最终我明白了：非常简单地，必须将权限添加到清单中

<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>

不知道能不能用内部目录代替sdcard。

由于这是我第一次回答我自己的问题，请让我知道将我自己的答案标记为正确答案是否是一种好的礼仪（我在这个话题上发现了不同的意见）

Answer 2

如果您不依赖文件持久性，您也可以使用 MemoryPersistence 类的实例。

所以获取客户的电话是：

MemoryPersistence persistence = new MemoryPersistence();
MqttClient client = new MqttClient(host, clientId, persistence);

Answer 3

这解决了我的问题。

<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>

WAMP 周围也有一些嘲笑。

Answer 4

        MqttClientPersistence persistence = new MqttDefaultFilePersistence(mContext.getApplicationInfo().dataDir);
        mqttclient = new MqttAsyncClient(url.toString(), clientId, persistence);

Answer 5

该错误是因为 MQTT 客户端代码在以高 (1/2) QOS 级别发布时试图打开本地存储上的文件以存储消息。错误的原因有两个：

1.您可能没有授予应用程序的存储访问权限

2.您不太可能拥有写入 MQTT 客户端选择的默认位置的权限。

解决此问题的最简单方法是为 MQTT 客户端使用内存存储 (org.eclipse.paho.client.mqttv3.persist.MemoryPersistence)。

...
MemoryPersistence persistence = new MemoryPersistence();
client = new MqttClient("tcp://test.mosquitto.org:1883", clientId);
...

一旦你解决了这个问题，你很可能会遇到在 UI 线程上执行网络 io 的问题。为避免这种情况，我建议您查看 Android 提供的 AsyncTask 代码