阿里云物联网平台NET SDK实现RRPC服务端调用

简介: MQTT协议是基于PUB/SUB的异步通信模式,不适用于服务端同步控制设备端返回结果的场景。前面博客基于开源Java MQTT Client的阿里云物联网平台RRPC功能测试介绍了RRPC原理,使用Open API实现服务端的调用实现。本文介绍如何使用NET SDK在本地实现RRPC的服务端调用。

概述

MQTT协议是基于PUB/SUB的异步通信模式,不适用于服务端同步控制设备端返回结果的场景。前面博客基于开源Java MQTT Client的阿里云物联网平台RRPC功能测试介绍了RRPC原理,使用Open API实现服务端的调用实现。本文介绍如何使用NET SDK在本地实现RRPC的服务端调用。

Step By Step

1、创建产品与设备

参考链接 准备工作部分。

2、设备端Code

import com.alibaba.taro.AliyunIoTSignUtil;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import java.util.HashMap;
import java.util.Map;

public class IoTRRPCForSysTopicDemo {

    // 设备三元组信息
    public static String productKey = "a16MX******";
    public static String deviceName = "RRPC******";
    public static String deviceSecret = "Ayq069ifWO7WOmwKyswNLv6E********";
    public static String regionId = "cn-shanghai";

    // RRPC 系统Topic
    private static String subTopic = "/sys/" + productKey + "/" + deviceName+ "/rrpc/request/+";
    private static MqttClient mqttClient;

    public static void main(String [] args) {

        initAliyunIoTClient();

        // RRPC订阅Topic
        try {
            mqttClient.subscribe(subTopic);
        } catch (MqttException e) {
            e.printStackTrace();
        }

        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                System.out.println("connectionLost:" + cause.getMessage());
            }

            @Override
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                System.out.println("message: " + new String(message.getPayload()));
                System.out.println("topic:" + topic);

                // 根据RRPC请求消息Topic,构建RRPC响应消息Topic
                String responseTopic = topic.replace("request","response");
                MqttMessage message1 = new MqttMessage("resonse demo".getBytes("utf-8"));
                mqttClient.publish(responseTopic, message1);
            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
            }
        });
    }

    /***
     * 初始化Client
     */
    private static void initAliyunIoTClient() {

        try {
            String clientId = "java" + System.currentTimeMillis();

            Map<String, String> params = new HashMap<>(16);
            params.put("productKey", productKey);
            params.put("deviceName", deviceName);
            params.put("clientId", clientId);
            String timestamp = String.valueOf(System.currentTimeMillis());
            params.put("timestamp", timestamp);

            // cn-shanghai
            String targetServer = "tcp://" + productKey + ".iot-as-mqtt." + regionId + ".aliyuncs.com:1883";

            String mqttclientId = clientId + "|securemode=3,signmethod=hmacsha1,timestamp=" + timestamp + "|";
            String mqttUsername = deviceName + "&" + productKey;
            String mqttPassword = AliyunIoTSignUtil.sign(params, deviceSecret, "hmacsha1");

            connectMqtt(targetServer, mqttclientId, mqttUsername, mqttPassword);

        } catch (Exception e) {
            System.out.println("initAliyunIoTClient error " + e.getMessage());
        }
    }

    public static void connectMqtt(String url, String clientId, String mqttUsername, String mqttPassword) throws Exception {

        MemoryPersistence persistence = new MemoryPersistence();
        mqttClient = new MqttClient(url, clientId, persistence);
        MqttConnectOptions connOpts = new MqttConnectOptions();
        // MQTT 3.1.1
        connOpts.setMqttVersion(4);
        connOpts.setAutomaticReconnect(false);
        connOpts.setCleanSession(true);

        connOpts.setUserName(mqttUsername);
        connOpts.setPassword(mqttPassword.toCharArray());
        connOpts.setKeepAliveInterval(60);

        mqttClient.connect(connOpts);
    }
}

3、云端Code

  • 3.1 SDK安装:
Install-Package aliyun-net-sdk-iot -Version 7.4.0

_

  • 3.2 NET Code
using System;
using System.Text;
using Aliyun.Acs.Core;
using Aliyun.Acs.Core.Exceptions;
using Aliyun.Acs.Core.Profile;
using Aliyun.Acs.Iot.Model.V20180120;

namespace IoTRRPCDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // ak,sk https://yq.aliyun.com/articles/693979
            IClientProfile profile = DefaultProfile.GetProfile("cn-shanghai", "LTAIOZZg********", "v7CjUJCMk7j9aKduMAQLjy********");
            DefaultAcsClient client = new DefaultAcsClient(profile);
            client.SetConnectTimeoutInMilliSeconds(8000);// 设置 Client 连接超时时间,默认是5S,RRPC响应超过5S是必须设置


            var request = new RRpcRequest();
            request.Timeout = 8000;
            // 设置设备三元组信息
            request.DeviceName = "RRPC******";
            request.RequestBase64Byte = "5raI5oGv5LiL6KGM5rWL6K+V";  // 消息下行测试 base64编码内容
            request.ProductKey = "a16MX******";

            try
            {
                var response = client.GetAcsResponse(request);
                Console.WriteLine(Encoding.Default.GetString(response.HttpResponse.Content));
                Console.ReadKey();
            }
            catch (ServerException e)
            {
                Console.WriteLine("ServerException:");
                Console.WriteLine(e);
                Console.ReadKey();
            }
            catch (ClientException e)
            {
                Console.WriteLine("ClientException: ");
                Console.WriteLine(e);
                Console.ReadKey();
            }
        }
    }
}

4、测试情况

  • 4.1 设备端

_

  • 4.2 云端

_

参考链接

基于开源Java MQTT Client的阿里云物联网平台RRPC功能测试

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
相关文章
|
1月前
|
消息中间件 物联网 网络安全
MQTT常见问题之调用.net sdk 报“不知道这样的主机”如何解决
MQTT(Message Queuing Telemetry Transport)是一个轻量级的、基于发布/订阅模式的消息协议,广泛用于物联网(IoT)中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总:
|
4天前
|
XML 开发工具 iOS开发
替代微信ipad协议的sdk方案分享
替代微信ipad协议的sdk方案分享
8 0
|
1月前
|
消息中间件 网络协议 开发工具
MQ产品使用合集之rocketmq5.x只有tcp接入点吗,python sdk需要http接入点,请问怎么使用
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
API Python
调用物联网平台云端api时的签名python3实现
调用物联网平台云端api时的签名python3实现。
178 0
|
Java 测试技术 API
.net core实践系列之短信服务-Api的SDK的实现与测试(二)
.net core实践系列之短信服务-Api的SDK的实现与测试(二)
152 0
.net core实践系列之短信服务-Api的SDK的实现与测试(二)
|
弹性计算 Ubuntu 物联网
编译并调用iot中云端api的pub c++版本
编译并调用iot中云端api的pub c++版本。
336 0
编译并调用iot中云端api的pub c++版本
|
网络协议 物联网 Java
阿里云物联网平台MQTT通道的动态注册(Python)
目前阿里云物联网平台MQTT通道的动态注册,仅提供了Java的示例代码。本文基于开源的Paho MQTT库,使用Python进行接入。
818 0
阿里云物联网平台MQTT通道的动态注册(Python)
HH
|
物联网 API 开发工具
阿里云物联网平台之Open Api调用
物联网平台可以通过调用云端API,以实现物联网平台的云端能力,如产品管理、设备管理、Topic管理、数据流转规则管理、消息通信等。 (本文以Common sdk和云端sdk创建设备为例)。
HH
2545 0
阿里云物联网平台之Open Api调用
|
编解码 小程序 调度
产品百科 |阿里云 RTC Web SDK 常见问题汇总
本章节为您介绍了集成 SDK 时,集成工具报错的处理方法,帮助您快速定位问题,并集成 SDK。
产品百科 |阿里云 RTC Web SDK 常见问题汇总
|
移动开发 开发工具 Android开发
产品百科 |RTC SDK 媒体扩展信息的使用说明
本文为您介绍媒体扩展信息的使用说明,您可以使用传递时间戳和位控制信息,以达到更好的产品体验。
产品百科 |RTC SDK 媒体扩展信息的使用说明

热门文章

最新文章

相关产品

  • 物联网平台