相关代码:
public void publish(String topic, String message) {
try {
InsideApplication.getSharedPreferences().getString(Const.ROOM_ID, "");
String roomTopic = topic;
if (!isNetworkConnected(InsideApplication.getApplication())) {
LogUtils.d(TAG, "publish()--没有网");
//在这里尝试过注销这mClient广播接收器 设置成null,
//这个网络断开和连接非常快设置了睡眠 也无用
}
if (mClient == null) {
mClient = new MqttAndroidClient(InsideApplication.getApplication(), mUri, DeviceUuidFactory.getLocalSerialHex());
mClient.setCallback(this);
//连接
}
mClient.publish(
roomTopic,
message.getBytes(),
MQTTConfig.QOS,
false,
null,
new ActionListener(
mContext,
Action.PUBLISH,
this));
} catch (MqttSecurityException e) {
} catch (MqttException e) {
}
报错信息:
at org.eclipse.paho.android.service.MqttAndroidClient.publish(MqttAndroidClient.java:715)
at com.insideroom.mqtt.MQTTConnect.publish(MQTTConnect.java:112)
at com.insideroom.base.InsideApplication.publish(InsideApplication.java:93)
at com.insideroom.activity.VoiceNameActivity.pushNET(VoiceNameActivity.java:224)
at com.insideroom.activity.VoiceNameActivity.onCreate(VoiceNameActivity.java:110)
at android.app.Activity.performCreate(Activity.java:5131)
at android.app.Instrumentation.callActivityOnCreate(Instrumentation.java:1090)
at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:2144)
... 11 more
学习是最好的投资!