博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
微服务模式下,实现前后端多资源服务调用
阅读量:4033 次
发布时间:2019-05-24

本文共 9220 字,大约阅读时间需要 30 分钟。

Micro

Services

首先,我先解释下,文章标题的意思:

咋看起来特别像是一个标题党????,可能是我没想好怎么表达,其实白话文就是:在微服务场景下,肯定会有很多子服务API,那多个前端项目如何对接多个后端资源服务器项目呢?

也就是多个前端VUE如何对接多个后端的WebApi项目,这是问题,其实也不难,今天就简单的讨论讨论,我这里列举了三个场景的解决的方案,相信很多人都用过,都是比较主流的方案,文章的末端会有一个思考,就是如何实现第四种方案,这也就是我标题里为啥用微服务的原因了,本文主要是对微软微服务框架eShop的思考。

既然了解了问题,那你不妨先思考一下,如果是你自己的项目出现了这样的需求,VUE项目如何调用调用多个API项目,跟着我先慢慢往下看吧。

1、先来个需求吧

(图片来源自Blog.Admin首页)

相信如果留心的小伙伴,肯定这几天看到了我的Admin后台多了一个这样的数据统计,特别是下边的30天用户注册统计曲线图,这里先说下这是干啥的:

大家都知道,现在我的所有在线项目都是基于IdentityServer4(下文简称Is4)作为统一认证平台的,那这里的用户信息肯定都是来自于Is4项目的,因为之前项目我一直在修改,用的是默认账号,看不出来真实效果,所以我干脆去掉了默认账号,让每个访问的用户自己注册(放心,基本填的数据基本都是假的,而且我也不会发邮件,其他人也看不到),我就时不时的需要登录ids.neters.club认证平台去看数据,时间长了就麻烦了,那么需求来了:如何集成到Admin后台,通过线图的形式展示呢,还能查看日志,用户量,访问情况,异常信息等

但是Admin项目的后端Api是BlogCore的,我们已经习惯了这种一对一的开发模式,现在要实现一个前端对应多个后端的这种一对多的开发模,那如何来处理呢。

其实我们简单的思考一下就知道了,无论是一对一,还是一对多,甚至是多对多的情况,核心的问题,都是如何处理跨域的问题,如果浏览器不存在跨域的话,我们就可以任意的连接任何资源api了。当然除了跨域,第二个问题就是如何对资源的统一管理,这是个次要的重点知识。

当然,工欲善其事必先利其器,要实现这个需求,我们就首先需要在is4认证平台里,添加对外的接口,这里是未加权的,以后我会说说在加权的情况下,如何来处理,其实是一样的。

[HttpGet] public MessageModel
GetAchieveUsers() {     List
 apiDates = new List
();     var users = _userManager.Users.Where(d => !d.tdIsDelete).OrderByDescending(d => d.Id).ToList(); var tadayRegisterUser = users.Where(d => d.birth >= DateTime.Now.Date).Count(); apiDates = (from n in users group n by new { n.birth.Date } into g select new ApiDate { date = g.Key?.Date.ToString("yyyy-MM-dd"), count = g.Count(), }).ToList(); apiDates = apiDates.OrderByDescending(d => d.date).Take(30).ToList(); if (apiDates.Count == 0) { apiDates.Add(new ApiDate() { date = "没数据,或未开启相应接口服务", count = 0 }); } return new MessageModel
() { msg = "获取成功", success = true, response = new AccessApiDateView { columns = new string[] { "date", "count" }, rows = apiDates.OrderBy(d => d.date).ToList(), today = tadayRegisterUser, } }; }

现在接口有了,前端页面也设计好了(具体写法就是vue-chart线图,自行查看),那如何来解决调用问题呢,下边就从四个方面来讨论下。

2、万物皆可代理模式

代理模式,可谓是软件开发中,长盛不衰,一直活跃的东西,虽然有时候很多的名字是“代理”,而实际上上不是一回事,但是却丝毫不影响我们来使用。

那我们在VUE开发中,也会用到代理模式,就是devProxy本地代理,代码很简单,基于node服务,只需要简单的配置下,就可以将任意多个后端给代理到vue本地,只不过这里有个弊端,只能是本地开发模式下使用。

在项目根目录下的vue.config.js中配置(没有的话,新建即可)

devServer: {    open: true, //配置自动启动浏览器    host: "127.0.0.1",    port: 2364, // 当前vue项目 端口号    https: false,    hotOnly: false, // https:{type:Boolean}    // proxy: null, // 设置代理    // proxy: 'http://123.206.33.109:8081',// 配置跨域处理,只有一个代理    proxy: {      // 配置多个代理      "/api": {        target: "http://localhost:8081",//这里改成你自己的后端api端口地址,记得每次修改,都需要重新build        ws: true,        changeOrigin: true,        pathRewrite: {          // 支持路径重写,          "^/api": "" // 替换target中的请求地址        }      },      "/images": {        target: "http://localhost:8081",        ws: true,        changeOrigin: true      },      "/is4api": {        target: "http://localhost:5004",        ws: true,        changeOrigin: true      },    },    before: app => {}  },

是不是很简单,这里我定义了三种策略方案,匹配了两个后端项目,其中/is4api这个节点,就是针对is4项目的接口。

然后接口用相对路径的方式来调用,设置baseUrl="",这样就把所有的接口给代理到了前端了,这个很简单,我就不截图说明了。

上边说了,这种方案是vue本地的代理,我们build后的静态文件,是没有这个功能的,毕竟没有了node服务支持了,所以开发好项目上线的时候,就需要代理服务的反向代理功能了。我这里使用的是nginx做web服务器,那相应的配置如下:

    location /api/ {      rewrite ^.+apb/?(.*)$ /$1 break;      include uwsgi_params;      proxy_pass http://localhost:8081;      proxy_http_version 1.1;      proxy_set_header Upgrade $http_upgrade;      proxy_set_header Connection "upgrade";      proxy_set_header Host $host;      proxy_set_header X-Real-IP $remote_addr;      proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;    }    location /images/ {      include uwsgi_params;      proxy_pass http://localhost:8081;      proxy_http_version 1.1;      proxy_set_header Upgrade $http_upgrade;      #proxy_set_header Connection "upgrade";      #proxy_set_header Host $host;      proxy_set_header X-Real-IP $remote_addr;      proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;    }    location /is4api/ {      include uwsgi_params;      proxy_pass http://localhost:5004;      proxy_http_version 1.1;      proxy_set_header Upgrade $http_upgrade;      proxy_set_header Connection "upgrade";      proxy_set_header Host $host;      proxy_set_header X-Real-IP $remote_addr;      proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;    }

这种就很简单的实现了我们的需求,如果还有其他的微服务,我们就一一的增加进来,往里边添加就行,总体来说还是很方便的。

但是从上边看出来,我们本地开发的时候需要配置一套,然后项目上线的时候有需要配置一套,感觉不是很美观,而且还对管理不友好。所以要是服务比较多的话,我们可以换另一种方案,就是网关。

3、微服务中网关作用很大

(微服务简易网关,图源网络)

上边咱们说到了代理模式,在比较简单的,或者说服务比较少的情况下,还是一种比较常见、比较高效的开发方案,但是随着我们的项目的服务增多,因为我这里只有用户数据和博客数据,分别对应的是Blog.Idp项目和Blog.Core项目,那如果以后需要新增其他功能的时候,如上图,就需要一个统一的平台或者功能来管理我们的所有资源api了,网关就是一个很不错的选择,而且也可以结合其他的功能组件,中间件等扩展,比如服务注册和治理,熔断,负载等等。

既然说到了网关,那常见的网关就是Ocelot、Zuul、Kong这些,其中优劣不予置评,我习惯用Ocelot,那今天就说它。

第一:创建一个网关项目。

我其实blog.core项目中已经有了,你可以查看下Blog.Core.AdminMvc项目,这里什么都没有,我就用来做网关了,引用Ocelot组件

第二:配置Ocelot服务

在startup.cs文件中,配置服务和中间件

public void ConfigureServices(IServiceCollection services) {     // 配置服务     services.AddOcelot(); } // This method gets called by the runtime. Use this method to configure the HTTP request pipeline. public void Configure(IApplicationBuilder app, IWebHostEnvironment env) {     if (env.IsDevelopment())     {         app.UseDeveloperExceptionPage();     }          // 添加中间件     app.UseOcelot().Wait(); }

第三:配置网关策略

在根目录下,创建OcelotGatewaySet.json文件,然后添加内容,具体的逻辑,自行百度查看把,很简单,就是通过一定的配置,把分散的下游项目,也就是分散的微服务项目,给交给一个统一的上游地址,只不过有一定的url规则。

{  "Routes": [    {      "DownstreamPathTemplate": "/api/{url}",      "DownstreamScheme": "http",      "DownstreamHostAndPorts": [        {          "Host": "localhost",          "Port": 8081        }      ],      "UpstreamPathTemplate": "/gateway/api/{url}",      "UpstreamHttpMethod": [        "Get",        "Post",        "Put",        "Delete"      ],      "LoadBalancerOptions": {        "Type": "RoundRobin"      }    },    {      "DownstreamPathTemplate": "/is4api/{url}",      "DownstreamScheme": "http",      "DownstreamHostAndPorts": [        {          "Host": "localhost",          "Port": 5004        }      ],      "UpstreamPathTemplate": "/gateway/is4api/{url}",      "UpstreamHttpMethod": [        "Get",        "Post",        "Put",        "Delete"      ],      "LoadBalancerOptions": {        "Type": "RoundRobin"      }    }  ],  "GlobalConfiguration": {    "BaseUrl": "http://localhost:9000"  }}

这里我定义了两个下游,就是blogcore的8081,is4的5004,然后分别对应了上游的9000项目的两个地址:"/gateway/api/{url}"、"/gateway/is4api/{url}"。

第四步:添加Json文件到应用

上边我们自定义了配置策略文件,肯定是需要添加到应用里的,不然不会被识别,除非你是直接写到了appsettings.json里,但是这样好像又不太好,还是单独写一个文件吧:

public static IHostBuilder CreateHostBuilder(string[] args) =>    Host.CreateDefaultBuilder(args)            // 配置json文件        .ConfigureAppConfiguration((hostingContext, config) =>        {            config.AddJsonFile("OcelotGatewaySet.json");        })                .ConfigureWebHostDefaults(webBuilder =>        {            webBuilder.UseStartup
().UseUrls("http://*:9000");        });

然后就可以看到效果了

这样,以后无论多少个下游微服务,都可以集中到网关里,那前端vue项目,就很简单的配置一个9000就行了。

这样不仅可以实现多对多连接,还可以方便服务管理,是不是很方便。但是也有一个小问题,就是不好做服务之间的业务处理,比如我要在blogcore某个业务中,使用is4的用户数据,也就是跨项目跨数据库实现业务逻辑和事务,该怎么办呢,别着急,我项目中已经集成了多库操作,来看看吧。

4、扔到后端:多库模式

BlogCore目前支持,单库-多库-读写分离三种模式,事务当然也是支持,不过跨服跨库事务,可能需要分布式事务的组件来实现。

具体的内容可以参考《》

具体的写法呢,我的b站视频里也录制了,都是很简单的操作,只需要简单的配置,就可以实现多库处理,然后仓储层连接好后,还可以配合着service层来增删改查,就比如这样的来写。

第一:当然是配置连接字符串

在appsettings.json文件中,做多库处理,如果不会,可以看我的视频

https://www.bilibili.com/video/BV1BJ411B7mn?p=6

第二:定义对应的Model实体,在SugarTable特性里,配置好数据库的ConnId,这个配置的信息在appsettings.json里。

namespace Blog.Core.Model.IDS4DbModels{    ///     /// 以下model 来自ids4项目,多库模式,为了调取ids4数据    /// 用户表    ///     [SugarTable("AspNetUsers", "WMBLOG_MYSQL_2")]    public class ApplicationUser    {        public string LoginName { get; set; }        public string RealName { get; set; }        public int sex { get; set; } = 0;        public int age { get; set; }        public DateTime birth { get; set; } = DateTime.Now;        public string addr { get; set; }        public bool tdIsDelete { get; set; }    }}

第三:就是直接创建Service层,当然,如果你有封装单独的逻辑业务,可以自己创建一个仓储层,但是如果普通的CURD,可以直接使用泛型基类仓储接口:

public class ApplicationUserServices : BaseServices
, IApplicationUserServices { IBaseRepository
_dal; public ApplicationUserServices(IBaseRepository
dal) { this._dal = dal; base.BaseDal = dal;     } }

这样就可以轻松的实现连接了。可以在控制器,甚至是Service里写逻辑了,这里就不多介绍了。

但是!其实这种写法呢,应该不符合今天内容的主旨,这么写虽然可以任意的再后端做多库处理,写业务了,但是如果微服务多了怎么办,又不好做控制,负载什么的。而且又不那么灵活,甚至如果一个服务崩了,也会导致主服务受到影响。

那为什么我还要拿出来说一下呢,主要是想引出第四种方案,就是微服务下,在使用网关、做服务治理、负载均衡的情况下,如何实现多服务之间的调用。

5、如果有第四种方案?

这里先说下第四种思路的由来:

就是上边提到的问题,在微服务场景下,我们是讲一个个服务都拆开限界的,各个子服务独立做负载均衡,服务注册和治理,然后通过网关,将所有的服务连接起来,看着没问题,但是如果某两个,或者多个子服务之间相互左右,或者相互调用来实现交叉业务逻辑的时候,是不是感觉很苍白无力,从而导致了很多人问了这样的问题:

微服务好是好,但是我想多表联查怎么办?看似和微服务,和DDD背道而驰,但是却是不得不考虑的一个问题。

当然,方案还是有的,比如常见的RestFul、gRPC、MQ、Bus等等技术,这些知识点,其实就是第四种方案,其实就是第二和第三种方案的结合体。

这些内容在微软的微服务框架eShopOnContainer都可以看的到,我也正在学习和讲解,想了解的时候,可以看一看:

《》

END

欢迎将文章分享到朋友圈

如需转载,请在后台回复“转载”获取授权

更多精彩推荐,老张的哲学

把时间交给阅读

你可能感兴趣的文章
coursesa课程 Python 3 programming course_2_assessment_8 sorted练习题
查看>>
visca接口转RS-232C接口线序
查看>>
在unity中建立最小的shader(Minimal Shader)
查看>>
1.3 Debugging of Shaders (调试着色器)
查看>>
关于phpcms中模块_tag.class.php中的pc_tag()方法的含义
查看>>
vsftp 配置具有匿名登录也有系统用户登录,系统用户有管理权限,匿名只有下载权限。
查看>>
linux安装usb wifi接收器
查看>>
用防火墙自动拦截攻击IP
查看>>
补充自动屏蔽攻击ip
查看>>
谷歌走了
查看>>
多线程使用随机函数需要注意的一点
查看>>
getpeername,getsockname
查看>>
让我做你的下一行Code
查看>>
浅析:setsockopt()改善程序的健壮性
查看>>
关于对象赋值及返回临时对象过程中的构造与析构
查看>>
VS 2005 CRT函数的安全性增强版本
查看>>
SQL 多表联合查询
查看>>
Visual Studio 2010:C++0x新特性
查看>>
drwtsn32.exe和adplus.vbs进行dump文件抓取
查看>>
cppcheck c++静态代码检查
查看>>