c# 通过消息队列处理高并发请求实列

网站面对高并发的情况下，除了增加硬件， 优化程序提高以响应速度外，还可以通过并行改串行的思路来解决。这种思想常见的实践方式就是数据库锁和消息队列的方式。这种方式的缺点是需要排队，响应速度慢，优点是节省成本。

演示一下现象
创建一个在售产品表
CREATE TABLE [dbo].[product](
[id] [int] NOT NULL,--唯一主键
[name] nvarchar NULL,--产品名称
[status] [int] NULL ,--0未售出 1 售出 默认为0
[username] nvarchar NULL--下单用户
)

添加一条记录

insert into product(id,name,status,username) values(1,'小米手机',0,null)
创建一个抢票程序

public ContentResult PlaceOrder(string userName)
{
using (RuanMou2020Entities db = new RuanMou2020Entities())
{
var product = db.product.Where(p => p.status== 0).FirstOrDefault();
if (product.status == 1)
{
return Content("失败，产品已经被卖光");
}
else
{
//模拟数据库慢造成并发问题
Thread.Sleep(5000);
product.status = 1;
product.username= userName;
　　　　　　　　　　　　　　db.SaveChanges();
　　　　　　　　　　　　　　return Content("成功购买");
　　　　　　　　　　　　 }
　　　　　　}
　　　　}

如果我们在5秒内一次访问以下两个地址，那么返回的结果都是成功购买且数据表中的username是lisi。

/controller/PlaceOrder?username=zhangsan

/controller/PlaceOrder?username=lisi

这就是并发带来的问题。

第一阶段，利用线程锁简单粗暴
Web程序是多线程的，那我们把他在容易出现并发的地方加一把锁就可以了，如下图处理方式。

    private static object _lock = new object();

    public ContentResult PlaceOrder(string userName)
    {
        using (RuanMou2020Entities db = new RuanMou2020Entities())
        {
            lock (_lock)
            {
                var product = db.product.Where<product>(p => p.status == 0).FirstOrDefault();
                if (product.status == 1)
                {
                    return Content("失败，产品已经被卖光");
                }
                else
                {
                    //模拟数据库慢造成并发问题
                    Thread.Sleep(5000);
                    product.status = 1;
                    product.username = userName;
                    db.SaveChanges();
                    return Content("成功购买");
                }
            }
        }
    }

这样每一个请求都是依次执行，不会出现并发问题了。

优点：解决了并发的问题。

缺点：效率太慢，用户体验性太差，不适合大数据量场景。

第二阶段，拉消息队列，通过生产者，消费者的模式
1，创建订单提交入口（生产者）

public class HomeController : Controller
{

    /// <summary>
    /// 接受订单提交（生产者)
    /// </summary>
    /// <returns></returns>
    public ContentResult PlaceOrderQueen(string userName)
    {
        //直接将请求写入到订单队列
        OrderConsumer.TicketOrders.Enqueue(userName);
        return Content("wait");
    }

    /// <summary>
    /// 查询订单结果
    /// </summary>
    /// <returns></returns>
    public ContentResult PlaceOrderQueenResult(string userName)
    {
        var rel = OrderConsumer.OrderResults.Where(p => p.userName == userName).FirstOrDefault();
        if (rel == null)
        {
            return Content("还在排队中");
        }
        else
        {
            return Content(rel.Result.ToString());
        }
    }

}

2，创建订单处理者(消费者)

///

        //在Global的Application_Start事件里单独开启一个消费者线程
        Task.Run(OrderConsumer.StartTicketTask);
    }

        //程序启动前，先初始化待售产品消息队列
        ProductForSaleManager.Init();
    }
}