zoukankan      html  css  js  c++  java
  • .Net Core 商城微服务项目系列(八):购物车

    最近加班有点多,一周五天,四天加班到11点+,心很累。原因是我当前在的这个组比较特殊,相当于业务的架构组,要为其它的开发组提供服务和监控。所以最近更新的也少,不过这个元旦三天假应该会更新三篇。

    这篇是介绍一下商城的购物车,代码就不详细介绍了,因为技术点都已经再前面几篇介绍过了,无非就是产品的增删该查,当然,数据的更新交互这一块使用的是我们上一篇介绍的消息队列,比如购车的添加、修改、删除。

    商城到这块功能方面就不打算继续往下写了,因为后面的功能都是围绕业务展开,技术方面千篇一律,而我们的关注点在于技术,所以后面的商城系列,一定是围绕着技术改造,现在还有几个技术点没有完成:

    1.日志使用Log4net+Kafka+ELK (现在是直接将日志通过tcp发送到logstash)

    2.添加SkyWalking调用链监控。

    3.RabbitMQ消费端独立成Windows服务,并添加监控。

    4.使用Apollo,将配置于程序进行解耦。

    5.添加定时任务、消费补偿机制。

    6.将服务部署到k8s中。

    后面的打算是暂时把这几个技术点给完成,这些都是我们再生产项目中直接用到的技术,一方面巩固自己的掌握,另一方面可以给有兴趣的人了解一下,这里面,我暂时比较想完成的是第6个,有时间的话我会把这几个服务部署到k8s中,这样我们就不再需要依赖Consul的服务注册和发现机制了。

    先来看一下购物车完成的情况:

     

     业务其实很简单,添加到购物车然后进行展示,代码也就不细讲了,贴下主要的购物车代码:

    /// <summary>
            /// 修改购物车产品数量
            /// </summary>
            public async Task<JsonResult> CountChange(int? CarID, int ProductID, int VersionID, string Operate)
            {
                var request = new AddCountRequest { CarId = CarID, ProductId = ProductID, VersionId = VersionID };
                if(Operate== "reduce")
                {
                    request.Num = -1;
                }
                else
                {
                    request.Num = 1;
                }
                eventBus.Publish("ShopCarCountChange", request);
                return Json("OK");
            }
    
            /// <summary>
            /// 新增购物车
            /// </summary>
            public async Task<JsonResult> AddCar(int ProductID, int VersionID)
            {
                var getColorResponse = await shopCarService.GetColorAsync(new GetColorRequest { VersionId = VersionID });
                //发送新增购物车MQ
                var addShopCarRequest = new AddShopCarRequest { ProductID = ProductID, VersionID = VersionID };
                try
                {
                    eventBus.Publish("AddShopCar", addShopCarRequest);
                }
                catch(Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    return Json("error");
                }
                
                return Json("ok");
            }

    可以看到,购物车这里对于数据库的交互都是通过消息队列来完成的,服务的代码就不看了,就是普通的增删改查。

    到此。商城服务一共有5个,我们通过Consul看下:

     应该不会再新增服务了,后面会逐步的实现文章开始提到的几个技术点改造。

  • 相关阅读:
    Ubuntu 下Apache安装和配置
    MariaDB二进制包简单安装部署
    Ubuntu下MongoDB的安装和使用
    Linux文件类型及目录配置
    centos7下挂载U盘和移动硬盘
    详解 比特(位,bit),字节(Byte),字符的区别 *(转)
    Socket使用及简单实例
    缓存
    字体小图标记录
    大流量下的兜底容灾方案
  • 原文地址:https://www.cnblogs.com/weiBlog/p/10200241.html
Copyright © 2011-2022 走看看