C#微信公眾號開發(fā)之消息處理

更新時間：2022年06月15日 11:43:21 作者：艾三元

這篇文章介紹了C#微信公眾號開發(fā)之消息處理，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

前言：

回顧上一節(jié)服務器配置的內容，我們已經可以自己完成公眾號服務器的配置。配置完成之后，我們就可以通過調用的方式，完成對消息管理的處理。當用戶關注公眾號或者發(fā)送消息的時候，我們應該啟用默認回復，要不然用戶得不到回應，

從而導致丟失體驗。所以這一章節(jié)，我們將通過消息管理的方式，對用戶的信息進行處理，完成公眾號消息回復功能，實現(xiàn)公眾號與用戶之間的完整對話。

了解:

微信公眾平臺對信息做了比較清晰的分類，最基本的包括請求（Request）和響應（Response）兩大類信息，這兩類信息有分為文字、語音、圖片等格式。Senparc.Weixin.MP提供了MessageHandler消息處理類，這些類型在以枚舉的方式區(qū)分，

同時根據(jù)嚴格命名規(guī)則命名了所有類型的RequestMessage和ResponseMessage。在Senparc里也詳細說明了如何這個類的

開始：

第一步：

新建一個UserMessageHandler.cs，需要繼承Senparc.Weixin.MP.MessageHandlers<TC>這個抽象類,并重寫所有方法：

    public class UserMessageHandler : MessageHandler<UserMessageContext>
    {
        /// <summary>
        /// 構造函數(shù)
        /// </summary>
        /// <param name="inputStream">構造函數(shù)的inputStream用于接收來自微信服務器的請求流（如果需要在外部處理，這里也可以傳入XDocument）</param>
        /// <param name="postModel">微信公眾服務器Post過來的加密參數(shù)集合（不包括PostData）</param>
        public UserMessageHandler(Stream inputStream, PostModel postModel)
            : base(inputStream, postModel)
        {
           
        }
        public override IResponseMessageBase DefaultResponseMessage(IRequestMessageBase requestMessage)
        {
            /* 所有沒有被處理的消息會默認返回這里的結果
            */
            var responseMessage = this.CreateResponseMessage<ResponseMessageText>();//ResponseMessageText也可以是News等其他類型
            responseMessage.Content = "這條消息來自DefaultResponseMessage。";
            return responseMessage;
        }
    }

using Senparc.Weixin.Context;
using Senparc.Weixin.MP.Entities;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace WeiXinHandler
{
    public class UserMessageContext: MessageContext<IRequestMessageBase, IResponseMessageBase>
    {
        public UserMessageContext()
        {
            /*
            * 注意：即使使用其他類實現(xiàn)IMessageContext，
            * 也務必在這里進行下面的初始化，尤其是設置當前時間，
            * 這個時間關系到及時從緩存中移除過期的消息，節(jié)約內存使用
            */
            base.MessageContextRemoved += UserMessageContext_MessageContextRemoved;
        }

        /// <summary>
        /// 當上下文過期，被移除時觸發(fā)的時間
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        void UserMessageContext_MessageContextRemoved(object sender, Senparc.Weixin.Context.WeixinContextRemovedEventArgs<IRequestMessageBase, IResponseMessageBase> e)
        {
            /* 注意，這個事件不是實時觸發(fā)的（當然你也可以專門寫一個線程監(jiān)控）
             * 為了提高效率，根據(jù)WeixinContext中的算法，這里的過期消息會在過期后下一條請求執(zhí)行之前被清除
             */
            var messageContext = e.MessageContext as CustomMessageContext;
            if (messageContext == null)
            {
                return;//如果是正常的調用，messageContext不會為null
            }
            //TODO:這里根據(jù)需要執(zhí)行消息過期時候的邏輯，下面的代碼僅供參考
            //Log.InfoFormat("{0}的消息上下文已過期",e.OpenId);
            //api.SendMessage(e.OpenId, "由于長時間未搭理客服，您的客服狀態(tài)已退出！");
        }
    }
}

重寫的方法對應了接收不同的Request類型，構造函數(shù)的inputStream用于接收來自微信服務器的請求流

第二步：

基本用戶不同類型的請求，比如用戶向我們發(fā)送一條信息，那么會最終會調用OnTextRequest這個方法，所以在不同的重寫方法內，實現(xiàn)自己的方法。

比如：我們對于文字（Text）信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnTextRequest:

        public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
        {
            var responseMessage = base.CreateResponseMessage<ResponseMessageText>();
            responseMessage.Content = "您剛剛發(fā)送了文字信息：" + requestMessage.Content;  //requestMessage.Content即用戶發(fā)過來的文字內容
            return responseMessage;
        }

對于圖片信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnImageRequest

        /// <summary>
        /// 處理圖片請求
        /// </summary>
        /// <param name="requestMessage"></param>
        /// <returns></returns>
        public override IResponseMessageBase OnImageRequest(RequestMessageImage requestMessage)
        {
            var responseMessage = CreateResponseMessage<ResponseMessageNews>();
            responseMessage.Articles.Add(new Article()
            {
                Title = "您剛才發(fā)送了圖片信息",
                Description = "您發(fā)送的圖片將會顯示在邊上",
                PicUrl = requestMessage.PicUrl,
                Url = "https://www.cnblogs.com/i3yuan/"
            });
            return responseMessage;
        }

對于語音信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnVoiceRequest

        /// <summary>
        /// 處理語音請求
        /// </summary>
        /// <param name="requestMessage"></param>
        /// <returns></returns>
        public override IResponseMessageBase OnVoiceRequest(RequestMessageVoice requestMessage)
        {

            //獲取公眾號
            AccessTokenResult account = Senparc.Weixin.MP.CommonAPIs.CommonApi.GetToken(AppId, AppSecret);

            var responseMessage = CreateResponseMessage<ResponseMessageMusic>();
            //上傳縮略圖
            var uploadResult = Senparc.Weixin.MP.AdvancedAPIs.MediaApi.UploadTemporaryMedia(account.access_token, UploadMediaFileType.image,
                                                         Server.GetMapPath("~/Images/Logo.jpg"));

            //設置音樂信息
            responseMessage.Music.Title = "天籟之音";
            responseMessage.Music.Description = "播放您上傳的語音";
            responseMessage.Music.MusicUrl = "http://sdk.weixin.senparc.com/Media/GetVoice?mediaId=" + requestMessage.MediaId;
            responseMessage.Music.HQMusicUrl = "http://sdk.weixin.senparc.com/Media/GetVoice?mediaId=" + requestMessage.MediaId;
            responseMessage.Music.ThumbMediaId = uploadResult.media_id;
            return responseMessage;
        }

對于視頻信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnVideoRequest

        /// <summary>
        /// 處理視頻請求
        /// </summary>
        /// <param name="requestMessage"></param>
        /// <returns></returns>
        public override IResponseMessageBase OnVideoRequest(RequestMessageVideo requestMessage)
        {
            var responseMessage = CreateResponseMessage<ResponseMessageText>();
            responseMessage.Content = "您發(fā)送了一條視頻信息，ID：" + requestMessage.MediaId;
            return responseMessage;
        }

對于地理信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnLocationRequest

        /// <summary>
        /// 處理位置請求
        /// </summary>
        /// <param name="requestMessage"></param>
        /// <returns></returns>
        public override IResponseMessageBase OnLocationRequest(RequestMessageLocation requestMessage)
        {
            var locationService = new LocationService();
            var responseMessage = locationService.GetResponseMessage(requestMessage as RequestMessageLocation);
            return responseMessage;
        }

對于鏈接信息進行這樣的處理，在UserMessageHandler中我們可以重寫方法OnLinkRequest

        /// <summary>
        /// 處理鏈接消息請求
        /// </summary>
        /// <param name="requestMessage"></param>
        /// <returns></returns>
        public override IResponseMessageBase OnLinkRequest(RequestMessageLink requestMessage)
        {
            var responseMessage = ResponseMessageBase.CreateFromRequestMessage<ResponseMessageText>(requestMessage);
            responseMessage.Content = string.Format(@"您發(fā)送了一條連接信息：
            Title：{0}
            Description:{1}
            Url:{2}", requestMessage.Title, requestMessage.Description, requestMessage.Url);
            return responseMessage;
        }

第三步：

在Action中使用MessageHandler，返回對用戶的處理，在上一節(jié)中我們已經新建了WXController.cs,在其中通過Post的方式處理用戶的請求

        [HttpPost]
        [ActionName("Index")]
        public Task<ActionResult> Post(PostModel postModel)
        {
            return Task.Factory.StartNew<ActionResult>(() =>
            {
                if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
                {
                    return new WeixinResult("參數(shù)錯誤！");
                }
                var messageHandler = new UserMessageHandler(Request.InputStream);
                messageHandler.Execute(); //執(zhí)行微信處理過程
                return new FixWeixinBugWeixinResult(messageHandler);
            }).ContinueWith<ActionResult>(task => task.Result);
        }

messageHandler.Execute();用于執(zhí)行整個信息處理過程，其中會調用重寫的OnxxRequest方法

效果：

測試發(fā)送文本

通過測試公眾號，我們可以發(fā)現(xiàn)，當我們發(fā)送文本的時候，系統(tǒng)會對用戶的信息進行處理，完成公眾號消息回復功能，實現(xiàn)公眾號與用戶之間的完整對話。

測試發(fā)送圖文消息

        public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
        {
            var responseMessage = CreateResponseMessage<ResponseMessageNews>();
            responseMessage.Articles.Add(new Article()
            {
                Title = "灌籃高手",
                Description = "灌籃高手",
                PicUrl = "http://images.cnblogs.com/cnblogs_com/i3yuan/1462639/o_timg%20(1).jpg",
                Url = "https://www.cnblogs.com/i3yuan/"
            });
            return responseMessage;

        }

總結：

1.通過MessageHandler的簡單處理，我們就可以進行對用戶文本消息的處理，完成公眾號與用戶的會話

2.發(fā)送不同的消息，處理不同的回復，實現(xiàn)更多類型的消息回復

3.參考了如何使用MessageHandler簡化消息處理流程

到此這篇關于C#微信公眾號開發(fā)之消息處理的文章就介紹到這了。希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

C#類的訪問修飾符用法分析
這篇文章主要介紹了C#類的訪問修飾符用法,較為詳細的分析了C#類的訪問修飾符概念與用法,具有一定的參考借鑒價值,需要的朋友可以參考下
2014-10-10
WinForm生成驗證碼圖片的方法
這篇文章主要介紹了WinForm生成驗證碼圖片的方法,涉及WinForm字符串及圖形操作的相關技巧,具有一定參考借鑒價值,需要的朋友可以參考下
2016-06-06
C# 實現(xiàn)ADSL自動斷網和撥號的方法(適用于撥號用戶)
下面小編就為大家?guī)硪黄狢# 實現(xiàn)ADSL自動斷網和撥號的方法(適用于撥號用戶)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2016-12-12
C#利用ScriptControl動態(tài)執(zhí)行JS和VBS腳本
C#中利用ScriptControl動態(tài)執(zhí)行JS和VBS腳本的實現(xiàn)方法，需要的朋友可以參考下
2013-04-04
C#中backgroundworker的使用教程
這篇文章主要介紹了C#中backgroundworker的使用教程,在文中有兩點需要注意的，大家可以看下
2018-04-04
C#基于Socket實現(xiàn)簡單聊天室功能
這篇文章主要為大家詳細介紹了C#基于Socket實現(xiàn)簡單聊天室功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2022-02-02
Unity Shader實現(xiàn)紋理遮罩效果
這篇文章主要為大家詳細介紹了Unity Shader實現(xiàn)紋理遮罩效果，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2020-04-04
C#四舍五入(函數(shù))用法實例
這篇文章主要介紹了C#四舍五入(函數(shù))用法實例，有需要的朋友可以參考一下
2013-11-11
Unity UI拖拽模型選擇功能
這篇文章主要為大家詳細介紹了Unity UI拖拽模型選擇功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2020-01-01
C#枚舉類型與結構類型實例解析
這篇文章主要介紹了C#枚舉類型與結構類型實例,需要的朋友可以參考下
2014-07-07