使用緩存防擊穿，解決微信”被動(dòng)回復(fù)用戶消息”重試回復(fù)問(wèn)題
背景
做微信公眾號(hào)開(kāi)發(fā)的時(shí)候，其中有個(gè)接收普通消息、接收事件推送 API。
有這么條規(guī)則， ”微信服務(wù)器在五秒內(nèi)收不到響應(yīng)會(huì)斷掉連接，并且重新發(fā)起請(qǐng)求，總共重試三次。假如服務(wù)器無(wú)法保證在五秒內(nèi)處理并回復(fù)，可以直接回復(fù)空串，微信服務(wù)器不會(huì)對(duì)此作任何處理，并且不會(huì)發(fā)起重試。詳情請(qǐng)見(jiàn)“發(fā)送消息-被動(dòng)回復(fù)消息””。
概括起來(lái)就2點(diǎn)
1、就是說(shuō)5s沒(méi)響應(yīng)，這個(gè)請(qǐng)求就會(huì)被放棄；
2、會(huì)重新發(fā)起請(qǐng)求，具有冪等性；
問(wèn)題
這樣就會(huì)產(chǎn)生2個(gè)問(wèn)題。
1、假設(shè)我的方法就正好需要6s,那么即使返回結(jié)果也是沒(méi)用的，因?yàn)檎?qǐng)求被放棄了。
2、我需要返回給用戶正確的回信，假設(shè)第一次超時(shí)沒(méi)法及時(shí)回信，比如綁定操作，第一次沒(méi)回信，第二次再來(lái)總不能回復(fù)綁定過(guò)了，這樣顯然不合理。
圖片
或者直接回復(fù) success ，這樣顯然沒(méi)法正常的進(jìn)行消息提醒。
那么怎么做到既執(zhí)行了操作（第一次超時(shí)了），（第二次微信重試）又及時(shí)回復(fù)正確的回信呢 。
圖片
代碼實(shí)現(xiàn)
1、定義緩存的key，就是消息MsgId。
string cacheKey = model.MsgId.ToString();2、使用緩存機(jī)制，把結(jié)果緩存起來(lái)，下次進(jìn)來(lái)，直接回復(fù)上次執(zhí)行的結(jié)果。
TimeSpan expired = new TimeSpan(0, 0, 20);
string cacheKey = model.MsgId.ToString();
return _cacheLayer.Get(cacheKey, () =>
{
MsgReply param = new MsgReply() { ToUserName = model.FromUserName, FromUserName = model.ToUserName };
string Jsonstr = WeiXinHelper.ReadAccess(HttpRuntime.AppDomainAppPath.ToString() + "/App_Data/WeChat/KeyWordReplay.json");
var r = JsonConvert.DeserializeObject<AutoReplay>(Jsonstr);
param.Content = r.content;
if (String.Equals(model.MsgType, "text", StringComparison.CurrentCultureIgnoreCase))
{
var item = r.keywordcontent.FirstOrDefault(o => o.keyword.Contains(model.Content));
if (item != null)
{
param.Content = item.content;
}
}
string response = _weChatAlertsService.SubscribeReply(param);
AddReceiveLog(model, xml, response);
return response;
}, expired);3、這樣既解決冪等問(wèn)題，也返回了正確的結(jié)果。
4、這里需要注意，緩存取得每個(gè) Key專有的 lock object；若同時(shí)有多個(gè) thread要求相同資料，只會(huì)(到數(shù)據(jù)庫(kù))查第一次，剩下的從 cache讀取。
public T Get<T>(string key, Func<T> getDataWork, TimeSpan absoluteExpireTime, bool forceRefresh = false, bool returnCopy = true) where T : class
{
try
{
lock (GetMemoryCacheLockObject(key))
{private static object GetMemoryCacheLockObject(string key)
{
string cacheLockKey = string.Format(MemoryCacheLockObjectFormat, key);
lock (CacheObject)
{
var lockObject = CacheObject[cacheLockKey];
if (lockObject == null)
{
// 取得每個(gè) Key專屬的 lock object；若同時(shí)有多個(gè) thread要求相同資料，只會(huì)(到資料庫(kù))查第一次，剩下的從 cache讀取
lockObject = new object();
CacheObject.Set(
cacheLockKey,
lockObject,
new System.Runtime.Caching.CacheItemPolicy()
{
AbsoluteExpiration = DateTimeOffset.UtcNow.AddMinutes(10)
}
);
}
return lockObject;
}
}總結(jié)
1、使用緩存機(jī)制，把第一次的結(jié)果保存下來(lái)，對(duì)方重試的時(shí)候，直接返回上次的結(jié)果。
2、使用lock ，保證并發(fā)的時(shí)候，若同時(shí)有多個(gè) thread要求相同資料，只會(huì)(到數(shù)據(jù)庫(kù))查第一次，剩下的從 cache讀取。
