微服务框架Demo.MicroServer运行手册

一.背景说明:

之前分享过一个微服务开发框架, “分享一个集成.NET Core+Swagger+Consul+Polly+Ocelot+IdentityServer4+Exceptionless+Apollo+SkyWalking的微服务开发框架”,前两天在Github上收到一个Issues,是想我这边提供下完整的运行文档和配置文件,因为之前想法是弄清楚这几个东西的职责之后,对于运行的先后顺序,和需要的配置key应该都会有了解,所以README编写只是介绍了用到了哪些东西,没有说如何运行,但是既然有人问起,我还是满足一下,就当成是自己回顾了。

二.回顾下项目结构


项目结构比较简单:

  • MicroServer.Instance文件夹下面存放的是微服务实例,至于微服务颗粒度的拆分得结合实际的业务情况

  • Demo.MicroServer.IdentityServer4 统一鉴权中心

  • Demo.MicroServer.Infrastructure 基础设施,可以自行在里面添加内容

  • Demo.MicroServer.Ocelot 这一层是Api网关

  • Demo.MicroServer.Repository 通用的数据访问层,包含MySQL,Mongo,Redis等,之所以抽离出来,是方便各个服务实例可是直接使用这些通用方法。

而上面说的 “.NET Core+Swagger+Consul+Polly+Ocelot+IdentityServer4+Exceptionless+Apollo+SkyWalking” 中有几个东西还未出现,分别是 Consul,Polly,Exceptionless,Apollo,SkyWalking,这里还是分别介绍下

  • Consul是一种服务网格解决方案,提供具有服务发现,健康检查,Key/Value存储,多数据中心等功能。在这里我们主要使用到服务发现,健康检查,启动场景是:微服务实例启动的时候

  • Polly是.NET弹性和瞬态故障处理库,与Ocelot天然友好集成,使用也只需要在Ocelot 层添加少数配置即可使用

  • Exceptionless是一款开源的实时的日志收集框架,可以使用在线或者本地搭建好的服务(如果只是本地测试建议直接使用在线的很方便),然后在微服务中配置好Url和应用的ApiKey就可以使用。

  • Apollo是携程框架部门研发的分布式配置中心,能够集中化管理应用不同环境、不同集群的配置,配置修改后能够实时推送到应用端,并且具备规范的权限、流程治理等特性,适用于微服务配置管理场景,搭建好Apollo服务后,我们代码配置文件就可以变得相当干净了,只用留Apollo的配置就行,其他的配置几乎全部可以放在Apollo里面了。

  • SkyWalking 关于SkyWalking 我有一篇文章专门介绍了这个,这里不在赘述,需要了解的可以查看:在微服务框架Demo.MicroServer中添加SkyWalking+SkyApm-dotnet分布式链路追踪系统

三.安装启动微服务周边应用

在运行服务之前,你或许可以先安装或开启以下几个服务

  1. MySql

  2. Exceptionless
    如果还没安装可以参考:https://github.com/exceptionless/exceptionless/wiki/self-hosting ,建议使用docker安装

  3. apollo
    如果还没安装,可以参考:https://github.com/ApolloAuto/apollo/blob/master/docs/quickstart/apollo_software_installation_guide_cn.md

  4. consul
    这个可以直接下载编译好的文件,直接启动就行
    ./consul agent -dev -data-dir=/data/consul -node=agent-1 -client=0.0.0.0 -bind=10.34.5.101 -datacenter=demo

  5. Skywalking
    请参考我之前的文章:在微服务框架Demo.MicroServer中添加SkyWalking+SkyApm-dotnet分布式链路追踪系统

咋一看这么多需要安装启动的是不是感觉很慌?
不用担心,其实如果先排除身份验证连数据库都不用读,可以只用安装consul就可以,至于apollo可以先将配置写在代码的配置文件中,对于将项目跑起来这点来说apollo不是必须的,日志收集也可以暂缓,性能检测也一样,我们可以先将核心的跑起来,再来完善他的周边,秉着这个思路,我们开始运行

四.开始启动

  1. 启动consul

    开发下我们可以这样启动consul服务:

    ./consul agent -dev -data-dir=/data/consul -node=agent-1 -client=0.0.0.0 -bind=10.34.5.101 -datacenter=demo

    启动之后的效果如图:

  2. 启动三个微服务实例

    dotnet Demo.MicroServer.UserService.dll --urls="http://*:6891" --ip="本机ip" --port=6891
    dotnet Demo.MicroServer.UserService.dll --urls="http://*:6892" --ip="本机ip" --port=6892
    dotnet Demo.MicroServer.UserService.dll --urls="http://*:6893" --ip="本机ip" --port=6893

    这里演示,分别在6891,6892,6893三个端口启动用户的微服务实例,启动之后,consul就开始工作了,如图

而Consul是如何发现服务的,其实得益于我们在服务里面添加的一个扩展:

public static IApplicationBuilder UseConsul(this IApplicationBuilder app, IConfiguration configuration)
{ConsulClient _client = new ConsulClient(c =>{c.Address = new Uri(configuration["Consul.ServerUrl"]);c.Datacenter = "Demo.MicroServer";});string ip = configuration["ip"];int port = int.Parse(configuration["port"]);int weight = string.IsNullOrEmpty(configuration["weight"]) ? 1 : int.Parse(configuration["weight"]);_client.Agent.ServiceRegister(new AgentServiceRegistration(){ID = "UserService-" + Guid.NewGuid(),Name = "Demo.MicroServer.UserService",Address = ip,Port = port,Tags = new string[] { string.IsNullOrEmpty(configuration["tags"]) ? "" : configuration["tags"] },   //标签Check = new AgentServiceCheck()                                                                     //健康检查{Interval = TimeSpan.FromSeconds(10),                                                            //每隔多久检测一次HTTP = $"http://{ip}:{port}/api/health/check",Timeout = TimeSpan.FromSeconds(5),DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(60)                                       //在遇到异常后关闭自身服务通道}});return app;
}

并在StartUp.cs中使用了他:app.UseConsul(Configuration);

其实到这里,项目就已经跑起来了,并且具备初步的负载均衡功能,我们可以通过这三个端口其中任意一个来调用服务都是可以的。凡是都有但是,难道要人为去配置什么场景使用哪个ip和端口的服务吗,或者说要将我们所有的服务都暴露出去吗,每个服务都加一套登录鉴权机制吗?想想都觉得很可怕,那么怎么解决这个问题呢,答案就是.Net 中常用的APi GateWay之:Ocelot

  1. 启动网关Ocelot

开始启动Ocelot层:dotnet Demo.MicroServer.Ocelot.dll
网关启动之后就可以通过网关的ip去访问任意被注册过的服务,前提是在网关层中有配置好协议,以下面两个为例子,一个是swagger,一个是用户服务

//swagger
{"DownstreamPathTemplate": "/doc/Demo.MicroServer.UserService/swagger.json","DownstreamScheme": "http","ServiceName": "Demo.MicroServer.UserService","LoadBalancer": "RoundRobin","UseServiceDiscovery": true,"UpstreamPathTemplate": "/doc/Demo.MicroServer.UserService/swagger.json","UpstreamHttpMethod": [ "GET", "POST", "DELETE", "PUT" ]
},
//UserService
{"DownstreamPathTemplate": "/api/{url}","DownstreamScheme": "http","UpstreamPathTemplate": "/api/{url}","UpstreamHttpMethod": [ "Get", "Post", "DELETE", "PUT" ],"ServiceName": "Demo.MicroServer.UserService","UseServiceDiscovery": true,"LoadBalancerOptions": {"Type": "RoundRobin"
},

由于每个服务中都已经配置好了swagger文档,所以这里只需要指定路由协议,一样的可以通过网关来访问swagger
这里可以通过网关的ip和端口访问swagger和userservice服务

截止到这里服务的注册与发现还有网关的上下游配置基本完成,但是围绕在网关层的东西有很多,例如缓存,限流,熔断器,在网关层统一鉴权等等,但是这些不是当前要讨论的,这个具体根据后续反馈再看是否要单独拿出来解释.

五.Apoll配置

上面介绍了运行启动流程,根据需求,这里也贴一下apollo总的配置项,而网关层和用户服务层的配置在appsetting中有配置,代码中已经都有了,这里着重贴下apollo中的配置

  1. Demo.MicroServer.Ocelot 层在apollo中的配置:

    Swagger.ServiceDocNames = Demo.MicroServer.UserService,Demo.MicroServer.ProductService
    IdentityService4.Uri = http://localhost:5000
    IdentityService4.UseHttps = false

    如图:

  2. Demo.MicroServer.UserService 层在apollo中的配置:

    MySqlConnections = server=mysql_ip;port=3306;database=demo_microserver;User Id=root;pwd=123456;charset=utf8
    Swagger.Name = Demo.MicroServer.UserService
    Swagger.Version = v1
    Swagger.DocName = Demo.MicroServer.UserService
    Swagger.Title = Api interface documentation
    Swagger.Description = See below for specific interface
    Swagger.Contact.Name = PeyShine
    Swagger.Contact.Email = PeyShine@qq.COM
    Swagger.XmlFile = Demo.MicroServer.UserService.xml
    Exceptionless.ApiKey = LmqMIxSTW0U68pKwJ3xXqrNrLqS6oEociW7OexNt
    Exceptionless.ServerUrl = http://exceptionless_ip:5000
    Consul.ServerUrl = http://consul_ip:8500
    MongoDB.DefaultConnection = mongodb://dev:Aa123456@mongo_ip/demo_db
    MongoDB.DefaultDatabase = demo_db
    MongoDB.DefaultTable = users

    如图:

六.总结

本文作为文章”分享一个集成.NET Core+Swagger+Consul+Polly+Ocelot+IdentityServer4+Exceptionless+Apollo+SkyWalking的微服务开发框架“的一个补充扩展,主要是介绍如何一步步启动Demo.MicroServer微服务框架,里面关于网关还有IdentityServer4没有进行深入讨论,想法是只要能先将项目核心部分跑起来,周边应用可以自行添加,后续再根据反馈是否要更加详细的去介绍。
其实理解了几个开源项目自己的职责之后,对运行流程就不难理解了,动手试试吧!

文章代码在Github中的地址:https://github.com/PeyShine/Demo.MicroServer,欢迎star

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/308538.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[Redis6]新数据类型_Bitmaps

Bitmaps 简介 现代计算机用二进制(位) 作为信息的基础单位, 1个字节等于8位, 例如“abc”字符串是由3个字节组成, 但实际在计算机存储时将其用二进制表示, “abc”分别对应的ASCII码分别是97、 98、 99&a…

mysql qps如何查看_一款查看mysql QPS的脚本

本脚本黏贴就可以使用绝对不坑人!!!(此脚本来源如一位大神网友)执行效果:脚本:#!/bin/bashPWEqipay20150504mysqladmin -P3306 -uroot -p$PW -r -i 1 ext |\awk -F"|" \"BEGIN{ count0; }"\{ if($…

.Net Core 自定义配置源从配置中心读取配置

配置,几乎所有的应用程序都离不开它。.Net Framework时代我们使用App.config、Web.config,到了.Net Core的时代我们使用appsettings.json,这些我们再熟悉不过了。然而到了容器化、微服务的时代,这些本地文件配置有的时候就不太合适…

[Redis6]Bitmaps与set对比

Bitmaps与set对比 但Bitmaps并不是万金油, 假如该网站每天的独立访问用户很少, 例如只有10万(大量的僵尸用户) , 那么两者的对比如下表所示, 很显然, 这时候使用Bitmaps就不太合适了&#xff0c…

MySQL分布式ID_分布式唯一ID系列(3)——数据库自增ID机制适合做分布式ID吗

数据库自增ID机制原理介绍在分布式里面,数据库的自增ID机制的主要原理是:数据库自增ID和mysql数据库的replace_into()函数实现的。这里的replace数据库自增ID和mysql数据库的replace_into()函数实现的。这里的replace into跟insert功能类似,不…

7-15 QQ帐户的申请与登陆 (25 分)(map做法+思路分析)

一:题目 实现QQ新帐户申请和老帐户登陆的简化版功能。最大挑战是:据说现在的QQ号码已经有10位数了。 输入格式: 输入首先给出一个正整数N(≤10 ​5 ​​ ),随后给出N行指令。每行指令的格式为:“命令符&a…

[Redis6]新数据类型_HyperLogLog

HyperLogLog 简介 在工作当中,我们经常会遇到与统计相关的功能需求,比如统计网站PV(PageView页面访问量),可以使用Redis的incr、incrby轻松实现。 但像UV(UniqueVisitor,独立访客)、独立IP数…

每天都在支付,你真的了解信息流和资金流?

作为一个财务类的产品经理,除了每天被财务“虐待”千百遍,还需要对整个资金流向很清楚:钱给谁,怎么给,怎么做逆向流程,谁参与容错等。财务很在意资金的流转安全,但又极不愿意花时间关注它。诸如…

mysql改表字段类型导致数据丢失_故障分析 | 记一次 MySQL 主从双写导致的数据丢失问题【转】...

一、问题起源不久前用户反馈部门的 MySQL 数据库发生了数据更新丢失。为了解决这个问题,当时对用户使用的场景进行了分析。发现可能是因为用户在两台互为主从的机器上都进行了写入导致的数据丢失。如图所示,是正常和异常情况下应用写入数据库的示例。随后…

[Redis6]新数据类型_Geospatial

Geospatial 简介 Redis 3.2 中增加了对GEO类型的支持。GEO,Geographic,地理信息的缩写。该类型,就是元素的2维坐标,在地图上就是经纬度。redis基于该类型,提供了经纬度设置,查询,范围查询&…

《Apache SkyWalking实战》送书活动结果公布

截至2020.07.31 本次送书活动 这么多Apache顶级项目,SkyWalking为何一枝独秀?,本次很多同学在看到活动的书,自行就到网上购买了书。下面把Top 8的留言截图给大家回顾一下。以下8位同学将获赠书籍一本:landon、田晓青、…

7-16 一元多项式求导 (20 分)(详解+题目分析)

7-16 一元多项式求导 (20 分) 1:题目 设计函数求一元多项式的导数。 输入格式: 以指数递降方式输入多项式非零项系数和指数(绝对值均为不超过1000的整数)。数字间以空格分隔。 输出格式: 以与输入相同的格式输出导数多项式非零项的系数和…

[MyBatisPlus]通用枚举

通用枚举 数据库表添加字段sex 创建通用枚举类型 package com.xxxx.mybatisplus.enums;import com.baomidou.mybatisplus.annotation.EnumValue; import lombok.Getter;Getter public enum SexEnum {MALE(1,"男"),FEMALE(2,"女");EnumValue // 将注解所标…

信创产业发展应不忘初心牢记使命

受国际大环境影响,信创市场国产化替代步伐已然加速。由于其中存在巨大的商机,信创市场中已然出现一些乱象。有的厂商拿洋技术标榜和宣传自主;有的厂商全国各地跑马圈地建产业园,进而向当地政府要政策要市场;有的厂商恶…

mysql采用 级触发_Mysql高级之触发器(trigger)

触发器是一类特殊的事务 ,可以监视某种数据操作(insert/update/delete),并触发相关操作(insert/update/delete)。看以下事件:完成下单与减少库存的逻辑Insert into o (gid,num) values (2,3); // 插入语句Update g set goods_num goods_num - 3 where id 2;// 更新…

[MyBatisPlus]代码生成器

代码生成器 引入依赖 <dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId><version>3.5.1</version></dependency><dependency><groupId>org.freemarker</groupId…

飞机游戏项目完整代码(详解JAVA300集)

一&#xff1a;简介 这是一个可以通过键盘移动飞机位置 然后可以躲避 炮弹的打击 &#xff0c;游戏结束为 当炮弹与飞机发生碰撞 则 最后显示出飞机存活的时长 代表游戏结束 二&#xff1a;上码 1&#xff1a;运行游戏的类 package src.src.cn.wyj.飞机;import java.awt.Co…

[MyBatisPlus]模拟多数据源环境及测试

模拟多数据源环境 多数据源 适用于多种场景&#xff1a;纯粹多库、 读写分离、 一主多从、 混合模式等 目前我们就来模拟一个纯粹多库的一个场景&#xff0c;其他场景类似 场景说明&#xff1a; 我们创建两个库&#xff0c;分别为&#xff1a;mybatis_plus&#xff08;以前…

生活有哪些残忍的真相?

1.很多人拼尽全力&#xff0c;只是为了艰难的生存。2.大多数人一点也不喜欢读书&#xff0c;只是喜欢被别人贴上“爱读书”的标签罢了。3.你越没能力&#xff0c;社交圈质量就越低&#xff0c;碰到的傻逼就越多。4.职场绝不能追求快乐&#xff0c;只能追求痛苦的成长。5.抬起头…

7-17 汉诺塔的非递归实现 (25 分)(思路分析)

一&#xff1a;题目 借助堆栈以非递归&#xff08;循环&#xff09;方式求解汉诺塔的问题&#xff08;n, a, b, c&#xff09;&#xff0c;即将N个盘子从起始柱&#xff08;标记为“a”&#xff09;通过借助柱&#xff08;标记为“b”&#xff09;移动到目标柱&#xff08;标记…