MQTT 获取离线消息怎么制作？

离线消息使用场景

• 场景一：客户端本身对离线消息的优先级比较低，只要保证最终能处理就可以。
• 场景二：客户端对于离线消息需要有限处理，且要求比较实时。

1. 客户端启动后，以控制消息的形式发起拉取消息的指令，设置拉取条数和顺序。
2. 客户端等待本地处理成功。
3. 继续拉取下一批消息。

• 客户端如果需要使用主动模式，请务必在连接建立后的第一个心跳周期内发起请求，否则系统会按照自动模式，即按照固定周期推送离线数据。
• 客户端每次最多拉取消息的数量为30条，客户端发起拉取请求的最大频率限制为5次/秒。
• 客户端需要自己控制拉取时机，因为消息从发起指令到推送到客户端，到客户端消费完成回应ACK都是异步过程。如果客户端拉取过快，很有可能拉到前一批还没有删除的消息，造成重复；或者拉取到重复的消息，因为前一次的消息还没有回复ACK。

2. public void testOfflineMsg() throws Exception {
3.         String broker = "tcp://XXXX:1883";
4.         String clientId = "GID_XXX@@@XXXX";
5.         final String topic = "XXXX/11";
6.         final String topicFilter[] = {topic};
7.         final int qos[] = {1};
8.         MemoryPersistence persistence = new MemoryPersistence();
9.         try {
10.             final MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
11.             final MqttConnectOptions connOpts = new MqttConnectOptions();
12.             System.out.println("Connecting to broker: " + broker);
13.             connOpts.setServerURIs(new String[]{broker});
14.             connOpts.setCleanSession(false);
15.             connOpts.setAutomaticReconnect(true);
16.             /**
17.              * 客户端长链接需要设置心跳实际，建议100s以下，超时，服务端会断开连接
18.              */
19.             connOpts.setKeepAliveInterval(90);
20.             sampleClient.setCallback(new MqttCallbackExtended() {
21.                 public void connectComplete(boolean reconnect, String serverURI) {
22.                     System.out.println("connect success");
23.                       sampleClient.subscribe(topicFilter, qos);
24.                 }
25.                 public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
26.                     System.out.println("recv Msg from " + topic);
27.                 }
28.                 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
29.                     System.out.println("deliveryComplete:" + iMqttDeliveryToken.getMessageId());
30.                 }
31.             });
32.             sampleClient.connect(connOpts);
33.             JSONObject object = new JSONObject();
34.             object.put("maxPushNum", 20);
35.             object.put("pushOrder", "DESC");
36.             sampleClient.publish("$SYS/getOfflineMsg", new MqttMessage(object.toJSONString().getBytes()));
37.             Thread.sleep(1000000);
38.         } catch (Exception e) {
39.             e.printStackTrace();
40.         }
41.     }