.net进行微信公众号开发的例子好像比较少,这里做个笔记
首先,我们需要让微信能访问到我们的项目,所以要么需要有一个可以部署项目的连接到公网下的服务器,要么可以通过端口转发将请求转发到我们的项目,总之,就是要让微信服务器能访问到我们的项目。
另外,需要注意一下,微信回调通知的地址目前只支持80端口和443端口,所以一般的,我们都需要做个虚拟路径
其他的就不多说了,具体配置可以在微信公众号的开发文档中接入:https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Access_Overview.html
接入过程中会遇到很多坑,什么Url超时,Token验证错误等等,反正就是一些触不及防,当我们接入开发完后,发现我们使用的是明文传送,那当然就不行了,改成密文又要使用AES加密,反正接入不知道遇到多少坑
下面贴出我接入的代码,复制一下,稍稍修改就可以用了,可直接验证接入,支持明文密文传输:
一个加密解密辅助类:
using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
using System.Xml;
namespace DemoApi
{
public sealed class EncryptHelper
{
private EncryptHelper() { }
/// <summary>
/// Md5加密
/// </summary>
/// <param name="text"></param>
/// <returns></returns>
public static string Md5Encrypt(string text)
{
//MD5加密
var md5 = MD5.Create();
var bs = md5.ComputeHash(Encoding.UTF8.GetBytes(text));
var sb = new StringBuilder();
foreach (byte b in bs)
{
sb.Append(b.ToString("x2"));
}
//所有字符转为大写
return sb.ToString().ToUpper();
}
/// <summary>
/// HMAC-SHA1加密算法
/// </summary>
/// <param name="str">加密字符串</param>
/// <returns></returns>
public static string Sha1Encrypt(string str)
{
var sha1 = SHA1.Create();
var hash = sha1.ComputeHash(Encoding.Default.GetBytes(str));
//return BitConverter.ToString(hash).Replace("-", "");
string byte2String = null;
for (int i = 0; i < hash.Length; i++)
{
byte2String += hash\[i\].ToString("x2");
}
return byte2String;
}
/// <summary>
/// AES加密
/// </summary>
/// <param name="text">加密字符</param>
/// <param name="encodingAESKey">加密的密码</param>
/// <param name="appid">appId</param>
/// <returns></returns>
public static string AESEncrypt(string text, string encodingAESKey, string appid)
{
if (string.IsNullOrEmpty(text))
{
return text;
}
byte\[\] key;
key = Convert.FromBase64String(encodingAESKey + "=");
byte\[\] iv = new byte\[16\];
Array.Copy(key, iv, 16);
#region 生成随机值
string codeSerial = "2,3,4,5,6,7,a,c,d,e,f,h,i,j,k,m,n,p,r,s,t,A,C,D,E,F,G,H,J,K,M,N,P,Q,R,S,U,V,W,X,Y,Z";
string\[\] arr = codeSerial.Split(',');
string code = "";
int randValue = -1;
Random rand = new Random(unchecked((int)DateTime.Now.Ticks));
for (int i = 0; i < 16; i++)
{
randValue = rand.Next(0, arr.Length - 1);
code += arr\[randValue\];
}
#endregion
byte\[\] bRand = Encoding.UTF8.GetBytes(code);
byte\[\] bAppid = Encoding.UTF8.GetBytes(appid);
byte\[\] btmpMsg = Encoding.UTF8.GetBytes(text);
int outval = 0, inval = btmpMsg.Length;
for (int i = 0; i < 4; i++)
outval = (outval << 8) + ((inval >> (i \* 8)) & 255);
byte\[\] bMsgLen = BitConverter.GetBytes(outval);
byte\[\] bMsg = new byte\[bRand.Length + bMsgLen.Length + bAppid.Length + btmpMsg.Length\];
Array.Copy(bRand, bMsg, bRand.Length);
Array.Copy(bMsgLen, 0, bMsg, bRand.Length, bMsgLen.Length);
Array.Copy(btmpMsg, 0, bMsg, bRand.Length + bMsgLen.Length, btmpMsg.Length);
Array.Copy(bAppid, 0, bMsg, bRand.Length + bMsgLen.Length + btmpMsg.Length, bAppid.Length);
var aes = new RijndaelManaged();
//秘钥的大小,以位为单位
aes.KeySize = 256;
//支持的块大小
aes.BlockSize = 128;
//填充模式
//aes.Padding = PaddingMode.PKCS7;
aes.Padding = PaddingMode.None;
aes.Mode = CipherMode.CBC;
aes.Key = key;
aes.IV = iv;
var encrypt = aes.CreateEncryptor(aes.Key, aes.IV);
byte\[\] xBuff = null;
byte\[\] msg = new byte\[bMsg.Length + 32 - bMsg.Length % 32\];
Array.Copy(bMsg, msg, bMsg.Length);
#region 自己进行PKCS7补位,用系统自己带的不行,微信加密要使用这个
int block\_size = 32;
// 计算需要填充的位数
int amount\_to\_pad = block\_size - (bMsg.Length % block\_size);
if (amount\_to\_pad == 0)
{
amount\_to\_pad = block\_size;
}
// 获得补位所用的字符
char pad\_chr = (char)(byte)(amount\_to\_pad & 0xFF);
string tmp = "";
for (int index = 0; index < amount\_to\_pad; index++)
{
tmp += pad\_chr;
}
byte\[\] pad = Encoding.UTF8.GetBytes(tmp);
Array.Copy(pad, 0, msg, bMsg.Length, pad.Length);
using (var ms = new MemoryStream())
{
using (var cs = new CryptoStream(ms, encrypt, CryptoStreamMode.Write))
{
cs.Write(msg, 0, msg.Length);
}
xBuff = ms.ToArray();
}
#endregion
#region 注释的也是一种方法,效果一样,微信加密不能使用这个!!!!
//ICryptoTransform transform = aes.CreateEncryptor();
//xBuff = transform.TransformFinalBlock(msg, 0, msg.Length);
#endregion
string output = Convert.ToBase64String(xBuff);
return output;
}
/// <summary>
/// AES解密
/// </summary>
/// <param name="encryptText">密文</param>
/// <param name="encodingAESKey">秘钥</param>
/// <param name="appid"></param>
/// <returns></returns>
public static string AESDecrypt(string encryptText, string encodingAESKey, out string appid)
{
if (string.IsNullOrEmpty(encryptText))
{
appid = "";
return encryptText;
}
byte\[\] key;
key = Convert.FromBase64String(encodingAESKey + "=");
byte\[\] iv = new byte\[16\];
Array.Copy(key, iv, 16);
byte\[\] btmpMsg = null;
RijndaelManaged aes = new RijndaelManaged();
aes.KeySize = 256;
aes.BlockSize = 128;
aes.Mode = CipherMode.CBC;
aes.Padding = PaddingMode.None;
aes.Key = key;
aes.IV = iv;
var decrypt = aes.CreateDecryptor(aes.Key, aes.IV);
using (var ms = new MemoryStream())
{
using (var cs = new CryptoStream(ms, decrypt, CryptoStreamMode.Write))
{
byte\[\] xXml = Convert.FromBase64String(encryptText);
byte\[\] msg = new byte\[xXml.Length + 32 - xXml.Length % 32\];
Array.Copy(xXml, msg, xXml.Length);
cs.Write(xXml, 0, xXml.Length);
}
var decrypted = ms.ToArray();
int pad = (int)decrypted\[decrypted.Length - 1\];
if (pad < 1 || pad > 32)
{
pad = 0;
}
btmpMsg = new byte\[decrypted.Length - pad\];
Array.Copy(decrypted, 0, btmpMsg, 0, decrypted.Length - pad);
}
int len = BitConverter.ToInt32(btmpMsg, 16);
len = IPAddress.NetworkToHostOrder(len);
byte\[\] bMsg = new byte\[len\];
byte\[\] bAppid = new byte\[btmpMsg.Length - 20 - len\];
Array.Copy(btmpMsg, 20, bMsg, 0, len);
Array.Copy(btmpMsg, 20 + len, bAppid, 0, btmpMsg.Length - 20 - len);
string oriMsg = Encoding.UTF8.GetString(bMsg);
appid = Encoding.UTF8.GetString(bAppid);
return oriMsg;
}
/// <summary>
/// AES解密
/// </summary>
/// <param name="encryptText">密文</param>
/// <param name="encodingAESKey">秘钥</param>
/// <param name="appid"></param>
/// <returns></returns>
public static string AESDecrypt(string encryptText, string encodingAESKey)
{
return AESDecrypt(encryptText, encodingAESKey, out \_);
}
}
public class CharSort : IComparer
{
public int Compare(object left, object right)
{
string sLeft = left as string;
string sRight = right as string;
int leftLength = sLeft.Length;
int rightLength = sRight.Length;
int index = 0;
while (index < leftLength && index < rightLength)
{
if (sLeft\[index\] < sRight\[index\])
return -1;
else if (sLeft\[index\] > sRight\[index\])
return 1;
else
index++;
}
return leftLength - rightLength;
}
}
}
EncryptHelper
接入接口核心代码:
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Threading.Tasks;
using System.Web;
using System.Xml.Linq;
using Microsoft.AspNetCore.Mvc;
namespace DemoApi.Controllers
{
[Route("api/[controller]")]
[ApiController]
public class WxController : ControllerBase
{
///
///
///
[NonAction]
private string MakeSign(params string[] args)
{
//字典排序
Array.Sort(args);
string tmpStr = string.Join("", args);
//字符加密
var sha1 = EncryptHelper.Sha1Encrypt(tmpStr);
return sha1;
}
///
///
///
[NonAction]
private string MakeMsgSign(params string[] args)
{
//字典排序
Array.Sort(args, new CharSort());
string tmpStr = string.Join("", args);
//字符加密
var sha1 = EncryptHelper.Sha1Encrypt(tmpStr);
return sha1;
}
///
///
[HttpGet, HttpPost]
public string Service()
{
//获取配置文件中的数据
var token = "";
var encodingAESKey = "";
var appId = "";
bool isGet = string.Equals(HttpContext.Request.Method, HttpMethod.Get.Method, StringComparison.OrdinalIgnoreCase);
bool isPost = string.Equals(HttpContext.Request.Method, HttpMethod.Post.Method, StringComparison.OrdinalIgnoreCase);
if (!isGet && !isPost)
{
return "";
}
bool isEncrypt = false;
try
{
var query = HttpContext.Request.QueryString.ToString();
string msg\_signature = "", nonce = "", timestamp = "", encrypt\_type = "", signature = "", echostr = "";
if (!string.IsNullOrEmpty(query))//需要验证签名
{
var collection = HttpUtility.ParseQueryString(query);
msg\_signature = collection\["msg\_signature"\]?.Trim();
nonce = collection\["nonce"\]?.Trim();
timestamp = collection\["timestamp"\]?.Trim();
encrypt\_type = collection\["encrypt\_type"\]?.Trim();
signature = collection\["signature"\]?.Trim();
echostr = collection\["echostr"\]?.Trim();
if (!string.IsNullOrEmpty(encrypt\_type))//有使用加密
{
if (!string.Equals(encrypt\_type, "aes", StringComparison.OrdinalIgnoreCase))//只支持AES加密方式
{
return "";
}
isEncrypt = true;
}
}
//先验证签名
if (!string.IsNullOrEmpty(signature))
{
//字符加密
var sha1 = MakeSign(nonce, timestamp, token);
if (!sha1.Equals(signature, StringComparison.OrdinalIgnoreCase))//验证不通过
{
return "";
}
if (isGet)//是否Get请求,如果true,那么就认为是修改服务器回调配置信息
{
return echostr;
}
}
else
{
return "";//没有签名,请求直接返回
}
var body = new StreamReader(HttpContext.Request.Body).ReadToEnd();
if (isEncrypt)
{
XDocument doc = XDocument.Parse(body);
var encrypt = doc.Element("xml").Element("Encrypt");
//验证消息签名
if (!string.IsNullOrEmpty(msg\_signature))
{
//消息加密
var sha1 = MakeMsgSign(nonce, timestamp, encrypt.Value, token);
if (!sha1.Equals(msg\_signature, StringComparison.OrdinalIgnoreCase))//验证不通过
{
return "";
}
}
body = EncryptHelper.AESDecrypt(encrypt.Value, encodingAESKey);//解密
}
if (!string.IsNullOrEmpty(body))
{
//
//在这里根据body中的MsgType和Even来区分消息,然后来处理不同的业务逻辑
//
//
//result是上面逻辑处理完成之后的待返回结果,如返回文本消息:
var result = @"<xml>
<ToUserName><!\[CDATA\[toUser\]\]></ToUserName>
<FromUserName><!\[CDATA\[fromUser\]\]></FromUserName>
<CreateTime>12345678</CreateTime>
<MsgType><!\[CDATA\[text\]\]></MsgType>
<Content><!\[CDATA\[你好\]\]></Content>
</xml>";
if (!string.IsNullOrEmpty(result))
{
if (isEncrypt)
{
result = EncryptHelper.AESEncrypt(result, encodingAESKey, appId);
var \_msg\_signature = MakeMsgSign(nonce, timestamp, result, token);
result = $@"<xml>
<Encrypt><!\[CDATA\[{result}\]\]></Encrypt>
<MsgSignature>{\_msg\_signature}</MsgSignature>
<TimeStamp>{timestamp}</TimeStamp>
<Nonce>{nonce}</Nonce>
</xml>";
}
return result;
}
//如果这里我们的处理逻辑需要花费较长时间,可以这里先返回空(""),然后使用异步去处理业务逻辑,
//异步处理完后,调用微信的客服消息接口通知微信服务器
}
}
catch (Exception ex)
{
//记录异常日志
}
return "";
}
}
}
WxController
如果只是接入,只需复制上面的接口代码,修改一下token,encodingAESKey,appId的值,然后使用接入的回调Url:http://XXX.XXXX.com/api/Wx就可以了
如果要处理微信通知过来的消息,可根据上面的接口自行处理业务逻辑,不过需要注意的是,微信回调接口只会等待5秒,5秒后断开,并重复3次,所以如果这里业务逻辑处理时间比较长的话,建议使用异步,在异步处理完之后,使用客服消息接口进行结果通知
另外开发过程中,可以使用微信公众平台接口调试工具进行调试:https://mp.weixin.qq.com/debug/cgi-bin/apiinfo?t=index
有一点注意一下,一般的,我们写接口时,为了保证接口返回的数据有一定格式,所以会写一些过滤器,对接口进行一个包装,比如我们会将结果包装成以下结构:
{
"result": "success",
"success": true,
"error": null,
"message": ""
}
但是这个微信调用的接口不能包装,要返回微信指定的格式才行,这个切记!!!否则会返回Token验证失败的错误!
手机扫一扫
移动阅读更方便
你可能感兴趣的文章