Unable to connect - MQTT protocol URL (plugin@taoqf/react-native-mqtt)

[shalini-whiz]

Here, I have integrated this plugin in my react native project and trying to connect URL with protocol mqtt. Referred doc
https://github.com/taoqf/MQTT.js/blob/react-native/README.md
Am unable to detect either connected or not. Below is my snippet
let mUrl = "mqtt://xxxx.xxxx.in";
let mOptions = {
username: server_user, password: server_pass,
protocol: 'mqtt',
clientId: 'mqttjs_' + Math.random().toString(16).substr(2, 8),
rejectUnauthorized: false,
protocolId: 'mqtt',
defaultProtocol:"mqtt",
protocolVersion: 4,
clean:false
}
var client = mqtt.connect(mUrl,mOptions);
client.on('connect', function () {
console.log("connected");
})
})
client.on('error', function ( err) {
console.log("client err : " + err)
})

Can anyone help ?

Thanks

[galihariad]

Same, I am new to react-native so still figuring out how to test this..
I tried to add this code to my button component, but the console.log I put inside the client.on('connect', function () { function hasn't come out yet as I checked in the browser console :/

cc: @taoqf

[DzungHD35]

Are there any updates on this issue? I just cannot connect to the broker, moreover, no errors are fired

[shalini-whiz]

@galihariad @DzungDH35 I switched to https://github.com/SudoPlz/sp-react-native-mqtt

[DzungHD35]

@shalini-whiz I used to try the lib you mentioned before, but there are some problems with connect() function which fire an exception. The console log is like below:

I do not understand why it is an UnknownHostException, I try to test this broker with a MQTTClient app and it still works

[shalini-whiz]

@DzungDH35 , for your reference added snippet. If you find issue still, raise issue in respective plugin itself
let options = {
uri: "mqtt" + "://XXXX.XXXX.XX:PORT",
user: "",
pass: "",
auth: true,
keepalive: 32000
}
options.clientId = "clientId"+Date.now()
MQTT.createClient(options).then((client) => {
client.connect();

  client.on('closed', () => {
    console.log('mqtt.event.closed');
  });

  client.on('error', (msg) => {
    console.log('bin mqtt.event.error', msg);
  });

  client.on('message', (msg) => {
    console.log('mqtt.event.message', msg);
  });

  client.on('connect', () => {
    console.log('connected');
    client.subscribe(topic_name, 2)
  });

}).catch((err) => {
  console.log("err : " + err);
});

[DzungHD35]

@shalini-whiz thank you so much. I still have no idea why your codes work :), my flow is quite the same as yours except for false value of auth, though ... whatever, it works, many thanks :)

[QMY-ZQ]

@shalini-whiz 但是用sp_react_native_mqtt对于android会友好，对于ios就会有点不兼容