MQTT在reactnative中的运行

import init from 'react_native_mqtt';
import AsyncStorage from '@react-native-community/async-storage';

init({
  size: 10000,
  storageBackend: AsyncStorage,
  defaultExpires: 1000 * 3600 * 24,
  enableCache: true,
  reconnect: true,
  sync: {}
});


第一步：创建
// 地址，端口，路径（这么写就行了），connectId(随便写)  ：地址和端口，都是后台给，或者你自己弄个mqtt的服务
let client = new Paho.MQTT.Client('192.168.0.63', 8083, '/mqtt', '/mqttjs_db6017d322')


第二步：连接,暂时有一个参数，2个方法：成功，失败
client.connect({
      useSSL: false,
      onSuccess: onConnect,
      onFailure:(e)=>{ console.log('失败'); console.log(e); }
});
// 成功后需要发送主题 ，就是一个接口的路径类似
function onConnect(){
    console.log('成功');
    client.subscribe(‘/fangtao’);
}
第三步：断掉
client.onConnectionLost = onConnectionLost;

function onConnectionLost (responseObject) {
    if (responseObject.errorCode !== 0) {
      console.log('onConnectionLost:' + responseObject.errorMessage);
    }
  }

第四步：接收消息
client.onMessageArrived = onMessageArrived;

function onMessageArrived (message) {
    console.log('消息：' + message.payloadString);
  }