用c#开发微信（3）基于Senparc.Weixin框架的接收普通消息处理 （源码下载）

本文讲述使用Senparc.Weixin框架来快速处理各种接收的普通消息。这里的消息指的是传统的微信公众平台消息交互，微信用户向公众号发送消息后，公众号回复消息给微信用户。包括以下7种类型：

1 文本消息 2 图片消息 3 语音消息 4 视频消息 5 小视频消息 6 地理位置消息 7 链接消息

实现非常简单，自定义一个继承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类，对微信请求的详细判断操作都在这里面。

var messageHandler = new CustomMessageHandler(Request.InputStream, maxRecordCount);

messageHandler.Execute();

2. 自定义消息处理类

定义CustomMessageHandler继承MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>

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种类型方法来处理我们的业务，当然也可以只重写需要的部分类型，不需要的类型可以不重写，只需要定义一个统一的DefaultResponseMessage

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