MQTT Token 客户端接口如何实现？

本文介绍 MQTT 客户端上传 Token、监听 Token 失效信息、监听 Token 非法信息三个接口的使用，并给出相关示例代码以供参考。

客户端上传 Token 凭证


发送 Topic：$SYS/uploadToken
内容：JSONString
内容信息：

名称	类型	说明
Token	String	如果客户端选用 Token 模式，则需要上传 Token 字符串。
type	String	Token 类型，分为 W，R，RW 共三种，对应三种权限类型的 Token。一个客户端最多拥有这3个 Token，设置错误的类型会导致权限校验错误。

返回值
普通的 PubAck 报文。客户端必须等到该响应才能进行下一步 Pub 或者 Sub 操作，否则服务端可能会鉴权失败导致连接断开。

客户端监听即将失效的 Token 信息


接收 Topic：$SYS/tokenExpireNotice
内容：JSONString
内容信息：

名称	类型	说明
expireTime	int	该 Token 即将于什么时候失效，一般提前5分钟通知，只通知一次。
type	String	Token 类型，分为 W，R，RW 共三种，对应客户端上传的三种权限类型的 Token。

响应：
客户端收到 Token 即将失效的消息后，需要尽快处理重新申请 Token 的动作，以免造成收发消息失败。

客户端监听 Token 非法的通知


接收 Topic：$SYS/tokenInvalidNotice
内容：JSONString
内容信息：

名称	类型	说明
code	int	Token 校验失败的类型。
type	String	Token 类型，分为 W，R，RW 共三种，对应客户端上传的三种权限类型的 Token。

响应：
服务端校验 Token 失效，会导致鉴权失败，服务端会主动断开链接。断开链接之前，服务端会给客户端推送失败的 code，客户端根据 code 即可判断原因。

type code	错误类型
1	伪造 Token，不可解析
2	Token 已经过期
3	Token 已经被吊销
4	资源和 Token 不匹配
5	权限类型和 Token 不匹配
8	签名不合法
-1	帐号权限不合法

注意：

• 服务端下推 Token 非法的通知后，会接着断开连接。正常情况下客户端应该能根据该通知判断是否需要申请 Token。
• 异常情况下，可能尚未收到通知，即已经断开连接。此时客户端需要判断原先的 Token 是否到期，如果确实接近到期时间，则先申请 Token 再重连。

示例程序

1. public static void main(String[] args) throws MqttException, InterruptedException {
2.         String broker = "tcp://XXXX:1883";
3.         String clientId = "GID_XXX@@@XXXX";
4.         final String topic = "XXXX/XXXXX";
5.         MemoryPersistence persistence = new MemoryPersistence();
6.         final MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
7.         final MqttConnectOptions connOpts = new MqttConnectOptions();
8.         System.out.println("Connecting to broker: " + broker);
9.         connOpts.setServerURIs(new String[] {broker});
10.         connOpts.setCleanSession(true);
11.         connOpts.setKeepAliveInterval(90);
12.         sampleClient.setCallback(new MqttCallbackExtended() {
13.             @Override
14.             public void connectComplete(boolean reconnect, String serverURI) {
15.                 //连接成功，需重新上传Token
16.                 JSONObject object = new JSONObject();
17.                 object.put("token", "XXXX");//设置Token内容
18.                 object.put("type", "RW");//设置Token类型，共有RW，R，W三种类型
19.                 MqttMessage message = new MqttMessage(object.toJSONString().getBytes());
20.                 message.setQos(1);
21.                 try {
22.                     sampleClient.publish("$SYS/uploadToken", message);
23.                     sampleClient.subscribe(topic, 0);
24.                 } catch (MqttException e) {
25.                     e.printStackTrace();
26.                 }
27.             }
29.             @Override
30.             public void connectionLost(Throwable throwable) {
31.                 System.out.println("mqtt connection lost");
32.                 throwable.printStackTrace();
33.             }
35.             @Override
36.             public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
37.                 if (topic.equals("$SYS/tokenInvalidNotice")) {
38.                     //Token非法的通知
39.                 } else if (topic.equals("$SYS/tokenExpireNotice")) {
40.                     //Token即将失效的通知
41.                 }
42.             }
44.             @Override
45.             public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
46.                 System.out.println("deliveryComplete:" + iMqttDeliveryToken.getMessageId());
47.             }
48.         });
49.         sampleClient.connect(connOpts);
50.         JSONObject object = new JSONObject();
51.         object.put("token", "XXXX");//设置Token内容
52.         object.put("type", "RW");//设置Token类型,共有RW，R，W三种类型
53.         MqttMessage message = new MqttMessage(object.toJSONString().getBytes());
54.         message.setQos(1);
55.         MqttTopic pubTopic = sampleClient.getTopic("$SYS/uploadToken");
56.         MqttDeliveryToken token = pubTopic.publish(message);
57.         token.waitForCompletion();//同步等待上传结果
58.         //Token上传成功，在开始正常的业务消息收发
59.         sampleClient.subscribe(topic, 0);
60.         while (true) {
61.             sampleClient.publish(topic, message);
62.             Thread.sleep(5000);
63.         }
64.     }