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)


相关推荐

  • 新东方网课资源分享_新东方笔记大赛官网

    新东方网课资源分享_新东方笔记大赛官网
    新东方李老师的734条高频词组笔记(实在是太有用了!就转来了,没看过的,赶紧点吧~)

    1.abideby(=befaithfulto;obey)忠于;遵守。
    2.beabsentfrom….缺席,不在
    3.absenceofmind(=beingabsent-minded)心不在焉
    4.absorb(=takeuptheattentionof)吸引…的注意力(被动语态)beabsorbedin

  • vue项目引入外部原生js文件_php引入文件的四个方法

    vue项目引入外部原生js文件_php引入文件的四个方法在开发Vue项目的时候,有时需要使用一些非ES6格式的没有export的js库,可以有如下方法实现:1.在index.html页面使用script标签引入当然也可以使用cdn的地址。这样引入后的内容是全局的,可以在所有地方使用。<!DOCTYPEhtml><html> <head> <title>Map</title> <metacharset=”utf-8″> <meta

  • win10JDK环境变量的配置

    win10JDK环境变量的配置在win10系统下进行jdk环境变量与win7的一些区别,作者踩过一些坑,最后通过网上查找资料才将问题解决,但是网上的资料比较零碎,作者整理一下亲自操作过程并且将步骤详细的写了下来,希望能够帮助需要的人。一、下载安装完成jdk之后,桌面右键此电脑选择属性,进入以下界面,然后选择高级系统设置,进入系统配置二、进入系统配置之后点击环境变量,进入环境变量配置窗口三、此时我们可以看到有用户变量…

  • python3 软连接_python3哪个版本好用

    python3 软连接_python3哪个版本好用在ubuntu下面发现pip的默认版本指向的是python3.6,而因项目需要利用Python2.7.查看pip版本pip–version指向的的Python3.6,而此时已经为Python建立2.7的软连接查看默认调用pip的位置.whichpip输出/usr/local/bin/pip先删除sudorm-rf/usr/local/bin/pip安装python2.7版本的pipsu…

  • pycharm如何关闭更新_win7怎么关闭系统更新

    pycharm如何关闭更新_win7怎么关闭系统更新关闭Pycharm2020.5.22自动更新1.为什么要关闭Pycharm自动更新?有的小白喜欢追新,一旦有更新就会想办法升级,但是很多人使用的专业版是D版,升级后就变为评估板了。所以告诉大家怎么关闭更新。2.操作方法(1)进入pycharm,选择”File”(2)选择“Settings”(3)选择“Appearance&Behavior”(4)选择“SystemSettings”(5)选择“Updates”(6)关闭自动更新“Au

  • 我是如何将网站全站启用Https的?-记录博客安装配置SSL证书全过程

    我是如何将网站全站启用Https的?-记录博客安装配置SSL证书全过程

    2021年10月14日

发表回复

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

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