用c#开发微信（3）基于Senparc.Weixin框架的接收普通消息处理 （源码下载）
本文讲述使用Senparc.Weixin框架来快速处理各类接收的普通消息。这里的消息指的是传统的微信公众平台消息交互，微信用户向公众号发送消息后，公众号回复消息给微信用户。包括如下7种类型：html
1 文本消息
2 图片消息
3 语音消息
4 视频消息
5 小视频消息
6 地理位置消息
7 连接消息c#
实现很是简单，自定义一个继承MessageHandler的类，重写这7种类型的方法便可。注意：DefaultResponseMessage必须重写，用于返回没有处理过的消息类型（也能够用于默认消息，如帮助信息等）；其中全部原OnXX的抽象方法已经都改成虚方法，能够没必要每一个都重写。若不重写，默认返回DefaultResponseMessage方法中的结果。浏览器
下面详细介绍实现步骤：服务器
1. 添加index页面
private readonly string Token = ConfigurationManager.AppSettings["token"];//与微信公众帐号后台的Token设置保持一致，区分大小写。
protected void Page_Load(object sender, EventArgs e)
{
string signature = Request["signature"];
string timestamp = Request["timestamp"];
string nonce = Request["nonce"];
string echostr = Request["echostr"];
if (Request.HttpMethod == "GET")
{
//get method - 仅在微信后台填写URL验证时触发
if (CheckSignature.Check(signature, timestamp, nonce, Token))
{
WriteContent(echostr); //返回随机字符串则表示验证经过
}
else
{
WriteContent("failed:" + signature + "," + CheckSignature.GetSignature(timestamp, nonce, Token) + "。" +
"若是你在浏览器中看到这句话，说明此地址能够被做为微信公众帐号后台的Url，请注意保持Token一致。");
}
Response.End();
}
else
{
//post method - 当有用户想公众帐号发送消息时触发
if (!CheckSignature.Check(signature, timestamp, nonce, Token))
{
WriteContent("参数错误！");
return;
}
//设置每一个人上下文消息储存的最大数量，防止内存占用过多，若是该参数小于等于0，则不限制
var maxRecordCount = 10;
//自定义MessageHandler，对微信请求的详细判断操做都在这里面。
var messageHandler = new CustomMessageHandler(Request.InputStream, maxRecordCount);
try
{
//测试时可开启此记录，帮助跟踪数据，使用前请确保App_Data文件夹存在，且有读写权限。
messageHandler.RequestDocument.Save(
Server.MapPath("~/App_Data/" + DateTime.Now.Ticks + "_Request_" +
messageHandler.RequestMessage.FromUserName + ".txt"));
//执行微信处理过程
messageHandler.Execute();
//测试时可开启，帮助跟踪数据
messageHandler.ResponseDocument.Save(
Server.MapPath("~/App_Data/" + DateTime.Now.Ticks + "_Response_" +
messageHandler.ResponseMessage.ToUserName + ".txt"));
WriteContent(messageHandler.ResponseDocument.ToString());
return;
}
catch (Exception ex)
{
//将程序运行中发生的错误记录到App_Data文件夹
using (TextWriter tw = new StreamWriter(Server.MapPath("~/App_Data/Error_" + DateTime.Now.Ticks + ".txt")))
{
tw.WriteLine(ex.Message);
tw.WriteLine(ex.InnerException.Message);
if (messageHandler.ResponseDocument != null)
{
tw.WriteLine(messageHandler.ResponseDocument.ToString());
}
tw.Flush();
tw.Close();
}
WriteContent("");
}
finally
{
Response.End();
}
}
}
private void WriteContent(string str)
{
Response.Output.Write(str);
}
1）当Get请求时，调用 CheckSignature.Check(signature, timestamp, nonce, Token) 方法验证url接入， 详情参考 用c#开发微信（1）服务号的服务器配置和企业号的回调模式 - url接入 （源码下载）微信
2) 当有Post请求过来时，调用自定义MessageHandler类，对微信请求的详细判断操做都在这里面。app
var messageHandler = new CustomMessageHandler(Request.InputStream, maxRecordCount);微信公众平台
messageHandler.Execute();框架
2. 自定义消息处理类
定义CustomMessageHandler继承MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>ide
public partial class CustomMessageHandler : MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>
{
public CustomMessageHandler(Stream inputStream, int maxRecordCount = 0)
: base(inputStream, null, maxRecordCount)
{
WeixinContext.ExpireMinutes = 3;
}
public override void OnExecuting()
{
//测试MessageContext.StorageData
if (CurrentMessageContext.StorageData == null)
{
CurrentMessageContext.StorageData = 0;
}
base.OnExecuting();
}
public override void OnExecuted()
{
base.OnExecuted();
CurrentMessageContext.StorageData = ((int)CurrentMessageContext.StorageData) + 1;
}
}
3. 分别重写7种接收普通消息
咱们能够经过重写MessageHandler里的这7种类型方法来处理咱们的业务，固然也能够只重写须要的部分类型，不须要的类型能够不重写，只须要定义一个统一的DefaultResponseMessagepost
public override IResponseMessageBase DefaultResponseMessage(IRequestMessageBase requestMessage)
{
//全部没有被处理的消息会默认返回这里的结果
var responseMessage = this.CreateResponseMessage<ResponseMessageText>();
responseMessage.Content = "这条消息来自DefaultResponseMessage。";
return responseMessage;
}
下面分别就这7种类型，各写一个例子：
1） 文本消息
/// <summary>
/// 处理文字请求
/// </summary>
/// <returns></returns>
public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
{
//注意：下面泛型ResponseMessageText即返回给客户端的类型，能够根据本身的须要填写ResponseMessageNews等不一样类型。
var responseMessage = CreateResponseMessage<ResponseMessageText>();
var result = new StringBuilder();
result.AppendFormat("您刚才发送了文字信息：{0}\r\n\r\n", requestMessage.Content);
if (CurrentMessageContext.RequestMessages.Count > 1)
{
result.AppendFormat("您刚才还发送了以下消息（{0}/{1}）：\r\n", CurrentMessageContext.RequestMessages.Count, CurrentMessageContext.StorageData);
for (int i = CurrentMessageContext.RequestMessages.Count - 2; i >= 0; i--)
{
var historyMessage = CurrentMessageContext.RequestMessages[i];
result.AppendFormat("{0} 【{1}】{2}\r\n",
historyMessage.CreateTime.ToShortTimeString(),
historyMessage.MsgType.ToString(),
(historyMessage is RequestMessageText)
? (historyMessage as RequestMessageText).Content
: "[非文字类型]"
);
}
result.AppendLine("\r\n");
}
result.AppendFormat("若是您在{0}分钟内连续发送消息，记录将被自动保留（当前设置：最多记录{1}条）。过时后记录将会自动清除。\r\n", WeixinContext.ExpireMinutes, WeixinContext.MaxRecordCount);
result.AppendLine("\r\n");
result.AppendLine("您还能够发送【位置】【图片】【语音】【视频】等类型的信息（注意是这几种类型，不是这几个文字），查看不一样格式的回复。");
responseMessage.Content = result.ToString();
return responseMessage;
}
2） 图片消息
/// <summary>
/// 处理图片请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnImageRequest(RequestMessageImage requestMessage)
{
var responseMessage = CreateResponseMessage<ResponseMessageNews>();
responseMessage.Articles.Add(new Article()
{
Title = "您刚才发送了图片信息",
Description = "您发送的图片将会显示在边上",
PicUrl = requestMessage.PicUrl,
Url = "http://www.hp.com"
});
responseMessage.Articles.Add(new Article()
{
Title = "第二条",
Description = "第二条带链接的内容",
PicUrl = requestMessage.PicUrl,
Url = "http://www.hp.com"
});
return responseMessage;
}
3） 语音消息
/// <summary>
/// 处理语音请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnVoiceRequest(RequestMessageVoice requestMessage)
{
var responseMessage = CreateResponseMessage<ResponseMessageMusic>();
responseMessage.Music.MusicUrl = "http://www.qxuninfo.com/music.mp3";
responseMessage.Music.Title = "这里是一条音乐消息";
responseMessage.Music.Description = "时间都去哪儿了";
return responseMessage;
}
4） 视频消息
/// <summary>
/// 处理视频请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnVideoRequest(RequestMessageVideo requestMessage)
{
var responseMessage = CreateResponseMessage<ResponseMessageText>();
responseMessage.Content = "您发送了一条视频信息，ID：" + requestMessage.MediaId;
return responseMessage;
}
5） 小视频消息
/// <summary>
/// 处理小视频请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnShortVideoRequest(RequestMessageShortVideo requestMessage)
{
var responseMessage = this.CreateResponseMessage<ResponseMessageText>();
responseMessage.Content = "您刚才发送的是小视频";
return responseMessage;
}
6） 地理位置消息
/// <summary>
/// 处理位置请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnLocationRequest(RequestMessageLocation requestMessage)
{
var responseMessage = CreateResponseMessage<ResponseMessageText>();
responseMessage.Content = string.Format("您刚才发送了地理位置信息。Location_X：{0}，Location_Y：{1}，Scale：{2}，标签：{3}",
requestMessage.Location_X, requestMessage.Location_Y,
requestMessage.Scale, requestMessage.Label);
return responseMessage;
}
7） 连接消息
/// <summary>
/// 处理连接消息请求
/// </summary>
/// <param name="requestMessage"></param>
/// <returns></returns>
public override IResponseMessageBase OnLinkRequest(RequestMessageLink requestMessage)
{
var responseMessage = CreateResponseMessage<ResponseMessageText>();
responseMessage.Content = string.Format(@"您发送了一条链接信息：
Title：{0}
Description:{1}
Url:{2}", requestMessage.Title, requestMessage.Description, requestMessage.Url);
return responseMessage;
}
从上面的例子中能够看出，回复的消息类型能够多种多样，不必定要跟请求的消息类型同样。
- 框架里的请求类型：
- 框架里的回复类型：
4. 最后发布到本身的服务器上，能够尝试给公众号发各类类型的消息，验证公众号回复的内容
5. 源码
最后整个程序结构以下：
源码下载： http://yunpan.cn/cwsftnRtzK599 访问密码 4247
一样的，使用源码前，要先把配置文件里的参数修改为本身的公众号。
部份类型效果截图：
官方文档： 接收普通消息
相关文章
- 1. 用c#开发微信 (4) 基于Senparc.Weixin框架的接收事件推送处理 （源码下载）
- 2. 微信公众号开发之接收普通消息
- 3. 3 微信公众号开发 接受普通消息
- 4. 微信公众号开发C#系列-六、消息管理-普通消息接受处理
- 5. C#微信公众号开发系列教程四（接收普通消息）
- 6. Delphi XE7 用indy开发微信公众平台（4）- 接收普通消息
- 7. 微信公众号开发系列-六、消息管理-普通消息接受处理
- 8. 微信消息接收事件-将微信接收消息转发到指定服务器的servlet处理
- 9. 微信开发——微信公众平台实现消息接收以及消息的处理（Java版）
- 10. Java开发微信公众号（四）---微信服务器post消息体的接收及消息的处理
- 更多相关文章...
- • Spring使用AspectJ开发AOP：基于XML和基于Annotation - Spring教程
- • C# 异常处理 - C#教程
- • PHP开发工具
- • ☆基于Java Instrument的Agent实现
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. Window下Ribbit MQ安装
- 2. Linux下Redis安装及集群搭建
- 3. shiny搭建网站填坑战略
- 4. Mysql8.0.22安装与配置详细教程
- 5. Hadoop安装及配置
- 6. Python爬虫初学笔记
- 7. 部署LVS-Keepalived高可用集群
- 8. keepalived+mysql高可用集群
- 9. jenkins 公钥配置
- 10. HA实用详解
欢迎关注本站公众号,获取更多信息
相关文章
- 1. 用c#开发微信 (4) 基于Senparc.Weixin框架的接收事件推送处理 （源码下载）
- 2. 微信公众号开发之接收普通消息
- 3. 3 微信公众号开发 接受普通消息
- 4. 微信公众号开发C#系列-六、消息管理-普通消息接受处理
- 5. C#微信公众号开发系列教程四（接收普通消息）
- 6. Delphi XE7 用indy开发微信公众平台（4）- 接收普通消息
- 7. 微信公众号开发系列-六、消息管理-普通消息接受处理
- 8. 微信消息接收事件-将微信接收消息转发到指定服务器的servlet处理
- 9. 微信开发——微信公众平台实现消息接收以及消息的处理（Java版）
- 10. Java开发微信公众号（四）---微信服务器post消息体的接收及消息的处理