Кнопка для закрытия JDialog

Добавьте эти зависимости в gradle

    dependencies{
   compile 'io.moquette:moquette-netty-parser:0.8.1'
    compile 'io.moquette:moquette-broker:0.8.1'
    compile 'io.moquette:moquette-parser-commons:0.8.1'
}

И используйте

io.moquette.server.Server server = new io.moquette.server.Server();
server.startServer();

, чтобы запустить сервер брокера. URI по умолчанию tcp://localhost:1883

Для меня server.startServer(); дал мне исключение, поскольку он не может создать файл BrokerConstants.DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME. Итак, я изменил назначение BrokerConstants.DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME, используя этот код ниже кода, и он работал для меня.

     try {
         MemoryConfig memoryConfig = new MemoryConfig(new Properties());
memoryConfig.setProperty(BrokerConstants.PERSISTENT_STORE_PROPERTY_NAME, Environment.getExternalStorageDirectory().getAbsolutePath()+ File.separator + BrokerConstants.DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME);
    server.startServer(memoryConfig); 
        // server.startServer();//is not working due to DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME; 
        Log.d(TAG,"Server Started");
         }
         catch (IOException e) { e.printStackTrace(); }
         catch (Exception e){ e.printStackTrace(); }

И использовать библиотеки Paho для android

compile 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.0'
compile 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'

Чтобы создать клиент и подключиться к tcp://localhost:1883, подписаться на тему и начать публикацию и получение сообщений.

moquette библиотека для android .