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

Bertha 。 2022-03-26 01:30 272阅读 0赞

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

## 简述 ##

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

![c7d9efa173894ac6f734f9307fc270ce2de.jpg][]

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

![9208d667920df7b2f35eac78edc98fa2a14.jpg][]

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

## 应用 ##

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

*  [创建一个.net][.net] core控制台项目

![86ee2e2d882e48a31e0d8bc8864e380f88c.jpg][]

*  引用`Beetlex.FastHttpApi`

![8da88fa7b426c6c8d348c44427d36b32523.jpg][]

*  编写一个简单的`HelloWorld`webapi服务

class Program
        {
            private static BeetleX.FastHttpApi.HttpApiServer mApiServer;
    
            static void Main(string[] args)
            {
                mApiServer = new BeetleX.FastHttpApi.HttpApiServer();
                mApiServer.Debug();
                mApiServer.Register(typeof(Program).Assembly);
                mApiServer.Open();
                Console.Write(mApiServer.BaseServer);
                Console.Read();
            }
        }
        [Controller]
        public class Home
        {
            /// <summary>
            /// Hello Word
            /// </summary>
            /// <param name="name">string:  you name</param>
            /// <returns>string</returns>
            [Get(Route = "{name}")]
            [DefaultJsonResultFilter]
            public object Hello(string name)
            {
                return new { Hello = "hello " + name, Time = DateTime.Now };
            }
        }

*  运行后浏览器访问一下

![ae56578f1a2bc336c7343f27661def8a1bf.jpg][]

*  创建Client调用

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

public interface IDataService
        {
            [Get(Route = "hello/{name}")]
            string Hello(string name);
        }

*  创建调用接口代理

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

*  调用服务

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

*  集群中心配置

![89c2e0054423698ebf6c171e6ec913fad69.jpg][]

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

## 配置负载 ##

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

![662a4991be9106e5dc6f9e4de29ab6f33cb.jpg][]

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

![fc636c9d006225553c7c5ae229ec2b0f057.jpg][]

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

![306d042b07f0a728927a160ca9413e318f5.jpg][]

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

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

项目地址:[https://github.com/IKende/FastHttpApi][https_github.com_IKende_FastHttpApi]

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

[c7d9efa173894ac6f734f9307fc270ce2de.jpg]: /images/20220326/d9fe314f61b143d587c1da5703811490.png
[9208d667920df7b2f35eac78edc98fa2a14.jpg]: /images/20220326/f48dbbe2b1c841ed990d6d321a4567fd.png
[.net]: http://xn--4gqvd70lutr.net/
[86ee2e2d882e48a31e0d8bc8864e380f88c.jpg]: /images/20220326/8f71af5f1db3492abd05b3e3ec64cf38.png
[8da88fa7b426c6c8d348c44427d36b32523.jpg]: /images/20220326/0c7cf3b21fda425c88234d9e2c295637.png
[ae56578f1a2bc336c7343f27661def8a1bf.jpg]: /images/20220326/9f40b9499d084ba38fc96569c7af4d8d.png
[89c2e0054423698ebf6c171e6ec913fad69.jpg]: /images/20220326/5844f07e4d6c452cabfcbd9d071c4e05.png
[662a4991be9106e5dc6f9e4de29ab6f33cb.jpg]: /images/20220326/59789aa909b24aa7a468cff13845d4ec.png
[fc636c9d006225553c7c5ae229ec2b0f057.jpg]: /images/20220326/32e7499774b14a6b9d23b94e457fb595.png
[306d042b07f0a728927a160ca9413e318f5.jpg]: /images/20220326/775eabfadc794921baa12eb283ea5519.png
[https_github.com_IKende_FastHttpApi]: https://github.com/IKende/FastHttpApi
[https_github.com_IKende_ClusterConfiguration]: https://github.com/IKende/ClusterConfiguration