那些遇到过的问题

使用android时,RSMB MQTT代理上的客户端标识符出现套接字错误

Emm*_*uel 6 android mqtt

我正在为android构建一个简单的MQTT客户端,我在RMBS控制台上收到"客户端标识符的套接字错误"错误.这只发生在客户端的android实现中(我还创建了一个Java桌面客户端并且运行没有问题).对于Android客户端,我正在起诉Paho Java客户端库.这是我的代码:

这是Android客户端:

package com.example.mqttdroid;

import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.eclipse.paho.client.mqttv3.internal.MemoryPersistence;

import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.Menu;
import android.widget.Toast;

public class MQTTClient extends Activity {

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_mqttclient);
//  new BackTask().execute(); not used because (seems to be the problem)
  MqttConnectOptions conOpts = new MqttConnectOptions();
            conOpts.setKeepAliveInterval(30);
            conOpts.setWill(client.getTopic("Error"), "something bad happened".getBytes(), 1, true);
            client.connect(conOpts);

            client.subscribe("/House/Kitchen/Bulb");
            client.setCallback( new MqttCallback() {



                @Override
                public void connectionLost(Throwable arg0) {
                    // TODO Auto-generated method stub

                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken arg0) {
                    // TODO Auto-generated method stub

                }

                @Override
                public void messageArrived(String arg0, MqttMessage arg1)
                        throws Exception {
                    // TODO Auto-generated method stub
                    Toast.makeText(Main.this, arg0.toString(), Toast.LENGTH_SHORT).show();
                }
            });
}

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

/*public class BackTask extends AsyncTask<Void, Void, Void>{

    private MqttClient client;
    @Override
    protected Void doInBackground(Void... params) {
        // TODO Auto-generated method stub

        try {

            client = new MqttClient("tcp://"Ip of machine running RSMB":1883", "ANDROID1", new MemoryPersistence());

            client.connect();
            client.subscribe("House/Kitchen/Bulb");


        } catch (MqttException e) {
            // TODO Auto-generated catch block
            Log.e("ERROR", "NOT CONNECTED");
            e.printStackTrace();
        }
        return null;
    }
    @Override
    protected void onPostExecute(Void result) {
        // TODO Auto-generated method stub
        super.onPostExecute(result);

        try {
            client.setCallback( new MqttCallback() {

                @Override
                public void messageArrived(MqttTopic arg0, MqttMessage arg1)
                        throws Exception {
                    // TODO Auto-generated method stub
                    Toast.makeText(MQTTClient.this, arg0.toString(), Toast.LENGTH_SHORT).show();
                }

                @Override
                public void deliveryComplete(MqttDeliveryToken arg0) {
                    // TODO Auto-generated method stub

                }

                @Override
                public void connectionLost(Throwable arg0) {
                    // TODO Auto-generated method stub

                }
            });
        } catch (MqttException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

 }*/
Run Code Online (Sandbox Code Playgroud)

这是桌面Java客户端:

 import org.eclipse.paho.client.mqttv3.MqttCallback;
 import org.eclipse.paho.client.mqttv3.MqttClient;
 import org.eclipse.paho.client.mqttv3.MqttClientPersistence;
 import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
 import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
 import org.eclipse.paho.client.mqttv3.MqttException;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
 import org.eclipse.paho.client.mqttv3.MqttTopic;
 import org.eclipse.paho.client.mqttv3.internal.MemoryPersistence;



 public class MQTTBaseClass {

/**
 * @param args
 */

public static void main(String[] args) {
    // TODO Auto-generated method stub
    MqttClientPersistence persistence;
    try {

        MqttClient client = new MqttClient("tcp://localhost:1883", "PC",new      MemoryPersistence());
        MqttConnectOptions conOpts = new MqttConnectOptions();
        conOpts.setKeepAliveInterval(30);
        conOpts.setWill(client.getTopic("Error"), "something bad happened".getBytes(), 1, true);
        client.connect(conOpts);
        MqttMessage msg = new MqttMessage("hello".getBytes());
        msg.setQos(0);
        msg.setRetained(true);
        MqttTopic topic = client.getTopic("House/Kitchen/Bulb");
        client.subscribe("House/Kitchen/Bulb");

        try {
            client.setCallback( new MqttCallback() {

                @Override
                public void messageArrived(MqttTopic arg0, MqttMessage arg1)
                        throws Exception {
                    // TODO Auto-generated method stub
                    System.out.println(arg1.toString());
                }

                @Override
                public void deliveryComplete(MqttDeliveryToken arg0) {
                    // TODO Auto-generated method stub

                }

                @Override
                public void connectionLost(Throwable arg0) {
                    // TODO Auto-generated method stub

                }
            });
        } catch (MqttException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        topic.publish(msg);


    } catch (MqttPersistenceException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (MqttException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}






 }
Run Code Online (Sandbox Code Playgroud)

只需几点说明:

我通过WiFi在我的Android设备上连接,当我运行Java Dekstop客户端时,我的桌面也是如此.

Java Destop Client与RSMB在同一台计算机上运行

Java桌面客户端创建并显示主题"House/Kitchen/Bulb"并发送带有字符串"Hello"的消息

Android客户端还订阅"House/Kitchen/Bulb"并尝试使用收到的消息显示Toast.

我已经在android清单上添加了Internet权限

Android设备似乎很好地连接到代理,但是一旦我初始化Java桌面服务客户端(或Eclipse中的Paho客户端插件并发布消息),我就会收到提到的错误.

我在RSMB运行的同一台机器上使用模拟器运行应用程序,我得到了同样的错误.

可能是什么问题？

更新:

最初,我有一个"主线程上的网络"异常,所以我将连接操作移动到AsyncTask.现在看来,当我用Java客户端发布消息时,Android客户端仍然连接(Asynctask可能一直在创建问题),但似乎没有调用MqttCallback()的messageArrived().

更新2:

我设法让它发挥作用.这是我现在使用的代码:

package com.example.mqttphone;

*import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.Menu;
import android.widget.Toast;*

public class Main extends Activity {
protected static String msg;
public MqttClient client;
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    try {

        client = new MqttClient("tcp://10.1.201.27:1883", "ANDROID1", new MemoryPersistence());

        MqttConnectOptions conOpts = new MqttConnectOptions();
        conOpts.setKeepAliveInterval(30);
        conOpts.setWill(client.getTopic("Error"), "something bad happened".getBytes(), 1, true);
        client.setCallback( new MqttCallback() {



            @Override
            public void connectionLost(Throwable arg0) {
                // TODO Auto-generated method stub

            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken arg0) {
                // TODO Auto-generated method stub

            }

            @Override
            public void messageArrived(String arg0, MqttMessage arg1)
                    throws Exception {
                // TODO Auto-generated method stub
            Main.msg = arg1.toString();
            Main.this.runOnUiThread(new Runnable() {

                @Override
                public void run() {
                    // TODO Auto-generated method stub
                    Toast.makeText(Main.this, msg, Toast.LENGTH_LONG).show();
                }
            });
                Log.e("MESSAGE RECEIVED", arg1.toString());

            }
        });
        client.connect(conOpts);
        //MqttMessage msg = new MqttMessage("ANDROID MESSAGE".getBytes());
        //client.getTopic("world").publish(msg);

        if(client.isConnected()){

        client.subscribe("/House/Kitchen/Bulb");


            Toast.makeText(this, "CONNECTED", Toast.LENGTH_SHORT).show();

        }



    } catch (MqttException e) {
        // TODO Auto-generated catch block
        Log.e("ERROR", "NOT CONNECTED");
        e.printStackTrace();
    }

}

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


}
Run Code Online (Sandbox Code Playgroud)

Emm*_*uel 1

我成功了。这是github 存储库的链接，每个人都可以在其中找到实现此代码的项目。它允许用户使用 Android 设备通过语音识别远程打开 LED 灯。

归档时间：

查看次数：

2581 次

最近记录：

13 年 前
相关归档
如何删除Android上ListViews之间的行？ 384
使用Android Application类来保存数据 109
如果连接了多个仿真器/设备,是否可以安装apk文件 88
DialogFragment优于AlertDialog 61
使用USB电缆连接时,在Eclipse中未检测到设备 60
Eclipse Android Change API Level 53
android捏缩放 47
使用Wifi连接ADB用于非root设备 42
如何在flutter中扩展textField看起来像一个文本区域 42
姆克特（Mqtt）：是否需要退订？ 2
难疑归档
如何检查字符串是否包含JavaScript中的子字符串？ 7430
如何检查文件是否存在而没有例外？ 5290
将(移动)子目录分离到单独的Git存储库中 1712
将存储过程的结果插入临时表 1526
为什么Dictionary优先于Hashtable？ 1348
使用jQuery作为JS对象向select中添加选项的最佳方法是什么？ 1340
如何使用Sublime Text 2重新格式化HTML代码？ 1282
检查Ruby中的数组中是否存在值 1258
如何在find中排除目录.命令 1250
如何使用jQuery更改超链接的href 1231