.Net Core微服务入门全纪录(一)——项目搭建
前言
写这篇博客主要目的是记录一下自己的学习过程,只能是简单入门级别的,因为水平有限就写到哪算哪吧,写的不对之处欢迎指正。代码放在:https://github.com/xiajingren/NetCoreMicroserviceDemo
什么是微服务?
关于微服务的概念解释网上有很多... 个人理解,微服务是一种系统架构模式,它和语言无关,和框架无关,和工具无关,和服务器环境无关... 微服务思想是将传统的单体系统按照业务拆分成多个职责单一、且可独立运行的接口服务。至于服务如何拆分,没有明确的定义。几乎任何后端语言都能做微服务开发。微服务也并不是完美无缺的,微服务架构会带来更多的问题,增加系统的复杂度,引入更多的技术栈...
创建项目
一个客户端,一个产品服务,一个订单服务。3个项目都是asp.net core web应用程序。创建项目的时候记得启用一下Docker支持,或者后面添加也行。
为产品、订单服务添加一些基础代码,就简单的返回一下 服务名称,当前时间,服务的ip、端口。
在Docker中运行服务
为了方便,我使用Docker来运行服务,不用Docker也行,关于docker的安装及基本使用就不介绍了。
- build镜像:
在项目根目录打开PowerShell窗口执行:docker build -t productapi -f ./Product.API/Dockerfile .
Successfully代表build成功了。
- 运行容器:
执行:docker run -d -p 9050:80 --name productservice productapi
执行:docker ps
查看运行的容器:
没问题,使用浏览器访问一下接口:
也没问题,其中的ip端口是Docker容器内部的ip端口,所以端口是80,这个无所谓。
- 产品服务部署好了,下面部署一下订单服务,也是同样的流程,就把指令简单贴一下吧:
build镜像:docker build -t orderapi -f ./Order.API/Dockerfile .
运行容器:docker run -d -p 9060:80 --name orderservice orderapi
浏览器访问一下:
OK,订单服务也部署完成了。
客户端调用
客户端我这里只做了一个web客户端,实际可能是各种业务系统、什么PC端、手机端、小程序。。。这个明白就好,为了简单就不搞那么多了。
- 因为客户端需要http请求服务端接口,所以需要一个http请求客户端,我个人比较习惯RestSharp,安利一波:https://github.com/restsharp/RestSharp
- 添加基础代码:
IServiceHelper.cs:
public interface IServiceHelper
{
/// <summary>
/// 获取产品数据
/// </summary>
/// <returns></returns>
Task<string> GetProduct();
/// <summary>
/// 获取订单数据
/// </summary>
/// <returns></returns>
Task<string> GetOrder();
}
ServiceHelper.cs:
public class ServiceHelper : IServiceHelper
{
public async Task<string> GetOrder()
{
string serviceUrl = "http://localhost:9060";//订单服务的地址,可以放在配置文件或者数据库等等...
var Client = new RestClient(serviceUrl);
var request = new RestRequest("/orders", Method.GET);
var response = await Client.ExecuteAsync(request);
return response.Content;
}
public async Task<string> GetProduct()
{
string serviceUrl = "http://localhost:9050";//产品服务的地址,可以放在配置文件或者数据库等等...
var Client = new RestClient(serviceUrl);
var request = new RestRequest("/products", Method.GET);
var response = await Client.ExecuteAsync(request);
return response.Content;
}
}
Startup.cs:
public class Startup
{
public Startup(IConfiguration configuration)
{
Configuration = configuration;
}
public IConfiguration Configuration { get; }
// This method gets called by the runtime. Use this method to add services to the container.
public void ConfigureServices(IServiceCollection services)
{
services.AddControllersWithViews();
//注入IServiceHelper
services.AddSingleton<IServiceHelper, ServiceHelper>();
}
// 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();
}
else
{
app.UseExceptionHandler("/Home/Error");
}
app.UseStaticFiles();
app.UseRouting();
app.UseAuthorization();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllerRoute(
name: "default",
pattern: "{controller=Home}/{action=Index}/{id?}");
});
}
}
HomeController.cs:
public class HomeController : Controller
{
private readonly ILogger<HomeController> _logger;
private readonly IServiceHelper _serviceHelper;
public HomeController(ILogger<HomeController> logger, IServiceHelper serviceHelper)
{
_logger = logger;
_serviceHelper = serviceHelper;
}
public async Task<IActionResult> Index()
{
ViewBag.OrderData = await _serviceHelper.GetOrder();
ViewBag.ProductData = await _serviceHelper.GetProduct();
return View();
}
public IActionResult Privacy()
{
return View();
}
[ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
public IActionResult Error()
{
return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
}
}
Index.cshtml:
@{
ViewData["Title"] = "Home Page";
}
<div class="text-center">
<h1 class="display-4">Welcome</h1>
<p>
@ViewBag.OrderData
</p>
<p>
@ViewBag.ProductData
</p>
</div>
代码比较简单,这里就不用docker了,直接控制台启动,使用浏览器访问:
- 一切正常。进行到这里,各个服务也独立运行了,客户端也能正常调用了,貌似算是完成一个简易的微服务了。但是,微服务架构最重要的原则就是——“高可用”。以上的做法明显不能满足高可用性,因为任何一个服务挂掉,所有依赖这个服务的业务系统都会受影响。
停止一下订单服务:docker stop orderservice
订单服务停止,导致客户端业务系统无法获取订单数据。要解决这个问题,很容易想到:集群。
简单的服务集群
既然单个服务实例有挂掉的风险,那么部署多个服务实例就好了嘛,只要大家不同时全挂就行。
- 使用docker运行多个服务实例:
docker run -d -p 9061:80 --name orderservice1 orderapi
docker run -d -p 9062:80 --name orderservice2 orderapi
docker run -d -p 9051:80 --name productservice1 productapi
docker run -d -p 9052:80 --name productservice2 productapi
现在订单服务和产品服务都增加到3个服务实例。
- 那么稍微改造一下客户端代码吧:ServiceHelper.cs:
public class ServiceHelper : IServiceHelper
{
public async Task<string> GetOrder()
{
string[] serviceUrls = { "http://localhost:9060", "http://localhost:9061", "http://localhost:9062" };//订单服务的地址,可以放在配置文件或者数据库等等...
//每次随机访问一个服务实例
var Client = new RestClient(serviceUrls[new Random().Next(0, 3)]);
var request = new RestRequest("/orders", Method.GET);
var response = await Client.ExecuteAsync(request);
return response.Content;
}
public async Task<string> GetProduct()
{
string[] serviceUrls = { "http://localhost:9050", "http://localhost:9051", "http://localhost:9052" };//产品服务的地址,可以放在配置文件或者数据库等等...
//每次随机访问一个服务实例
var Client = new RestClient(serviceUrls[new Random().Next(0, 3)]);
var request = new RestRequest("/products", Method.GET);
var response = await Client.ExecuteAsync(request);
return response.Content;
}
}
当然拿到这些服务地址可以自己做复杂的负载均衡策略,比如轮询,随机,权重等等 都行,甚至在中间弄个nginx也可以。这些不是重点,所以就简单做一个随机吧,每次请求来了随便访问一个服务实例。
- 浏览器测试一下:
可以看到请求被随机分配了。但是这种做法依然不安全,如果随机访问到的实例刚好挂掉,那么业务系统依然会出问题。简单处理思路是:1.如果某个地址请求失败了,那么换一个地址接着执行。2.如果某个地址的请求连续多次失败了,那么就移除这个地址,下次就不会访问到它了。。。。。。。业务系统实现以上逻辑,基本上风险就很低了,也算是大大增加了系统可用性了。
- 然后思考另一个问题:
实际应用中,上层的业务系统可能非常多,为了保证可用性,每个业务系统都去考虑服务实例挂没挂掉吗?而且实际应用中服务实例的数量或者地址大多是不固定的,例如双十一来了,流量大了,增加了一堆服务实例,这时候每个业务系统再去配置文件里配置一下这些地址吗?双十一过了又去把配置删掉吗?显然是不现实的,服务必须要做到可灵活伸缩。
- 这时候就引入一个名词:服务注册与发现
- [Golang软件推荐] Golang通用连接池
- RxJS -- Subscription
- ASP.Net Core项目在Mac上使用Entity Framework Core 2.0进行迁移可能会遇到的一个问题.
- RxJS速成 (下)
- RxJS速成 (上)
- Typescript 查缺补漏
- Git -- Stash
- Git -- Rebase
- Git -- 分支与合并 (命令行+可视化工具p4merge) Fast Forward 合并禁用 Fast Forward 合并自动合并解决合并的冲突
- 使用Angular CLI进行单元测试和E2E测试
- Git - 使用命令和P4Merge进行diff
- 使用Angular CLI进行Build (构建) 和 Serve
- 使用Angular CLI生成路由
- 使用Angular CLI从蓝本生成代码
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 错误提示合集--->待增加 Σ( ° △ °|||)︴
- RabbitMQ如何保证消息的可靠投递?
- Python处理json总结
- 使用SpringMVC写一个简单的跳转界面
- 使用自定义注解,设置发送到客户端的响应的内容类型
- Python构造数据的神器库-Faker
- SpringMVC中传参date类型失败,需要@DateTimeFormat(““)
- new ScalarHandler()-->返回值为long,不能用int接收!!!
- JavaWeb使用德鲁伊(略)实现登录、激活码注册(发送激活码到邮箱,点击激活链接后,才能正常登陆)、注册界面
- 转发的两种方式与重定向
- 关于监控、链路追踪、日志三者的区别
- 10.12面试:SpringMVC静态资源放行+如何实现转发和重定向+如何支持json+设置时间格式+设置json的key+对json的value序列化
- 10.13面试:什么是跨域?如何解决跨域问题+springMVC如何处理文件上传和下载+ssm整合思路 (待完善)
- 查找jar地址
- shiro篇:缓存配置