MQTT 的可靠性?

如何解决MQTT 的可靠性?

我正在开发一个 Uber 应用程序风格 (android),客户端/司机应用程序,他将在客户端和司机之间进行通信。

我将 RabbitMQ 用于 MQTT。以及适用于 android 的 paho 库。

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'
implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'

通信例如: 向司机发送行程请求, 接受司机的搭车, 由司机或客户取消行程, ...

为了进行客户端/驱动程序通信,我使用了 MQTT 协议。

我遇到的问题是有时消息无法到达收件人,例如比赛取消。即使我使用 QOS = 2 订阅主题或发送主题也是如此。

不使用此协议传递(或发送)消息是正常行为吗?

我对MQTT技术的选择感到疑惑。

Voici avec je me connecte :

    private MqttConnectOptions createMqttConnectOptions() {
        mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setAutomaticReconnect(true);
        mqttConnectOptions.setCleanSession(false);
        mqttConnectOptions.setKeepAliveInterval(0);
        mqttConnectOptions.setConnectionTimeout(0);
        mqttConnectOptions.setServerURIs(MQTT_SERVERS_URL);
        mqttConnectOptions.setUserName(MQTT_USERNAME);
        mqttConnectOptions.setPassword(MQTT_PASSWORD.toCharArray());
        return mqttConnectOptions;
    }

    private MqttAndroidClient createMqttAndroidClient(String serveurUri) {
        return mqttAndroidClient = new MqttAndroidClient(this,serveurUri,id,new MemoryPersistence());
    }

    public void connect(MqttConnectOptions mqttConnectOptions) {
        try {
            if (!mqttAndroidClient.isConnected()) {
                final IMqttToken token = mqttAndroidClient.connect(mqttConnectOptions);
                token.setActionCallback(new IMqttActionListener() {

                    @Override
                    public void onSuccess(IMqttToken asyncActionToken) {
                        DisconnectedBufferOptions disconnectedBufferOptions = new DisconnectedBufferOptions();
                        disconnectedBufferOptions.setBufferEnabled(true);
                        disconnectedBufferOptions.setBufferSize(1000);
                        disconnectedBufferOptions.setPersistBuffer(false);
                        disconnectedBufferOptions.setDeleteOldestMessages(true);
                        mqttAndroidClient.setBufferOpts(disconnectedBufferOptions);

                        subscribeToTopic(2,Constants.MQTT_TOPIC_DRIVER_REQUEST + mqttAndroidClient.getClientId());

                    }

                    @Override
                    public void onFailure(IMqttToken asyncActionToken,Throwable exception) {
                        Log.e(TAG,"Failed to connect to: " + mqttAndroidClient.getServerURI());
                    }
                });
            }
        } catch (MqttException e) {
            Log.e(TAG,"At connect method",e);
        }
   }

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com(将#修改为@)

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?