阿里云微服务消息队列(MQTT For IoT)C# 获取Token示例Demo

概述

微消息队列MQTT通过Token鉴权模式向MQTT客户端提供有时效性的临时访问权限。通过MQTT Token服务可以给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端，单一资源的细粒度权限控制。目前官方已经给出了Java获取Token的Demo，下面给出基于C#获取Token的实现，然后使用PostMan工具测试，用户可以基于PostMan工具生成其它语言获取Token的方法。

相关参考

1、API官方说明地址；

2、参考Java Demo；

C# Code实现

1、Nuget 安装：Newtonsoft，处理Json对象使用；

2、完整的Code Sample

using System; using System.Collections.Generic; using System.IO; using System.Net; using System.Security.Cryptography; using System.Text; using Newtonsoft.Json.Linq; namespace MQTTTokenDemo { class Program { static void Main(string[] args) { // 参数解释：https://help.aliyun.com/document_detail/54276.html?spm=a2c4g.11186623.6.572.632e2584wtKkVY string resources = "Demodd/AAA"; string instanceId = "post-cn-mp9********"; string accessKey = "********"; string secretkey = "********"; long expireTime = 10000000L; applyToken(resources, instanceId, accessKey, secretkey, expireTime); } /// <summary> /// 请求获取Token /// </summary> /// <param name="resources">资源名称，即 MQTT Topic，多个 Topic 以逗号（,）分隔</param> /// <param name="instanceId">MQTT 实例 ID，一定要和客户端实际使用的实例 ID 匹配</param> /// <param name="accessKey">当前请求使用的账号的 AccessKeyId</param> /// <param name="secretkey">当前请求使用的账号的 AccessSecretId</param> /// <param name="expireTime">Token 失效的毫秒时间戳</param> public static void applyToken(string resources, string instanceId, string accessKey, string secretkey, long expireTime) { string apiUrl = "https://mqauth.aliyuncs.com/token/apply"; Dictionary<string, string> paramDic = new Dictionary<string, string>(); paramDic.Add("resources", resources); paramDic.Add("actions", "R,W"); paramDic.Add("serviceName", "mq"); paramDic.Add("expireTime", (((DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000) + expireTime).ToString()); paramDic.Add("instanceId", instanceId); string signature = doHttpSignature(paramDic, secretkey); paramDic.Add("proxyType", "MQTT"); paramDic.Add("accessKey", accessKey); paramDic.Add("signature", System.Web.HttpUtility.UrlEncode(signature)); // 注意：此处务必对求得的signature进行urlencode处理，否则可能会因为不同时间求取的signature中可能包含特殊字符而出现请求407报错 //Console.WriteLine(sendRequestToGetToken(apiUrl, paramDic)); JObject json = JObject.Parse(sendRequestToGetToken(apiUrl, paramDic)); Console.WriteLine("Token: " + json["tokenData"].ToString()); Console.ReadKey(); } /// <summary> /// 计算签名signature /// </summary> /// <param name="paramDic"> 参数字典 </param> /// <param name="secretKey"> accessSecret </param> /// <returns> 返回签名 </returns> public static string doHttpSignature(Dictionary<string, string> paramDic, string secretKey) { List<string> paramList = new List<string>(); foreach (KeyValuePair<string, string> kvp in paramDic) { paramList.Add(kvp.Key + "=" + kvp.Value); } paramList.Sort(); StringBuilder stringBuilder = new StringBuilder(); for (int i = 0; i < paramList.Count; i++) { if (i > 0) { stringBuilder.Append("&"); } stringBuilder.Append(paramList[i]); } HMACSHA1 hmacKey = new HMACSHA1(Encoding.UTF8.GetBytes(secretKey)); string signature = Convert.ToBase64String(hmacKey.ComputeHash(Encoding.UTF8.GetBytes(stringBuilder.ToString()))); return signature; } /// <summary> /// 发送请求以获取token /// </summary> /// <param name="url"> url </param> /// <param name="parameters"> 请求的参数 </param> /// <param name="encoding"> 请求参数的编码方式 </param> /// <returns> 返回响应结果 </returns> public static string sendRequestToGetToken(string url, Dictionary<string, string> parameters) { //设置请求接口 var request = (HttpWebRequest)WebRequest.Create(url); byte[] data = null; StringBuilder buffer = new StringBuilder(); // 设置请求参数 if (!(parameters == null || parameters.Count == 0)) { int i = 0; foreach (string key in parameters.Keys) { if (i > 0) { buffer.AppendFormat("&{0}={1}", key, parameters[key]); } else { buffer.AppendFormat("{0}={1}", key, parameters[key]); } i++; } } data = Encoding.UTF8.GetBytes(buffer.ToString()); //请求方式 request.Method = "POST"; //请求头参数设置 request.ContentType = "application/x-www-form-urlencoded"; request.ContentLength = data.Length; using (var stream = request.GetRequestStream()) { stream.Write(data, 0, data.Length); } WebResponse response; try { response = request.GetResponse(); } catch (WebException ex) { response = ex.Response; } //转字符串 string responseString = new StreamReader(response.GetResponseStream()).ReadToEnd(); return responseString; } } }

3、测试运行结果

Post Man工具使用

1、具体的测试参数可以在上面Code的parameters对象中获取

2、请求参数设置

3、一键生成其它语言Demo

注意: signature参数还是需要使用者基于自己的开发语言自行参考Java或C# Demo实现。

参考链接

lmq-demo
C# POST请求demo，contentType 格式：application/x-www-form-urlencoded