ANDROID-MQTT :Unable To Connect To Server (32103)

I am trying to learn basic MQTT integration in Android. I am using a mosquitto broker to publish and subscribe messages. I am running the code on a real device and getting this exc

Solution 1:

As you are getting started, you need to see see how different implementations work. Take a look at my implementation. I use a separated class for MQTT specific stuff.

MqttUtil.java

public class MqttUtil {
    private static final String MQTT_TOPIC = "test/topic";
    private static final String MQTT_URL = "tcp://localhost:1883";
    private static boolean published;
    private static MqttAndroidClient client;
    private static final String TAG = MqttUtil.class.getName();


    public static MqttAndroidClient getClient(Context context){
        if(client == null){
            String clientId = MqttClient.generateClientId();
            client =  new MqttAndroidClient(context, MQTT_URL, clientId);
        }
        if(!client.isConnected())
            connect();
        return client;
    }

    private static void connect(){
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setCleanSession(true);
        mqttConnectOptions.setKeepAliveInterval(30);

        try{
            client.connect(mqttConnectOptions, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    Log.d(TAG, "onSuccess");
                }
                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    Log.d(TAG, "onFailure. Exception when connecting: " + exception);
                }
            });
        }catch (Exception e) {
            Log.e(TAG, "Error while connecting to Mqtt broker : " + e);
            e.printStackTrace();
        }
    }

    public static void publishMessage(final String payload){
        published = false;
        try {
            byte[] encodedpayload = payload.getBytes();
            MqttMessage message = new MqttMessage(encodedpayload);
            client.publish(MQTT_TOPIC, message);
            published = true;
            Log.i(TAG, "message successfully published : " + payload);
        } catch (Exception e) {
            Log.e(TAG, "Error when publishing message : " + e);
            e.printStackTrace();
        }
    }

    public static void close(){
        if(client != null) {
            client.unregisterResources();
            client.close();
        }
    }
}

And you can simply use it in your HomeActivity. Check it below:

public class HomeActivity extends AppCompatActivity{

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

    // Get Mqtt client singleton instance
    MqttUtil.getClient(this);

    // Publish a sample message
    MqttUtil.publishMessage("Hello Android MQTT");
    }
}

For testing purposes, use your Mosquitto sub client and see if you get the message.

Hope that helps!

Solution 2:

try using port 8883

    String clientId = MqttClient.generateClientId();
final MqttAndroidClient client =
        new MqttAndroidClient(this.getApplicationContext(), "ssl://iot.eclipse.org:8883",
                              clientId);
try {
    MqttConnectOptions options = new MqttConnectOptions();

        InputStream input =
                this.getApplicationContext().getAssets().open("iot.eclipse.org.bks");

        options.setSocketFactory(client.getSSLSocketFactory(input, "eclipse-password"));


        IMqttToken token = client.connect(options);
        token.setActionCallback(new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                // We are connected
                Log.d(TAG, "onSuccess");

            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                // Something went wrong e.g. connection timeout or firewall problems
                Log.d(TAG, "onFailure");

            }
        });


} catch (MqttException | IOException e) {
    e.printStackTrace();
}