基于Alink协议开发

准备工作

• 根据您的实际情况，准备合适的MQTT客户端。本示例使用Eclipse Paho作为MQTT客户端。

  <dependency>
  	<groupId>org.eclipse.paho</groupId>
  	<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
  	<version>1.1.1</version>//可以选择您需要的版本
  </dependency>

• 开发Java语言物模型，具体操作请参见物模型开发。

示例代码

示例代码如下所示。将示例代码中的your_ProductKey、your_DeviceName、your_DeviceSecret替换为您自己的设备证书信息，即充电桩设备（device-1）的设备证书，其余代码可直接运行。

• 上报属性

  设置设备属性时，需要订阅的Topic为Alink协议标准Topic：/sys/{productKey}/{deviceName}/thing/service/property/set，默认以异步方式返回结果。

  String productKey = "your_ProductKey";
  String deviceName = "your_DeviceName";
  String deviceSecret = "your_DeviceSecret";
  
  // MQTT连接
  MqttTestClient client;
  client = new MqttTestClient(productKey, deviceName, deviceSecret);
  
  client.connect();
  
  String setTopic = "/thing/event/property/post";
  String setTopicReply = "/thing/event/property/post_reply";
  
  // 上报属性，云端会返回REPLY，进行订阅。（为了节省端侧订阅开销，可以开通免订阅）
  // 此处client进行了封装，您根据自己的业务进行封装即可，也可以直接使用MQTT Client subscribe
  client.sysTopic(setTopicReply).subscribe();
  
  // 封装Alink协议系统参数
  Map<String, Object> payload = new HashMap<String, Object>();
  Map<String, Object> params = new HashMap<String, Object>();
  payload.put("id", 11);//id需要保证设备端一段时间内唯一
  payload.put("params", params);
  payload.put("method", "thing.event.property.post");
  
  // 组装属性payload
  String propKey = "acOutMeterIty";
  int statusValue = 30;
  Map<String, Object> proValue = new HashMap<>();
  proValue.put("value", statusValue);
  proValue.put("time", System.currentTimeMillis());
  params.put(propKey, proValue);
  
  // 上报（client进行了封装，您根据自己的业务进行封装即可，也可以直接使用MQTT Client publish消息）
  client.sysTopic(setTopic).publish(JSON.toJSONString(payload));
  
  // 打印云端返回的Reply（client进行了封装，您根据自己的业务进行封装即可，也可以直接使用MQTT Client监听订阅消息）
  client.sysTopic(setTopicReply).readTopic(10000);
  
  client.disconnect();

  运行代码成功后，日志打印的设备请求和响应如下图所示。

  

• 上报事件

  String productKey = "your_ProductKey";
  String deviceName = "your_DeviceName";
  String deviceSecret = "your_DeviceSecret";
  
  
  // MQTT连接
  MqttTestClient client;
  client = new MqttTestClient(productKey, deviceName, deviceSecret);
  
  client.connect();
  
  // topic中为"startChaResEvt"属于物模型事件标识符。
  String setTopic = "/thing/event/startChaResEvt/post";
  String setTopicReply = "/thing/event/startChaResEvt/post_reply";
  
  // 报事件，云端会返回REPLY，进行订阅。（为了节省端侧订阅开销，可以开通免订阅）
  client.sysTopic(setTopicReply).subscribe();
  
  // 封装Alink协议系统参数
  Map<String, Object> payload = new HashMap<String, Object>();
  Map<String, Object> params = new HashMap<String, Object>();
  payload.put("id", 11);//id需要保证设备端一段时间内唯一
  payload.put("params", params);
  payload.put("method", "thing.event.startChaResEvt.post");
  
  // 组装属性payload
  Map<String, Object> dataValue = new HashMap<>();
  // key为物模型中事件参数的标识符"gunNum", value为事件参数值需要遵循数值规范：int类型，取值范围0~100之间；
  dataValue.put("gunNum", 59);
  
  params.put("value", dataValue);
  params.put("time", System.currentTimeMillis());
  
  // 上报（client进行了封装，您根据自己的业务进行封装即可，也可以直接使用MQTT Client publish消息）
  client.sysTopic(setTopic).publish(JSON.toJSONString(payload));
  
  // 打印云端返回的Reply（client进行了封装，您根据自己的业务进行封装即可，也可以直接使用MQTT Client监听订阅消息）
  client.sysTopic(setTopicReply).readTopic(10000);
  
  client.disconnect();

• 调用服务

  此处为一段伪代码。可以在MQTT建连时，通过callback监听云端下发的控制指令或消息。

  调用服务时，同步异步方式取决于物模型中service配置的调用模式：

  • 服务异步方式订阅的Topic为Alink协议标准Topic：/sys/{productKey}/{deviceName}/thing/service/{tsl.service.identifier}。

  • 服务同步方式订阅的Topic需要遵循RRPC Topic模式。

  mqttClient = new MqttClient(url, clientId, persistence);
  final MqttConnectOptions connOpts = new MqttConnectOptions();
  connOpts.setMqttVersion(4);
  connOpts.setAutomaticReconnect(true);
  connOpts.setCleanSession(false);
  connOpts.setUserName(mqttUsername);
  connOpts.setPassword(mqttPassword.toCharArray());
  connOpts.setKeepAliveInterval(65);
  LogUtil.log(clientId + "进行连接, 目的地: " + url);
  
  // 此处订阅云端下发的消息
  mqttClient.setCallback(new MqttCallback() {
      @Override
      public void connectionLost(Throwable cause) {
          LogUtil.log("connection lost, cause:" + cause);
          cause.printStackTrace();
      }
  
      @Override
      public void messageArrived(String topic, MqttMessage message) throws Exception {
          TopicChannel topicChannel = getTopic(topic);
          LogUtil.log("receive message, channel:" + topicChannel
                      + ",topic:" + topic
                      + ", payload:" + new String(message.getPayload(), "UTF-8") + "");
          topicChannel.put(message);
      }
  
      @Override
      public void deliveryComplete(IMqttDeliveryToken token) {
          //如果是qos 0消息 token.resp是没有回复的
          LogUtil.log("sent, " + ((token == null || token.getResponse() == null) ? "null"
                                  : token.getResponse().getKey()));
      }
  });
  
  mqttClient.connect(connOpts);