.net core下简单构建高可用服务集群

一说到集群服务相信对普通开发者来说肯定想到很复杂的事情,如zeekeeper ,反向代理服务网关等一系列的搭建和配置等等;总得来说需要有一定经验和规划的团队才能应用起来。在这文章里你能看到在.net core下的另一种集群构建方案,通过Beetlex即可非常便捷地构建高可用的集群服务。

简述

Beetlex的Webapi集群应用并没有依赖于第三方服务,而是由Beetlex自身完成;它主要是通过Client和策略监控服务相结合的方式来实现集群化的服务负载访问。以下是服务结构:

client一旦从配置中心获取了集群的策略,就会脱离配置中心独自进行负载处理;在运行中会定时从配置中心获取更新策略,在这个过程中即使配置中心不可用也不影响整体服务处理。以下是配置中心的策略管理:

 

通过管理中心可以对不同的URL进行负载权重配置,默认可以配置一个*来处理所有负载;当到达一定规模的情况可以针对某些URL规则来进行策略配置.中心除了可以配置策略外还提供了服务资源监控,可以更方便地进行权重调整。

应用

接下来通过一个简单的示例来介绍如何通过Beetlex构建高可用的webapi集群服务.

  • 引用Beetlex.FastHttpApi

  • 编写一个简单的HelloWorldwebapi服务

    1class Program 2{ 3 private static BeetleX.FastHttpApi.HttpApiServer mApiServer; 4 5 static void Main(string[] args) 6 { 7 mApiServer = new BeetleX.FastHttpApi.HttpApiServer(); 8 mApiServer.Debug(); 9 mApiServer.Register(typeof(Program).Assembly); 10 mApiServer.Open(); 11 Console.Write(mApiServer.BaseServer); 12 Console.Read(); 13 } 14} 15[Controller] 16public class Home 17{ 18 /// <summary> 19 /// Hello Word 20 /// </summary> 21 /// <param name="name">string: you name</param> 22 /// <returns>string</returns> 23 [Get(Route = "{name}")] 24 [DefaultJsonResultFilter] 25 public object Hello(string name) 26 { 27 return new { Hello = "hello " + name, Time = DateTime.Now }; 28 } 29}
  • 运行后浏览器访问一下

  • 创建Client调用

同样是构建一个控制台程序,然后引用BeetleX.FastHttpApi,定义访问接口

1 public interface IDataService 2 { 3 [Get(Route = "hello/{name}")] 4 string Hello(string name); 5 }
  • 创建调用接口代理

    HttpClusterApi = new BeetleX.FastHttpApi.Clients.HttpClusterApi(); DataService = HttpClusterApi.Create<IDataService>(); await HttpClusterApi.LoadNodeSource("default", "http://localhost:8080");//加载配置服务中的default节点

  • 调用服务

    var result = DataService.Hello("henry");

  • 集群中心配置

这样一个集群化的服务就完成,可能有人会问这明明就是单一服务,怎可能是高可用的服务集群呢?接下来我们做一系的压测并通过配置中心实现无缝地增加服务来应对测试的处理。

配置负载

高可用集群才是我们的目标,但实际应用中也不可能一下子就有这样的需求,往往是随意着业务的增长集群服务的需求会慢慢显露出来;接下来就对上面的单服务进行一个压力测试,开启了40个线程进行压力测试,由于部署服务只是两核,所以一下子就把资源压满了。

接下来需要新的节点服务来支撑并发处理,这个时候只需要新部署一份服务,在配置中心添加节点即可。

有新的服务加入后,并发由原来的1W多变成3W,而这个调整是完全不需要调整任何程序的!由于压测下来两台服务器的资源都比较吃紧,所以再添加一台服务来应对并发,但这一次添加的服务权重只有之前两台的一半。

从测试结果来看最后添的服务,依据权重的设置来承载了相应的并发处理。

通过以上示例,你会发现通过Beetlex构建高可用的webapi集群服务是一件非常简单的事情。

项目地址:https://github.com/IKende/FastHttpApi

集群策略管理项目地址:https://github.com/IKende/ClusterConfiguration

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

RAC环境单实例启动数据库收到ORA

     在RAC环境中,如果你在没有启动节点的集群服务的情况下单实例启动数据库,将收到类似如下的报错:\oracle@rhel1u01\$sqlSQL\Plus:Release10.2.0.5.0ProductiononTueApr215:00:272013Copyright(

00:Java简单了解

浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。