栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > .Net

关于.net高并发商品秒杀方案

.Net 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

关于.net高并发商品秒杀方案

关于.net高并发商品秒杀方案

由于工作原因一直没有接触过高并发的项目,近期根据网上的教程整理了一个关于高并发的demo。Demo只在开发环境下使用,未上生产环境。第一次写文章,有啥子不好的地方请纠正

功能:商品抢购

使用场景:商城类型网站或者小程序等

开发工具:Visual Studio 2019、sql server2017、Jmeter、Visual Studio core、Nginx、RabbitMQ

框架:.net 5+ef core+swagger

数据库:sql server

缓存框架:redis 5.0 ----集群

消息队列:RabbitMQ

负载均衡:Nginx

消息总线框架:CAP

测试工具:Jmeter

参考文章:https://www.cnblogs.com/yaopengfei/category/1239348.html

Jmeter安装教程:https://blog.csdn.net/wust_lh/article/details/86095924

接口流程

数据库搭建

用户表,产品表,秒杀产品表,订单表,支付记录表(不使用),秒杀时间模型表(不使用):

用户表(User)

产品表(Product)

秒杀产品表(SeckillProduct)

订单表(Order),后期引入Redis NuGet包时名称会冲突建议不要用Order来命名

准备工作到这里差不多就完成了

VS2019创建新项目->选择ASP.NET Core Web应用程序->然后选择ASP.NET Core Web API(选择.net core 和ASP.NET Core 5.0 )

添加NuGet包: Microsoft.EntityFrameworkCore、Microsoft.EntityFrameworkCore.SqlServer、Swashbuckle.AspNetCore、EntityFramework、EFCore.BulkExtensions(如有遗漏请补充)

配置数据库:
appsettings.json添加数据库配置:

  "DBConnection": {
    "ConnectionStrings": { "Dbconn": "server=DESKTOP-236E652\MSSQLSERVER2;database=MessageQueuing;Trusted_Connection=true" }
    //"ConnectionStrings": { "Dbconn": "server=DESKTOP-236E652\MSSQLSERVER2;database=Demo;uid=sa;pwd=sa123456" }
  },

新建项目DBHelper,Common,Models,然后把实体类建好。

在Common项目中新建类DbHelperContext.cs(数据库连接类),继承DbContext,

    /// 
    /// 数据库连接类
    /// 
    public class DbHelperContext:DbContext
    {
        public DbHelperContext(DbContextOptions options)
            : base(options)
        {

        }

        public DbSet Order { get; set; }
        public DbSet PayRecord { get; set; }
        public DbSet Product { get; set; }
        public DbSet SeckillProduct { get; set; }
        public DbSet seckillTimeModel { get; set; }
        public DbSet User { get; set; }
        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {

        }
    }

到Startup.cs注册数据库连接类

        services.AddDbContext(option =>
            {
                option.UseSqlServer(Configuration[string.Join(":", new string[] { "DBConnection", "ConnectionStrings", "Dbconn" })]);
            });

接下来配置路由

            app.UseEndpoints(endpoints =>
            {
                endpoints.MapControllerRoute(
                   name: "default",
                   pattern: "{controller=Home}/{action=Index}/{id?}");
            });

开始配置Swagger: 添加NuGe包:IGeekFan.AspNetCore.Knife4jUI,这个版本下的Swagger ui页面看着舒服。在Common新建MiddlewareExtensions文件夹,然后再文件夹里添加SwaggerExtensions类,配置Swagger的基础信息,如标题,版本,路径

        public static void AddSwaggerExtensions(this IServiceCollection services)
        {
            services.AddSwaggerGen(x =>
            {
                x.SwaggerDoc("v1", new OpenApiInfo { Title = "MessageQueuing", Version = "v1" });
                x.OrderActionsBy(o => o.RelativePath);
                x.CustomOperationIds(apiDesc =>
                {
                    var controllerAction = apiDesc.ActionDescriptor as ControllerActionDescriptor;
                    if (controllerAction == null) return null;
                    return controllerAction.ControllerName + "-" + controllerAction.ActionName;
                });
                var basePath = Microsoft.DotNet.PlatformAbstractions.ApplicationEnvironment.ApplicationBasePath;
                var xmlFile = System.AppDomain.CurrentDomain.FriendlyName + ".xml";
                var xmlPath = Path.Combine(basePath, "MessageQueuing.xml");
                x.IncludeXmlComments(xmlPath, true);
            });
        }

然后到Startup.cs注册SwaggerExtensions类

//说明文档配置
services.AddSwaggerExtensions();

MiddlewareExtensions文件夹,继续添加SwaggerMiddlewareExtensions类,配置ui页面

        public static void UseSwaggerMiddlewareExtensions(this IApplicationBuilder app)
        {
            app.UseSwagger();
            app.UseKnife4UI(x =>
            {
                x.SwaggerEndpoint("/swagger/v1/swagger.json", "MessageQueuing v1");
            });
        }

依然到Startup.cs注册SwaggerMiddlewareExtensions类

            //文档说明
            app.UseSwaggerMiddlewareExtensions();

到这,项目基本的配置就完成了接下来开始进行接口开发和测试

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/909812.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号