HiveMQ Cloud持久化会话与消息队列问题：Java服务端vs Android客户端

问题根源分析 #

你的代码存在两处关键配置问题，导致服务器无法缓存离线消息并在客户端重连后推送：

• 订阅未指定匹配的QoS等级：客户端订阅时未设置QoS，默认采用MqttQos.AT_MOST_ONCE（QoS 0），而服务端发布消息用的是MqttQos.AT_LEAST_ONCE（QoS 1）。只有当订阅QoS ≥ 发布QoS时，服务器才会为持久会话缓存离线消息。
• 错误使用Retain标记：服务端每条消息都设置retain=true，这只会让服务器保留该主题的最后一条消息，而非离线期间产生的所有消息。Retain的作用是向新订阅者推送最新状态，无法用来缓存批量离线消息。

具体修复方案 #

1. 客户端订阅时指定QoS等级 #

修改客户端订阅代码，明确设置QoS为1（与服务端发布的QoS一致）：

client.subscribeWith()
        .topicFilter("hasan-device/sayHello")
        .qos(MqttQos.AT_LEAST_ONCE) // 新增：指定匹配的QoS等级
        .retainHandling(Mqtt5RetainHandling.SEND)
        .send();

2. 服务端关闭Retain标记（按需调整） #

如果不需要让新订阅者获取单条最新消息，将发布时的retain(true)改为retain(false)：

client.publishWith()
        .topic("hasan-device/sayHello")
        .payload(UTF_8.encode(message))
        .retain(false) // 修改为false，避免覆盖旧消息
        .qos(MqttQos.AT_LEAST_ONCE)
        .noMessageExpiry()
        .send();

3. 加固会话与重连逻辑 #

你的会话基础配置（固定客户端ID、cleanStart(false)、noSessionExpiry()）已经符合持久化要求，建议将订阅和回调注册放在连接成功的回调中，确保重连后逻辑正常生效：

client.toAsync().connectWith()
        .simpleAuth()
        .username(username)
        .password(UTF_8.encode(password))
        .applySimpleAuth()
        .noSessionExpiry()
        .cleanStart(false)
        .send()
        .whenComplete((connAck, throwable) -> {
            if (throwable == null) {
                // 连接成功后执行订阅和回调注册
                client.subscribeWith()
                        .topicFilter("hasan-device/sayHello")
                        .qos(MqttQos.AT_LEAST_ONCE)
                        .retainHandling(Mqtt5RetainHandling.SEND)
                        .send();
                
                client.toAsync().publishes(ALL, publish -> {
                    byte[] message = publish.getPayloadAsBytes();
                    LOGGER.info("Received message: {} -> {}, ", publish.getTopic(), new String(message, UTF_8));
                });
            }
        });

验证步骤 #

1. 杀死Android应用，让服务端持续发送多条消息。
2. 重新打开应用，客户端重连后应能接收离线期间的所有消息。

内容的提问来源于stack exchange，提问作者Hasan Mumin