.NET中大型项目开发必备(5)--Web服务/WebApi的负载均衡


相关下载:

Web服务的负载均衡-示例代码(dp4-WebBalance.rar)

Web服务的负载均衡-示例代码(dp4-WebBalance.rar)

 

【要点综述1】:为了演示Web服务的负载均衡,本文会创建3个形式一致的web服务(或者说,创建1个web服务但分别拷贝部署在3个不同的地址),然后在客户端创建一个代理以“负载均衡”的算法形式远程调用这3个web服务。

【要点综述2】:为了实现“统一/透明”的调用形式连接“web服务端”与“客户端”两者,一个居中的“接口”类是必须创建的,且所有远程web服务需要继承此接口。

【要点综述3】:Web Api是一个经典的http服务提供形式,WCF也是一个经典的两端通信模式,本文还将会极巧妙的整合这两者,让一个服务一次编写同时具备Web Api与WCF两者的特性。

 

我们首先在Visual Studio中新建第一个名字叫“YZZ.Interface”的解决方案+类库工程,并在此工程中创建“IBase接口”与“Person实体类”,代码分别如下:

IBase接口:

using System.ServiceModel;//需要添加对System.ServiceModel.dll程序集的引用
using System.ServiceModel.Web;//需要添加对System.ServiceModel.Web.dll程序集的引用

namespace YZZ.Interface
{
    [ServiceContract]
    public interface IBase
    {
        [OperationContract]
        [WebInvoke(Method = "POST", UriTemplate = "/AccessRight", RequestFormat = WebMessageFormat.Json, ResponseFormat = WebMessageFormat.Json, BodyStyle = WebMessageBodyStyle.WrappedRequest)]
        Person AccessRight(int age);
    }
}

Person实体类:

namespace YZZ.Interface
{
    public class Person
    {
        public string name;
        public int age;
        public int right;
    }
}

如上代码所示,IBase接口中定义了一个通过年龄来做权限判断的AccessRight方法,并在该方法上附加了OperationContract与WebInvoke两个属性。OperationContract这个属性是用来给方法赋予WCF的特性,而WebInvoke这个属性则是给方法赋予了Web Api的特性。

编译该解决方案,获得YZZ.Interface.dll。

 

 

然后,我们再在Visual Studio中新建第二个名字叫“YZZ.Service”的解决方案+WCF服务应用程序工程,并在此工程中创建名为“MyBaseService.svc”的WCF服务文件,该文件的后台代码如下:

using YZZ.Interface;//需要添加前述IBase接口定义的YZZ.Interface.dll的引用

namespace YZZ.Service
{
    public class MyBaseService : IBase
    {
        public Person AccessRight(int age)
        {
            if (age > 27)
                return new Person { name = "管理员", age = age, right = 1 };
            else
                return new Person { name = "学生/员工", age = age, right = 0 };
        }
    }
}

如上代码所示,MyBaseService类实现了IBase接口中定义的AccessRight方法。

 

并且,此时我们还需要在此工程的Web.config中做如下两项配置,才能使得WCF与Web Api的特性在AccessRight方法身上完全见效。

配置一:在<system.serviceModel>节点下添加如下配置

    <!--用来对外发布WCF与WebAPI-->
    <services>
      <service name="YZZ.Service.MyBaseService">
        <!-- 对应Web API的End Point -->
        <endpoint address="webapi" binding="webHttpBinding" contract="YZZ.Interface.IBase" behaviorConfiguration="WebApiEndPointBehavior" />
        <!-- 对应WCF的End Point -->
        <endpoint address="" binding="basicHttpBinding" contract="YZZ.Interface.IBase" />
      </service>  
    </services>

配置二:在<behaviors>节点下添加如下配置

      <!-- WCF Service转换为Web API后,使用的behavior -->
      <endpointBehaviors>
        <behavior name="WebApiEndPointBehavior">
          <webHttp />
        </behavior>
      </endpointBehaviors>

如此一来,AccessRight方法就兼具了Web Api与WCF的双重特性。其Web Api(Web服务)的调用路径如下:

http://部署的服务器路径(ip+port)/MyBaseService.svc/webapi/AccessRight

 

 

为了演示Web服务的负载均衡的效果,现在我们把AccessRight方法的内容稍做修改成3个版本,分别编译YZZ.Service工程后部署在3个不同的地方(如何部署请参考其它资料,这是基础知识)。如下:

部署地址1:http://139.244.52.136:120/MyBaseService.svc

对应AccessRight代码1:

        public Person AccessRight(int age)
        {
            if (age > 27)
                return new Person { name = "管理员", age = age, right = 1 };
            else
                return new Person { name = "学生/员工", age = age, right = 0 };
        }

部署地址2:http://139.244.52.136:220/MyBaseService.svc

对应AccessRight代码2:

        public Person AccessRight(int age)
        {
            if (age > 27)
                return new Person { name = "管理员1", age = age, right = 1 };
            else
                return new Person { name = "学生/员工1", age = age, right = 0 };
        }

部署地址3:http://139.244.52.136:230/MyBaseService.svc

对应AccessRight代码3:

        public Person AccessRight(int age)
        {
            if (age > 27)
                return new Person { name = "管理员2", age = age, right = 1 };
            else
                return new Person { name = "学生/员工2", age = age, right = 0 };
        }

 

 

当“接口”与其对应的“3个Web服务”全部准备就绪,我们最后就来创建一个客户端以“负载均衡”的算法形式远程调用这3个web服务。

我们再次打开Visual Studio,新建第三个名字叫“YZZ.Client”的解决方案+控制台工程。然后,我们做如下四步操作:

【第一步】:为工程添加DeveloperSharp.dll组件引用。并添加YZZ.Interface.dll的引用。

【第二步】:创建一个名为DeveloperSharp.xml的配置文件,并在该文件中设置如上3个web服务的负载均衡策略。文件内容如下:

<?xml version="1.0" encoding="utf-8" ?>
<DeveloperSharp>
    <IServiceList>
        <IService Id="YZZ.Interface.IBase">
            <Service Id="A11" Enable="true" Weight="100" BindType="basicHttpBinding" Address="http://139.244.52.136:120/MyBaseService.svc"/>
            <Service Id="A22" Enable="true" Weight="100" BindType="basicHttpBinding" Address="http://139.244.52.136:220/MyBaseService.svc"/>
            <Service Id="A33" Enable="true" Weight="100" BindType="basicHttpBinding" Address="http://139.244.52.136:230/MyBaseService.svc"/>
        </IService>
    </IServiceList>   
</DeveloperSharp>

对此xml配置文件说明如下:

(1)     每一个IService节点代表了一组Web服务,此节点的Id值(本文示例值是:YZZ.Interface.IBase)必须是这组Web服务的“基类接口”的完全限定名。

(2)     Service节点中的Weight属性代表了使用权重。本文示例的3个服务的Weight值分别是100、100、100,则这3个服务的负载均衡使用分配比例将会是1:1:1。若把这三个值分别设置为100、50、50,则这3个服务的使用分配比例将会变为2:1:1。设置成你想要的比例吧。

(3)     Service节点中的Enable属性代表了是否可用。true代表可用,false代表不可用。

 

【第三步】:在工程配置文件App.config(或Web.config)中添加appSettings节点,节点内容如下:

  <appSettings>
    <add key="DatabaseType" value="" />
    <add key="ConnectionString" value="" />
    <add key="ErrorPage" value="" />
    <add key="ErrorLog" value="D:\Test2\YZZ.Client\log.txt" />
    <add key="ConfigFile" value="D:\Test2\YZZ.Client\DeveloperSharp.xml" />
  </appSettings>

其中,ConfigFile的设置是为了链接前述的DeveloperSharp.xml这个配置文件。ErrorLog则是设置一个错误日志文件。它们均需要设置为文件的“绝对路径”(此处使用“绝对路径”而不是“相对路径”,一是有利于安全性,二是有利于分布式部署)

【第四步】:在控制台应用类的代码中,添加创建“Web服务”负载均衡调用的工具IUtility.GetService<T>(),并通过该工具调用远程的Web服务,注意:核心代码就一行而已!!此示例连续3次调用Web服务,看会显示什么结果。如下:

    class Program
    {
        static void Main(string[] args)
        {
            YZZ.Interface.Person p;
            DeveloperSharp.Framework.CoreUtility.IUtility IU = new DeveloperSharp.Framework.CoreUtility.Utility();//创建“Web服务”负载均衡调用的工具

            //第一次调用远程Web服务
            p = IU.GetService<YZZ.Interface.IBase>().AccessRight(20);
            Console.WriteLine(p.name);

            //第二次调用远程Web服务
            p = IU.GetService<YZZ.Interface.IBase>().AccessRight(20);
            Console.WriteLine(p.name);

            //第三次调用远程Web服务
            p = IU.GetService<YZZ.Interface.IBase>().AccessRight(20);
            Console.WriteLine(p.name);

            Console.ReadLine();
        }
    }

从以上示例代码我们可以清晰的得知:IUtility.GetService<T>()就是实现负载均衡的关键所在。泛型T需要设置为被调用“Web服务组”的“基类接口”,而IUtility.GetService<T>()方法则会每次根据配置的负载均衡策略创建对应的远程Web服务代理。

 

YZZ.Client控制台工程输出显示结果如下:

学生/员工

学生/员工1

学生/员工2

 

最后提示一点:若要把一组Web服务的负载均衡应用改为单Web服务应用,只需要把DeveloperSharp.xml配置文件中IService节点下的Service节点数量设置为一个即可实现。

 

后记:读完本文,你有没有发现,“微服务”中常用的注册、发现、服务降级、等功能,往往可通过修改DeveloperSharp.xml这个配置文件来实现?未完待续… 

 

总结

本文技术点思路梳理:

  1. 创建Web服务组的通用基类“接口”。并在该“接口”上附加ServiceContract、OperationContract、WebInvoke三属性。
  2. 创建WCF服务并实现上述“接口”。并在Web.config中添加<services>与<endpointBehaviors>两项配置,让WCF服务兼具Web服务的特性。
  3. 把上述Web服务分别部署在网络上多个不同的地方,形成“Web服务组”。
  4. 通过DeveloperSharp.xml来配置“Web服务组”的负载均衡策略。
  5. 创建客户端,在其App.config/Web.config中添加链接DeveloperSharp.xml的appSettings节点。再在代码中创建基于DeveloperSharp.dll的“Web服务负载均衡调用”工具,并通过该工具调用远程的Web服务。

 

【附注】:文章开头给出的下载示例,均已成功运行通过。但下载示例往往只包含“核心模板”内容。有些辅助内容需要自己建立/设置(比如:数据库创建、链接字符串设置、文件配置、路径设置、参数设定、等等...)。
请在理解文章内容的基础上,再做示例实验。若遇异常报错,请仔细阅读+理解本文。
也随时欢迎联系作者,微信扫描文末二维码,获取更多技术支持!

推荐阅读

 

引用来源:https://www.cnblogs.com/DeveloperSharp/p/15824810.html

版权声明:本文为YES开发框架网发布内容,转载请附上原文出处连接
管理员
上一篇:.NET中大型项目开发必备(8)--高效分页
下一篇:.NET中大型项目开发必备(4)--数据库的读写分离
评论列表

发表评论

评论内容
昵称:
验证码:
验证码
关联文章

.NET大型项目开发必备(5)--Web服务/WebApi负载均衡
windows平台分布式微服务解决方案(5)--Web服务/WebApi负载均衡
.NET大型项目开发必备(6)--IUtility工具介绍
.NET大型项目开发必备(8)--高效分页
.NET大型项目开发必备(4)--数据库读写分离
.NET大型项目开发必备(10)--图片裁剪、缩放、与加水印
.NET大型项目开发必备(2)--CORS跨域访问
.NET大型项目开发必备(1)--UUID全球通用唯一识别码
.NET大型项目开发必备(12)--使用MQ消息队列
.NET大型项目开发必备(9)--http请求调用(Post与Get)
.NET大型项目开发必备(7)--ORM数据库访问技术
YES-WEB快速开发框架,.NET WEB开发平台,高效web项目开发框架
在Winform项目Web API.NetCore项目使用Serilog 来记录日志信息
Winform开启一个http服务,web服务
.NET Core鉴权授权正确方式(.NET5)
网站迁移纪实:从Web Form 到 Asp.Net Core (Abp vNext 自定义开发
(五)React Ant Design Pro + .Net5 WebApi:后端环境搭建-Autofac注入+ 泛型仓储
.NET Core 项目windows server部署
.net服务之RFC
在ASP.NET Core web API使用Swagger/OpenAPI(Swashbuckle)

热门标签
.NET Core .NET Reactor ag-grid AI发布 api安全 ASP.NET Core C#DLL加密 C#播放声音 C#代码混淆 C#代码加密 ChromeDriver Codex DateTime DBeaver devexpress devTool DLL混淆 edge.js EF EFCore Electron element-ui el-form el-table excel FastReport FileStream FolderBrowerDialog FolderSelectDialog form提交 git gridcontrol gridview input javascript json字符串 JS转换对象JSON jwt JWT授权 linq log Math MCP mitmproxy MVC MySQL Navicat netstat nginx node_modules NSwag Nuget Nuget镜像 number PowerShell pyinstaller python pythoncom python爬虫 python抓包 pywin32 redis Requests-html RestSharp Selenium sql SQL Server Swagger to-cms Visual Studio VSCode vue VueRouter vue路由 VUE页面通讯 Webpack Windows Windows服务 winform wmi xlrd yaml YESCMS YESWEB开发框架 白象 表单提交 播放声音 打开URL 代码混淆 弹窗提醒 端口占用 对象转换 分布式 公共字典 机器码 进程排查 静态资源 开发指南 路由参数 密钥 配置教程 配置文件 权限 人工智能 任务 任务调度 日期间隔 日志 日志记录 省市区 授权验证 数据库 四舍五入 文案 文件读取 文件夹选择 文件目录选择 问题排查 行政区域数据 页面通讯 中间件 CSharp 事务锁 工单系统 并发控制 重复提交 CMS Markdig Markdown markdown-it marked 技术选型 VS Code 开发工具 源代码管理 版本控制 Docker PostgreSQL 时区 部署排查 CMS架构 EF Core 主题系统 二次开发 插件系统 容器 运维命令 镜像清理 Linux NAS 远程挂载 飞牛 fnOS S/4HANA SAP GUI SAP HANA SAP R/3 SAP入门 SAP版本 ERP SAP SAP MM 库存管理 物料管理 采购管理 入门教程 SAP S/4HANA SPRO 企业结构 采购组织 MM01 物料主数据 物料类型 BP分组 业务伙伴 供应商主数据 ME41 RFQ 库存物料 采购流程 ME51 消耗性物料 科目分配 采购申请 AC03 ML81N 外部服务 服务主数据 Business Partner SAP培训 ME51N MM模块 Lean Services MM-SRV 外部服务采购 PIR 供应来源 采购主数据 采购信息记录 ME31K 框架协议 计划协议 采购合同 ME01 供应来源确定 货源清单 MEQ1 供应源确定 配额安排 配额评分 MD04 MD21 MRP 计划文件 需求计划 批量程序 MD01N MD02 MRP Live MD05 MM 物料计划 优化采购 供应源 采购订单 ME2A 供应商确认 采购监控 Flexible Workflow 凭证释放 采购审批 释放策略 实地盘点 物料凭证 货物移动 MIGO 收货 移动类型 已撤回 供应商退货 货物发出 STO 库存转储 转移过账 生产订单 预留 GR/IR MIRO 供应商发票 物流发票校验 OMR2 税码 FI PP SD 实操教程 MRBR OMR6 发票差异 交货成本 后续借记 MI01 实物盘点 盘点差异 公司代码 工厂 组织结构 OMS2 主数据定制 自动科目确定 BP角色 CVI 伙伴确定 编号范围 凭证类型 字段选择 FBN1 OMBT OMC2 会计凭证 OMJJ BOM 委外加工 项目类别L MRKO 供应商寄售 特殊库存K MRKON PIPE Pipeline 特殊库存P ERS MRIS 发票计划 周期性结算 里程碑付款 变更追踪 版本管理 采购凭证 SFTP WebDAV 网盘 飞牛fnOS AMPL HERS MPN 中文教程 库存确定 可用性检查 缺件检查 Output Management 消息确定 输出确定 分割评估 库存计价 评估类别 评估类型 PB00 RM0000 条件技术 采购定价 MM-FI集成 OBYC 库存估价 文本类型 文本采用 EFB EVO MSV SU3 用户参数 发票校验 合同参照 履约保留款 特别总账 预付款 Fiori Launchpad SAP Fiori 应用导航 用户体验 LSMW LTMC Migration Cockpit 数据迁移 BRFplus OPD Output Control My Inbox 审批流程 灵活工作流 SAP PP 外部加工 SAP QM 检验批 质量信息记录 采购收货 SAP PM 维护BOM 维护订单 SAP SD SAP Service 端到端流程 MM模块培训 FI-MM集成 供应商管理 审批配置 FICO入门 SAP FICO 财务配置 供应商税务 预扣税 House Bank 银行对账 客户清账 应收账款 FI控制 验证与替代 印度 GST 税务配置 F110 FBZP EWM入门 SAP EWM 仓库管理 OX14 成本核算 物料评估 后勤配置 物料组 价值更新 数量更新 PP-PI 流程制造 生产计划 容差配置 SAP事务码 SAP基础 TCODE Basis 事务代码 MMNR 编号区间 采购实操 组织架构 OMSF SAP实操 FI配置 端口修改 密码设置 数据库配置 远程访问 ABAP基础 SAP ABAP 内表 变量定义 常量 数据类型 ABAP SAP开发 变量 基础语法 系统变量 结构体 字符串处理 循环语句 控制语句 DDIC SE11 数据字典 透明表 ABAP开发 ALE EDI IDoc 增强技术 ABAP内表 HASHED TABLE SORTED TABLE STANDARD TABLE 基本概念 性能优化 PARAMETERS SELECT-OPTIONS SELECTION-SCREEN 报表程序 选择屏幕 F4帮助 Report事件 输入校验 ABAP SQL ABAP语法 Open SQL SELECT 数据库访问 IKuai IP修改 PVE 网络配置 虚拟化
联系我们
联系电话:15090125178(微信同号)
电子邮箱:garson_zhang@163.com
站长微信二维码
微信二维码