1 准备工作

设备端可以使用C,C++，Android等语言开发，后台服务使用Java SpringBoot构建；消息服务使用阿里云物联网平台；下面主要介绍企业服务器和物联网平台的通信。
步骤1：通过HTTP/2协议订阅设备端消息
步骤2：通过提供的SDK api接口发布消息，给设备端订阅。

image.png

首先申请阿里云账户，在阿里云平台新建产品和设备获取三元组信息

1.1 新建产品和设备

image.png

1.2设备三元组

image.png

1.3开启订阅服务

选择产品中的服务端订阅菜单，点击设置

image.png

有三个选型，可以根据需要进行选择

image.png

2 服务器端订阅

2.1 接入HTTP/2 SDK

请确保JDK版本为8

<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>iot-client-message</artifactId>
    <version>1.1.3</version>
</dependency>

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.7.1</version>
</dependency>

2.2 消息订阅

通过阿里云账号AccessKey进行身份认证，建立SDK与物联网平台的连接，并订阅设备topic，接手设备端消息

      logger.info("==========init AioT properties===========");
     // endPoint:  https://${uid}.iot-as-http2.${region}.aliyuncs.com
    // uid是阿里云账户id  egionId是物联网平台服务所在地域代码
      String endPoint = "https://" + aiotConfig.getUserUid() + ".iot-as-http2." + aiotConfig.getRegionId() + ".aliyuncs.com";
        // 连接配置
      Profile profile = Profile.getAccessKeyProfile(endPoint, aiotConfig.getRegionId(), aiotConfig.getAccessKey(), aiotConfig.getAccessSecret());
        // 构造客户端
      MessageClient client = MessageClientFactory.messageClient(profile);
        // 数据接收
      client.connect(messageToken -> {
            Message m = messageToken.getMessage();
            return MessageCallback.Action.CommitSuccess;
        });
       MessageCallback messageCallback = new MessageCallback() {
            @Override
            public Action consume(MessageToken messageToken) {
                Message message = messageToken.getMessage();
                logger.info("receive : " + new String(message.getPayload()));
                //订阅消息处理服务 payload数据体
                aiotPublishService.pub(message);
                return MessageCallback.Action.CommitSuccess;
            }
        };
      //设备端消息订阅 topic
       client.setMessageListener("/ProductKey/DeviceName/user/update ",messageCallback);

2.3 消息发布

物联网平台提供的云端SDK，通过提供的API发布消息

2.3.1 maven依赖

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-iot</artifactId>
    <version>6.11.0</version>
</dependency>
<!-- 公共依赖包，订阅消息也需要引入 -->
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.5.1</version>
</dependency>

2.3.1 服务端消息发布

/**
 * 服务的消息发布
 * @param mesg
 * @throws IOException
 */
public static void pub(String mesg) {
    MessagePack msgpack = new MessagePack();
    byte[] values = msgpack.write(mesg);
    PubRequest request = new PubRequest();
    request.setProductKey("a12zcpFg9L2"); 
    request.setMessageContent(Base64.encodeBase64String(values));
       //消息发布topic
    request.setTopicFullName("/a12zcpFg9L2/TestFace01/user/get");
    request.setQos(0); //目前支持QoS0和QoS1 
    try { 
                   //创建连接
           DefaultAcsClient client = conn();
           PubResponse response = client.getAcsResponse(request); 
           System.out.println(response.getSuccess()); 
           System.out.println(response.getErrorMessage());
           
    }catch (ServerException e) {
           e.printStackTrace();
    } catch (ClientException e){
          e.printStackTrace();
    }catch (IOException  e){
          e.printStackTrace();
    }


public static DefaultAcsClient conn() throws ClientException{
    //通过阿里云accessKey管理获取
    String accessKey = "accessKey";
    String accessSecret = "accessSecret";
    DefaultProfile.addEndpoint("cn-shanghai", "cn-shanghai", "Iot", "iot.cn-shanghai.aliyuncs.com");
    IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);
    DefaultAcsClient client = new DefaultAcsClient(profile); //初始化SDK客户端
    return client;
    }

总结

阿里云物联网平台提供产品和设备管理，提供Java SDK方便开发。通过设备三元组（ProductKey，DeviceName，DeviceSecret），实现设备端和服务端的认证，通过消息订阅与发布，实现通信，协议使用MQTT和HTTP/2 ; 数据传输协议使用MessgePack，比Json更小，效率高，节约成本。