C#微信公眾號開發(fā)之消息處理
前言:
回顧上一節(jié)服務器配置的內容,我們已經(jīng)可以自己完成公眾號服務器的配置。配置完成之后,我們就可以通過調用的方式,完成對消息管理的處理。當用戶關注公眾號或者發(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é)中我們已經(jīng)新建了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# 實現(xiàn)ADSL自動斷網(wǎng)和撥號的方法(適用于撥號用戶)
下面小編就為大家?guī)硪黄狢# 實現(xiàn)ADSL自動斷網(wǎng)和撥號的方法(適用于撥號用戶)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2016-12-12
C#利用ScriptControl動態(tài)執(zhí)行JS和VBS腳本
C#中利用ScriptControl動態(tài)執(zhí)行JS和VBS腳本的實現(xiàn)方法,需要的朋友可以參考下2013-04-04

