本篇将和大家分享一下秒杀商品活动架构，采用的架构方案正如标题名称.NetCore+Jexus代理+Redis，由于精力有限所以这里只设计到商品添加，抢购，订单查询，处理队列抢购订单的功能；有不足或者不够详细的还请见谅，顺手点个推荐也不错；

a. ^_秒杀流程

b. 封装StackExchange.Redis的使用类

c. Ubuntu16.04上使用Jexus搭建代理完成分布式部署

d. NetCore写实时监控队列服务

秒杀架构设计图︿(￣︶￣)︿三幅

1. 一般业务性架构

2. 后端分布式架构

3. 整站分布式

项目工程结构描述

a. 该项目git开源地址： https://github.com/shenniubuxing3/SeckillPro ，线上效果地址： http://www.lovexins.com:3333/

b. SeckillPro.Web：面向用户的web站点，主要提供商品展示，秒杀抢购，抢购结果，订单列表等功能；

c. SeckillPro.Api：主要处理秒杀活动的请求，然后加入到秒杀队列中，以及订单状态的查询接口；

d. SeckillPro.Server：处理秒杀队列的服务；根据Redis模糊匹配key的方式，开启多个商品秒杀的任务，并处理秒杀请求和改变订单抢购状态；

e. SeckillPro.Com：集成公共的方法；这里面前有操作Redis的list，hash，string的封装类；

SeckillPro.Web商品后台管理

对于商品活动来说，商品维护是必不可少的，由于这里商品维护的信息比较少，并且这里只加入到了RedisDb中，所以就不直接上代码了；一个列表，一个添加仅此而已；这里就不再贴代码了，如果你感兴趣可以去我的git上面看源码： https://github.com/shenniubuxing3/SeckillPro/blob/master/SeckillPro/SeckillPro.Web/Controllers/HomeController.cs 

SeckillPro.Web用户端商品列表+秒杀请求+用户订单列表

商品列表和订单列表没有可以太多说的，一般订单系统都有这两个列表；关键点在于订单秒杀流程中，咋们来简单分析下面向客户秒杀的流程需要注意的事项：

a. 限制秒杀开始时间和结束时间(测试未限制)

b. 未开始活动限制提交按钮不可点(测试未限制)

c. 获取真实剩余库存限制秒杀提交(获取redis中商品hash存储的真实剩余量)

d. 把客户的秒杀请求转移到另外的api集群，以此提高面向客户端的web站点并发承载率(测试项目中我直接指定4545端口的api测试)

这里就不再贴代码了，如果你感兴趣可以去我的git上面看看这部分源码： https://github.com/shenniubuxing3/SeckillPro/blob/master/SeckillPro/SeckillPro.Web/Controllers/HomeController.cs 

.NetCore写处理秒杀活动队列的服务

这个处理队列服务处理流程：模糊匹配Redis中每种商品的队列key-》开启不同商品的处理队列任务-》处理秒杀订单-》更新库存和秒杀订单状态；

a. 模糊匹配Redis中每种商品的队列key：这里采用的是StackExchange.Redis中指定redis原生命令的方法来获取匹配队列key，设计的代码如下：

 1 /// <summary> 2         /// 模糊匹配redis中的key 3         /// </summary> 4         /// <param name="paramArr"></param> 5         /// <returns></returns> 6         public async Task<List<string>> MatchKeys(params string[] paramArr) 7         { 8             var list = new List<string>(); 9             try10             {11                 var result = await this.ExecuteAsync("keys", paramArr);12 13                 var valArr = ((RedisValue[])result);14                 foreach (var item in valArr)15                 {16                     list.Add(item);17                 }18             }19             catch (Exception ex) { }20             return list;21         }22 23         /// <summary>24         /// 执行redis原生命令25         /// </summary>26         /// <param name="cmd"></param>27         /// <param name="paramArr"></param>28         /// <returns></returns>29         public async Task<RedisResult> ExecuteAsync(string cmd, params string[] paramArr)30         {31             try32             {33                 var db = this.GetDb();34                 return await db.ExecuteAsync(cmd, paramArr);35             }36             catch (Exception ex) { }37             return default(RedisResult);38         }

b. 开启不同商品的处理队列任务：通过Task.Factory.StartNew(action,object)方法开启不同商品的处理秒杀订单的任务；

c. 更新库存和秒杀订单状态：由于抢购商品要求库存剩余实时性，所以每处理一个抢购订单，需要对该商品减去相应的库存和修改秒杀订单的状态方便用户查看秒杀结果；

d. 处理队列具体的实现代码可以去git看下，个人觉得还是有用的：https://github.com/shenniubuxing3/SeckillPro/blob/master/SeckillPro/SeckillPro.Server/Program.cs

使用Jexus代理部署分布式站点和接口

这里部署的代理采用的是Jexus代理；作为在linux和unix上部署.net程序实用的工具，真的很感谢jexus作者；首先本篇讲解的部署环境是ubunt16.04x64（至于这么安装jexus可以参考上一篇分享文章），为了更直观的看出来效果我在服务器上拷贝了两份SeckillPro.Web发布的站点，他们代码都是一样的只是分别把_Layout.cshtml试图模板中加入了端口7777和8888，我就用这两个端口来测试jexus的代理效果；

测试方便直接分别在两个复制站点中执行如下终端命令：dotnet SeckillPro.Web.dll http://ip:端口 ；一个监听7777端口一个监听8888；执行命令效果图：

监听7777和8888端口成功后，我们就可以直接在浏览器输入：http://172.16.9.66:7777 访问，正常情况下能够看到如下图示例：

单个站点访问没问题了，下面开始配置jexus代理；只需要在jexus/siteconf的配置文件中（我这里是default配置文件），增加如下设置：

注意reproxy参数：

a. 第一个/表示根目录，一般不变

b. 多个被代理地址使用‘,’隔开；

c. 被代理地址后面也同样需要加/

此时我们配置完后，只需要启动jexus就行了：./jws start （怎么启动可以参考上一篇文章）；当启动jws成功后，我们就能通过配置的80端口，来访问SeckillPro.Web站点了，效果图：

至于代理分发的策略暂不在本章的讨论范围内，如果可以建议去jexus官网了解下；同样对于Seckill.Api我们也可以这样部署，这里部署了个秒杀线上地址，有兴趣的朋友可以点击试试：http://www.lovexins.com:3333/ （注：这里没有使用代理）

封装StackExchange.Redis的使用类StackRedis.cs

其实这个在之前已经分享过了，只不过只有操作string和list的分装；本篇测试涉及到订单查询和商品查询等功能，所以这里我又扩展了对hash的操作方法，可以说更丰富了吧，如果您正打算使用redis或许直接用我这个封装类是个不错的打算；

  1 public class StackRedis : IDisposable  2     {  3         #region 配置属性   基于 StackExchange.Redis 封装  4         //连接串 （注：IP:端口,属性=,属性=)  5         public string _ConnectionString = "127.0.0.1:6377,password=shenniubuxing3";  6         //操作的库（注：默认0库）  7         public int _Db = 0;  8         #endregion  9  10         #region 管理器对象 11  12         /// <summary> 13         /// 获取redis操作类对象 14         /// </summary> 15         private static StackRedis _StackRedis; 16         private static object _locker_StackRedis = new object(); 17         public static StackRedis Current 18         { 19             get 20             { 21                 if (_StackRedis == null) 22                 { 23                     lock (_locker_StackRedis) 24                     { 25                         _StackRedis = _StackRedis ?? new StackRedis(); 26                         return _StackRedis; 27                     } 28                 } 29  30                 return _StackRedis; 31             } 32         } 33  34         /// <summary> 35         /// 获取并发链接管理器对象 36         /// </summary> 37         private static ConnectionMultiplexer _redis; 38         private static object _locker = new object(); 39         public ConnectionMultiplexer Manager 40         { 41             get 42             { 43                 if (_redis == null) 44                 { 45                     lock (_locker) 46                     { 47                         _redis = _redis ?? GetManager(this._ConnectionString); 48                         return _redis; 49                     } 50                 } 51  52                 return _redis; 53             } 54         } 55  56         /// <summary> 57         /// 获取链接管理器 58         /// </summary> 59         /// <param name="connectionString"></param> 60         /// <returns></returns> 61         public ConnectionMultiplexer GetManager(string connectionString) 62         { 63             return ConnectionMultiplexer.Connect(connectionString); 64         } 65  66         /// <summary> 67         /// 获取操作数据库对象 68         /// </summary> 69         /// <returns></returns> 70         public IDatabase GetDb() 71         { 72             return Manager.GetDatabase(_Db); 73         } 74         #endregion 75  76         #region 操作方法 77  78         #region string 操作 79  80         /// <summary> 81         /// 根据Key移除 82         /// </summary> 83         /// <param name="key"></param> 84         /// <returns></returns> 85         public async Task<bool> Remove(string key) 86         { 87             var db = this.GetDb(); 88  89             return await db.KeyDeleteAsync(key); 90         } 91  92         /// <summary> 93         /// 根据key获取string结果 94         /// </summary> 95         /// <param name="key"></param> 96         /// <returns></returns> 97         public async Task<string> Get(string key) 98         { 99             var db = this.GetDb();100             return await db.StringGetAsync(key);101         }102 103         /// <summary>104         /// 根据key获取string中的对象105         /// </summary>106         /// <typeparam name="T"></typeparam>107         /// <param name="key"></param>108         /// <returns></returns>109         public async Task<T> Get<T>(string key)110         {111             var t = default(T);112             try113             {114                 var _str = await this.Get(key);115                 if (string.IsNullOrWhiteSpace(_str)) { return t; }116 117                 t = JsonConvert.DeserializeObject<T>(_str);118             }119             catch (Exception ex) { }120             return t;121         }122 123         /// <summary>124         /// 存储string数据125         /// </summary>126         /// <param name="key"></param>127         /// <param name="value"></param>128         /// <param name="expireMinutes"></param>129         /// <returns></returns>130         public async Task<bool> Set(string key, string value, int expireMinutes = 0)131         {132             var db = this.GetDb();133             if (expireMinutes > 0)134             {135                 return db.StringSet(key, value, TimeSpan.FromMinutes(expireMinutes));136             }137             return await db.StringSetAsync(key, value);138         }139 140         /// <summary>141         /// 存储对象数据到string142         /// </summary>143         /// <typeparam name="T"></typeparam>144         /// <param name="key"></param>145         /// <param name="value"></param>146         /// <param name="expireMinutes"></param>147         /// <returns></returns>148         public async Task<bool> Set<T>(string key, T value, int expireMinutes = 0)149         {150             try151             {152                 var jsonOption = new JsonSerializerSettings()153                 {154                     ReferenceLoopHandling = ReferenceLoopHandling.Ignore155     
  http://www.cnblogs.com/wangrudong003/p/7111789.html

更多精彩分享

• 陆老师 [海军工程大学 硕士 — 嵌入式开发专家] 2024-03-26 11:26:03.003
• 时光飞逝 2024-03-26 11:25:53.823
• 纸上得来终觉浅 2024-03-26 11:25:42.68
• 软件行业发展七大方向 2024-03-26 11:25:34.457
• 如何组建测试团队？ 2024-03-26 11:25:25.33
• 在青岛学习JavaEE哪家学校最好？ 2024-03-26 11:25:16.78
• 教务排课系统 2024-03-26 11:24:56.74
• 青岛帕特智能科技有限公司 2024-03-26 11:24:30.433
• 消息队列NetMQ 原理分析4-Socket、Session、Option和Pipe 2024-03-26 11:24:15.657
• 感谢，我亲爱的万码学堂 2024-03-26 11:12:06.6

陆老师 [海军工程大学 硕士 — 嵌入式开发专家]