Ggtcf

I want to connect to a local broker like tcp://192.168.1.25:80 but the android mqtt client wont only string address, like tcp://test.mosquitto.org. For now, I change the emulator hosts file, but in a smartphone without the root it is impossible. There is a bug-fix for this?
There is my code:

private MqttAndroidClient mqttAndroidClient;

private final String serverUri = "wss://192.168.1.25:443";

private final String clientId = "AndroidID";
private final String subscriptionTopicData = "/data";


private final String username = "UUUUU";
private final String password = "PPPPP";

public MqttHelper(Context context)
 mqttAndroidClient = new MqttAndroidClient(context, serverUri, clientId, new MemoryPersistence(), MqttAndroidClient.Ack.AUTO_ACK);
 mqttAndroidClient.setCallback(new MqttCallbackExtended()
 @Override
 public void connectComplete(boolean b, String s) 
 Log.w("mqtt", s);
 

 @Override
 public void connectionLost(Throwable throwable) 
 Log.w("mqtt", throwable.toString());
 

 @Override
 public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception 
 Log.w("Mqtt", mqttMessage.toString());
 

 @Override
 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) 
 

 );
 connect();


public void setCallback(MqttCallbackExtended callback) 
 mqttAndroidClient.setCallback(callback);


private void connect()
 MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
 mqttConnectOptions.setAutomaticReconnect(true);
 mqttConnectOptions.setMqttVersion(MqttConnectOptions.MQTT_VERSION_DEFAULT);
 mqttConnectOptions.setCleanSession(false);
 mqttConnectOptions.setSocketFactory(SSLSocketFactory.getDefault());
 mqttConnectOptions.setUserName(username);
 mqttConnectOptions.setPassword(password.toCharArray());
 try 
 mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener() 
 @Override
 public void onSuccess(IMqttToken asyncActionToken) 
 DisconnectedBufferOptions disconnectedBufferOptions = new DisconnectedBufferOptions();
 disconnectedBufferOptions.setBufferSize(100);
 disconnectedBufferOptions.setBufferEnabled(true);
 disconnectedBufferOptions.setPersistBuffer(false);
 disconnectedBufferOptions.setDeleteOldestMessages(false);
 mqttAndroidClient.setBufferOpts(disconnectedBufferOptions);
 subscribeToTopic();
 

 @Override
 public void onFailure(IMqttToken asyncActionToken, Throwable exception) 
 Log.w("MQTT", "Failed to connect to: " + serverUri + ": "+exception.toString());
 Log.w("Mqtt", exception.fillInStackTrace());

 
 );

 catch (MqttException ex)
 Log.d("MQTT-------",Log.getStackTraceString(ex), ex.getCause());
 



private void subscribeToTopic() 
 try 
 mqttAndroidClient.subscribe(subscriptionTopicData, 0, null, new IMqttActionListener() 
 @Override
 public void onSuccess(IMqttToken asyncActionToken) 
 

 @Override
 public void onFailure(IMqttToken asyncActionToken, Throwable exception) 
 Log.w("Mqtt", "Subscribed fail!");
 
 );
 doReconnect=true;
 catch (MqttException ex) 
 System.err.println("Exception whilst subscribing");
 ex.printStackTrace();
 

doReconnect is for a workaround for the re-subscribe of all the topic.

The error:

 W/Mqtt: MqttException (0) - java.io.IOException: WebSocket Response header: Incorrect connection header
 at helper.MqttHelper$2.onFailure(MqttHelper.java:99)
 at org.eclipse.paho.android.service.MqttTokenAndroid.notifyFailure(MqttTokenAndroid.java:146)
 at org.eclipse.paho.android.service.MqttAndroidClient.simpleAction(MqttAndroidClient.java:1501)
 at org.eclipse.paho.android.service.MqttAndroidClient.connectAction(MqttAndroidClient.java:1439)
 at org.eclipse.paho.android.service.MqttAndroidClient.onReceive(MqttAndroidClient.java:1368)
 at android.support.v4.content.LocalBroadcastManager.executePendingBroadcasts(LocalBroadcastManager.java:313)
 at android.support.v4.content.LocalBroadcastManager$1.handleMessage(LocalBroadcastManager.java:121)
 at android.os.Handler.dispatchMessage(Handler.java:106)
 at android.os.Looper.loop(Looper.java:193)
 at android.app.ActivityThread.main(ActivityThread.java:6669)
 at java.lang.reflect.Method.invoke(Native Method)
 at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:493)
 at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:858)
 Caused by: java.io.IOException: WebSocket Response header: Incorrect connection header
 at org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketHandshake.receiveHandshakeResponse(WebSocketHandshake.java:143)
 at org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketHandshake.execute(WebSocketHandshake.java:76)
 at org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketSecureNetworkModule.start(WebSocketSecureNetworkModule.java:63)
 at org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:701)
 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:458)
 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:301)
 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)
 at java.lang.Thread.run(Thread.java:764)

UPDATE

I tried to connect to cloudMQTT with the ip address, traslated by a dns, and it works, also over WSS protocol. So, I think, that it's a broker config or a local access to my lan devices by android devices.
I also tried to connect to my local device using chrome and it sees the device, so I think is also a broker config.

UPDATE 2

I made a simple mosquitto broker, in my computer, for testing. Same Issiue, but I can put on stack the configuration:

bind_address localhost
port 1883
listener 443 192.168.1.25/my.broker.io
protocol websockets
message_size_limit 1500

This time if I try to access to the ip, the connection go in timeout, than if I try to connet to my.broker.io the error is:

W/Mqtt: Failed to connect to: ws://my.broker.io:443MqttException (0) - java.net.UnknownHostException: my.broker.io