asp.net core 阿里云消息服务(Message Service,原MQS)发送接口的实现

asp.net core 阿里云消息服务(Message Service,原MQS)发送接口的实现最近在后台处理订单统计等相关功能用到了大力的mqs,由于官方没有实现asp.netcore的sdk,这里简单实现了发送信息的功能,有兴趣的可以参考实现其他相关功能usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Net.Http;usingSystem.Net.Http.Headers;…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全家桶1年46,售后保障稳定

最近在后台处理订单统计等相关功能用到了大力的mqs,由于官方没有实现asp.net core的sdk,这里简单实现了发送信息的功能,有兴趣的可以参考实现其他相关功能

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;

namespace Iyibank.Aliyun.MNS
{

public class MQHelper
{

private string url;
private string accessKeyId;
private string accessKeySecret;

private string host;
private string version = “2015-06-06”;

public MQHelper(string url, string accessKeyId, string accessKeySecret)
{

this.url = url;
this.accessKeyId = accessKeyId;
this.accessKeySecret = accessKeySecret;

this.host = url.StartsWith(“http://”) ? url.Substring(7) : url;

}
/// <summary>
/// URL 中的 Key,Tag以及 POST Content-Type 没有任何的限制,只要确保Key 和 Tag 相同唯一即可
/// </summary>
/// <param name=”tag”></param>
/// <param name=”body”></param>
/// <returns></returns>
public async Task<bool> Pub(string name, string body)
{

try
{

using (HttpClient httpClient = new HttpClient())
{

Dictionary<string, string> headers = new Dictionary<string, string>();
headers.Add(“Host”, this.host);
headers.Add(“Date”, DateTime.Now.ToUniversalTime().ToString(“r”));
headers.Add(“x-mns-version”, this.version);
headers[“Content-Type”] = “text/xml”;
string url = string.Format(“{0}/{1}”, name, “messages”);
headers.Add(“Authorization”, this.authorization(“POST”, headers, string.Format(“{0}”, “/queues/” + name + “/messages”)));

foreach (var kv in headers)
{

if (kv.Key != “Content-Type”)
{

httpClient.DefaultRequestHeaders.Add(kv.Key, kv.Value);
}

}
httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue(“application/xml”));
StringBuilder sb = new StringBuilder();
sb.Append(” <Message> “);
sb.Append(“<MessageBody>” + Convert.ToBase64String(System.Text.Encoding.UTF8.GetBytes(body)) + “</MessageBody> “);
sb.Append(“<DelaySeconds>0</DelaySeconds> “);
sb.Append(” <Priority>1</Priority>”);
sb.Append(“</Message>”);
HttpContent content = new StringContent(sb.ToString());
content.Headers.ContentType = new MediaTypeHeaderValue(“text/xml”);
httpClient.DefaultRequestHeaders.Connection.Add(“keep-alive”);
var res = await httpClient.PostAsync(this.url + “/” + string.Format(“queues/{0}/{1}”, name, “messages”), content);
if (res.StatusCode == System.Net.HttpStatusCode.Created)
{

return true;
}
return false;
}
}
catch { return false; }
}
/// <summary>
/// 生成验证信息
/// </summary>
/// <param name=”method”></param>
/// <param name=”headers”></param>
/// <param name=”resource”></param>
/// <returns></returns>
private string authorization(string method, Dictionary<string, string> headers, string resource)
{

return string.Format(“MNS {0}:{1}”, this.accessKeyId, this.signature(“POST”, headers, resource));
}
/// <summary>
/// 签名
/// </summary>
/// <param name=”method”></param>
/// <param name=”headers”></param>
/// <param name=”resource”></param>
/// <returns></returns>
private string signature(string method, Dictionary<string, string> headers, string resource)
{

List<string> toSign = new List<string>();
toSign.Add(method.ToString());
toSign.Add(headers.ContainsKey(“Content-MD5”) ? headers[“Content-MD5”] : string.Empty);
toSign.Add(headers.ContainsKey(“Content-Type”) ? headers[“Content-Type”] : string.Empty);
toSign.Add(headers.ContainsKey(“Date”) ? headers[“Date”] : DateTime.Now.ToUniversalTime().ToString(“r”));

 

foreach (KeyValuePair<string, string> header in headers.Where(kv => kv.Key.StartsWith(“x-mns-“)).OrderBy(kv => kv.Key))
{

toSign.Add(string.Format(“{0}:{1}”, header.Key, header.Value));
}

toSign.Add(resource);

HMACSHA1 hmac = new HMACSHA1(Encoding.UTF8.GetBytes(this.accessKeySecret));
string key = string.Join(“\n”, toSign);
var hashBytes = hmac.ComputeHash(Encoding.UTF8.GetBytes(string.Join(“\n”, toSign)));
return Convert.ToBase64String(hashBytes);
}
}
}

转载于:https://www.cnblogs.com/zhangkjun/p/6143381.html

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/222978.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 武侠世界2-try catch思考

    以前一直不知道trycatch具体应用到什么地方,之前待过的几家公司也看不到有类似的代码。从网上搜来的,描述trycatch优点有下面几点。1、把错误处理和真正的工作分开来;  2、代码更易组织,更清晰,复杂的工作任务更容易实现;  3、毫无疑问,更安全了,不至于由于一些小的疏忽而使程序意外崩溃了;  4、由于C++中的trycatch可以分层嵌套,所以它…

  • Drupal安装及使用问题解决列表

    Drupal安装及使用问题解决列表#1.启动CleanURL修改Apache的配置文件(如httpd.conf),打开LoadModulerewrite_modulemodules/mod_rewrite.so选项。然后在<Directory/>模块中修改AllowOverride属性为ALL。如下所示<Directory> OptionsFollowSymL…

  • 代码保护(一) 几款加壳工具[通俗易懂]

    代码保护(一) 几款加壳工具[通俗易懂]DRMsoftEncryptEXE(有激活成功教程版)加密模式:非绑定模式—-加密后的文件不绑定用户电脑,但用户需要一个开启密码才可以打开绑定模式—-一机一码授权,加密后的文件不同用户电脑需要不同的开启密码无密码模式—-加密后的文件无需要开启密码即可运行,仅对原始文件做加密保护一码通模式—-采用相同秘钥和产品编号加密的不同文件,在同台电脑上只需认证一次特点:可以设置加密…

  • 总结ThinkPHP使用技巧经验分享(二)

    总结ThinkPHP使用技巧经验分享(二)

  • Start Failed Android studio

    Start Failed Android studio

  • 微信推送消息遇到的坑 – 返回error code 40008,并且发送不成功[通俗易懂]

    微信推送消息遇到的坑 – 返回error code 40008,并且发送不成功[通俗易懂]api文档就是这里啦。https://work.weixin.qq.com/api/doc#90000/90135/90236/%E6%96%87%E6%9C%AC%E6%B6%88%E6%81%AF我感觉腾讯并没有把这个errorcode做得很细,反之,非常笼统,让你看到这个err不知所措不晓得到底啥问题。我这边要用微信接收系统发出来的alert,比如哪个服务器cpu负荷…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号