欢迎光临
我的个人博客网站

第9课 消息队列 SenparcMessageQueue

文章说明:

  本文是基于盛派网络苏震巍老师的《微信公众号+小程序快速开发》课程笔记。

课程地址:

  https://study.163.com/course/courseMain.htm?courseId=1004873017

本课项目地址:

  https://github.com/wechatdeveloper/WechatVideoCourse

课程目标

  使用消息队列,执行有顺序的异步操作。也就是把蜂拥而至的请求,进行排队后,按照先进先执行的规则有顺序的执行。

 

队列图示:

第9课  消息队列 SenparcMessageQueue

 

微信中使用场景 :

大量用户向公众号发起消息请求,而微信的规则是需要在5S内响应返回给用户;

如果大量的并发请求出现,应用服务器可能产生堵塞,无法及时响应用户;

可变通的方法是:把所有的请求加入队列中,在队列中以客人消息的方式返回给用户,从而保证用户有良好的体验。

 

SDK SenparcMessageQueue 源码解读:

源码位置:https://github.com/Senparc/Senparc.CO2NET

把1个个的对象【SenparcMessageQueueItem】(Key标识唯一性),放到队列【MessageQueueDictionary】中, 然后逐个执行【OperateQueue】

 

【SenparcMessageQueueItem】:

 1          /// <summary>  2         /// 队列项唯一标识  3         /// </summary>  4         public string Key { get; set; }  5         /// <summary>  6         /// 队列项目命中触发时执行的委托  7         /// </summary>  8         public Action Action { get; set; }  9         /// <summary> 10         /// 此实例对象的创建时间 11         /// </summary> 12         public DateTimeOffset AddTime { get; set; } 13         /// <summary> 14         /// 项目说明(主要用于调试) 15         /// </summary> 16         public string Description { get; set; } 17  18         /// <summary> 19         /// 初始化SenparcMessageQueue消息队列项 20         /// </summary> 21         /// <param name="key"></param> 22         /// <param name="action"></param> 23         /// <param name="description"></param> 24         public SenparcMessageQueueItem(string key, Action action, string description = null) 25         { 26             Key = key; 27             Action = action; 28             Description = description; 29             AddTime = SystemTime.Now; 30         }

 

【OperateQueue】获取对象 => 逐个执行 => 清除已执行的对象 => 获取下一个对象

 1      /// <summary>  2         /// 操作队列  3         /// </summary>  4         public static void OperateQueue()  5         {  6             lock (FlushCacheLock)  7             {  8                 var mq = new SenparcMessageQueue();  9                 var key = mq.GetCurrentKey(); //获取最新的Key 10                 while (!string.IsNullOrEmpty(key)) 11                 { 12                     var mqItem = mq.GetItem(key); //获取任务项 13                     mqItem.Action(); //执行 14                     mq.Remove(key, out SenparcMessageQueueItem value); //清除 15                     key = mq.GetCurrentKey(); //获取最新的Key 16                 } 17             } 18         }

 

获取对象,是根据先进先出的原则:

 1         /// <summary>  2         /// 获取当前等待执行的Key  3         /// </summary>  4         /// <returns></returns>  5         public string GetCurrentKey()  6         {  7             lock (MessageQueueSyncLock)  8             {  9                 //不直接使用 Key 是因为 Key 的顺序是不确定的 10                 var value = MessageQueueDictionary.Values.OrderBy(z=>z.AddTime).FirstOrDefault(); 11                 if (value==null) 12                 { 13                     return null; 14                 } 15                 return value.Key; 16             } 17         }

 

队列执行效果:

第9课  消息队列 SenparcMessageQueue

 

 

 

 

 

 


 

赞(0) 打赏
未经允许不得转载:张拓的天空 » 第9课 消息队列 SenparcMessageQueue
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

专业的IT技术经验分享 更专业 更方便

联系我们本站主机

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏