其他分享
首页 > 其他分享> > Taurus.MVC 微服务框架 入门开发教程:项目集成:6、微服务间的调用方式:Rpc.StartTaskAsync。

Taurus.MVC 微服务框架 入门开发教程:项目集成:6、微服务间的调用方式:Rpc.StartTaskAsync。

作者:互联网

系统目录:

本系列分为项目集成、项目部署、架构演进三个方向,后续会根据情况调整文章目录。

开源地址:https://github.com/cyq1162/Taurus.MVC

本系列第一篇:Taurus.MVC V3.0.3 微服务开源框架发布:让.NET 架构在大并发的演进过程更简单。

Taurus.MVC 微服务框架 入门开发教程:项目集成:1、服务端:注册中心、网关(提供可运行程序下载)。

Taurus.MVC 微服务框架 入门开发教程:项目集成:2、客户端:ASP.NET Core(C#)项目集成:应用中心。

Taurus.MVC 微服务框架 入门开发教程:项目集成:3、客户端:其它编程语言项目集成:Java集成应用中心。

Taurus.MVC 微服务框架 入门开发教程:项目集成:4、默认安全认证与自定义安全认证。

Taurus.MVC 微服务框架 入门开发教程:项目集成:5、统一的日志管理。

Taurus.MVC 微服务框架 入门开发教程:项目集成:6、微服务间的调用方式:Rpc.StartTaskAsync。

Taurus.MVC 微服务框架 入门开发教程:项目部署:1、微服务应用程序常规部署实现多开,节点扩容。

Taurus.MVC 微服务框架 入门开发教程:项目部署:2、让Kestrel支持绑定多个域名转发,替代Ngnix使用。

Taurus.MVC 微服务框架 入门开发教程:项目部署:3、微服务应用程序版本升级:全站升级和局部模块升级。

Taurus.MVC 微服务框架 入门开发教程:项目部署:4、微服务应用程序发布到Docker部署(上)。

Taurus.MVC 微服务框架 入门开发教程:项目部署:5、微服务应用程序发布到Docker部署(下)。

Taurus.MVC 微服务框架 入门开发教程:项目部署:6、微服务应用程序Docker部署实现多开。

Taurus.MVC 微服务框架 入门开发教程:项目部署:7、微服务节点的监控。

Taurus.MVC 微服务框架 入门开发教程:架构演进:1、从单应用程序简单过渡到负载均衡。

Taurus.MVC 微服务框架 入门开发教程:架构演进:2、负载均到模块拆分负载。

Taurus.MVC 微服务框架 入门开发教程:架构演进:3、模块拆分负载到多级负载均衡。

Taurus.MVC 微服务框架 入门开发教程:运行示例:https://github.com/cyq1162/Taurus.MVC.MicroService.Demo

前言:

以过多天的努力,终于提交了V3.1.1版本:

-------------------------V3.1.1.0【升级微服务功能】((2022-09-09 - 2022-09-13)-----------------------------
1、优化:调整Controller的名称空间:Taurus.Core =>Taurus.Mvc
2、优化:控制器命名调整:允许控制器名称不以Controller结尾(DefaultController除外)。
3、优化:Extend 更名:Plugin :原有Auth模块,独立出外部项目,变更为插件方式提供。
4、优化:微服务网关代理调用。
5、优化:微服务间的Key的网络调用请求头传参数名变更:microservice => mskey。
6、优化:CheckAck、CheckToken、CheckMicroService、BeginInvode、EndInvode等方法(参数优化)。

7、新增:IgnoreDefaultControllerAttribute 允许控制器忽略全局DefaultController事件。
8、新增:提供微服务间的调用方式:Taurus.MicroService.Rpc。

而新的版本,重要的内容,就是重新提供了Rpc间的方法调用,花了不少精力在处理并发的优化上面。

对于微服务间的调用而言,Taurus.MVC微服务框架提供了以下方法:

namespace Taurus.MicroService
{
    /// <summary>
    /// 一般用于客户端:服务间的RPC调用
    /// </summary>
    public static partial class Rpc
    {
        /// <summary>
        /// 根据微服务注册名称获取请求的主机地址【有多个时,由内部控制负载均衡,每次获取都会循环下一个】
        /// 【自动识别(先判断:是否客户端;再判断:是否服务端)】
        /// </summary>
        /// <param name="name">微服务注册名称</param>
        /// <returns></returns>
        public static string GetHost(string name)

        /// <summary>
        /// 根据微服务注册名称获取请求的主机地址【有多个时,由内部控制负载均衡,每次获取都会循环下一个】
        /// </summary>
        /// <param name="name">微服务注册名称</param>
        /// <param name="isClient">指定查询:true(客户端):false(服务端)</param>
        /// <returns></returns>
        public static string GetHost(string name, bool isClient)

        /// <summary>
        /// 执行一个异步的【通用】请求任务。
        /// </summary>
        /// <param name="request">任务请求</param>
        /// <returns></returns>
        public static RpcTask StartTaskAsync(RpcTaskRequest request)
        {
            return Rest.StartTaskAsync(request);
        }

        /// <summary>
        /// 对远程服务发起一个异步Get请求。
        /// </summary>
        /// <param name="name">远程的注册模块名</param>
        /// <param name="pathAndQuery">请求路径和参数</param>
        /// <param name="header">请求头</param>
        /// <returns></returns>
        public static RpcTask StartGetAsync(string name, string pathAndQuery, Dictionary<string, string> header = null)


        /// <summary>
        /// 对远程服务发起一个异步Get请求。
        /// </summary>
        /// <param name="url">请求的地址</param>
        /// <param name="header">可追加的请求头部分</param>
        /// <returns></returns>
        public static RpcTask StartGetAsync(string url, Dictionary<string, string> header = null)

        /// <summary>
        ///  对远程服务发起一个异步Post请求。
        /// </summary>
        /// <param name="name">微服务名称</param>
        /// <param name="pathAndQuery">请求路径</param>
        /// <param name="data">请求数据</param>
        /// <param name="header">请求头</param>
        /// <returns></returns>
        public static RpcTask StartPostAsync(string name, string pathAndQuery, byte[] data, Dictionary<string, string> header = null)

        /// <summary>
        /// 对远程服务发起一个异步Post请求。
        /// </summary>
        /// <param name="url">请求的地址</param>
        /// <param name="data">post的数据</param>
        /// <param name="header">可追加的请求头部分</param>
        /// <returns></returns>
        public static RpcTask StartPostAsync(string url, byte[] data, Dictionary<string, string> header = null)

    }
}

下面进行使用说明:

1、Rpc.GetHost(...)方法说明:

对于微服务而言,微服务一开就是好多个,不太应该用固定的host去访问。

因此,框架提供方法,可以根据微服务的注册名称,获得负载均衡下的其中一个host地址。

Rpc一般都在微服务应用中心(即客户端调用);

服务端(网关,或注册中心)一般不使用,但框架仍贴心的提供重载方法,以便服务端也可以使用。

框架提供此方法,获得请求Host后,使用者是可以根据情况,自行写代码调用,也可以使用以下框架封装好的代码。

2、RpcTask:方法间的调用(异步任务)

框架对ASP.NET、ASP.NET2.1-3.1-5、ASP.NET6及以上,分三种情景分别进行了优化封装。

并严格进行了并发(>1000)下的测试与优化,保障了并发下的顺畅不卡顿。

下面看使用示例方法:

1、Get请求:

    public class RpcController : Taurus.Mvc.Controller
    {
        static int i = 0;
        public void CallGet()
        {
            i++;
            RpcTask task = Rpc.StartGetAsync("ms", "/ms/hello?msg=" + DateTime.Now.Ticks);
            System.Diagnostics.Debug.WriteLine("-----------------------------" + i);
            //可以处理其它业务逻辑
            string text = task.Result.IsSuccess ? task.Result.ResultText : task.Result.ErrorText;
            RpcTaskState state = task.State;
            if (string.IsNullOrEmpty(text) || !task.Result.IsSuccess)
            {
                Response.StatusCode = 404;
            }
            Write(text);
        }
}

说明:

1、task.Wait(...)方法,可以手动执行异步等待。

2、task.Result(获取结果,内部也会进行等待返回)

2、Post请求:

public void CallPost()
        {

            i++;
            RpcTask task = Rpc.StartPostAsync("ms", "/ms/hello?id=" + DateTime.Now.Ticks, Encoding.UTF8.GetBytes("id=2&msg=" + DateTime.Now.Ticks));//,
            System.Diagnostics.Debug.WriteLine("-----------------------------" + i);
            task.Wait();
            string text = task.Result.IsSuccess ? task.Result.ResultText : task.Result.ErrorText;
            RpcTaskState state = task.State;
            if (string.IsNullOrEmpty(text) || !task.Result.IsSuccess)
            {
                Response.StatusCode = 404;
            }
            Write(text);
        }

3、Put请求:

        public void CallPut()
        {
            i++;
            RpcTask task = Rpc.StartTaskAsync(new RpcTaskRequest() { Method = "Put", Url = Rpc.GetHost("ms") + "/ms/hello2" });//,Encoding.UTF8.GetBytes("id=2&msg=" + DateTime.Now.Ticks)
            System.Diagnostics.Debug.WriteLine("-----------------------------" + i);
            task.Wait();
            string text = task.Result.IsSuccess ? task.Result.ResultText : task.Result.ErrorText;
            RpcTaskState state = task.State;
            if (string.IsNullOrEmpty(text) || !task.Result.IsSuccess)
            {

                Response.StatusCode = 404;
            }
            Write(text);
        }

4、Head请求:

        public void CallHead()
        {
            i++;
            RpcTask task = Rpc.StartTaskAsync(new RpcTaskRequest() { Method = "Head", Url = Rpc.GetHost("ms") + "/ms/hello2" });//,Encoding.UTF8.GetBytes("id=2&msg=" + DateTime.Now.Ticks)
            System.Diagnostics.Debug.WriteLine("-----------------------------" + i);
            task.Wait();
            string text = task.Result.IsSuccess ? CYQ.Data.Tool.JsonHelper.ToJson(task.Result.Header) : task.Result.ErrorText;
            RpcTaskState state = task.State;
            if (string.IsNullOrEmpty(text) || !task.Result.IsSuccess)
            {
                Response.StatusCode = 404;
            }
            Write(text);
        }

5、Delete请求:

        public void CallDelete()
        {

            i++;
            RpcTask task = Rpc.StartTaskAsync(new RpcTaskRequest() { Method = "Delete", Url = Rpc.GetHost("ms") + "/ms/hello2" });//,Encoding.UTF8.GetBytes("id=2&msg=" + DateTime.Now.Ticks)
            System.Diagnostics.Debug.WriteLine("-----------------------------" + i);
            task.Wait();
            string text = task.Result.IsSuccess ? task.Result.ResultText : task.Result.ErrorText;
            RpcTaskState state = task.State;
            if (string.IsNullOrEmpty(text) || !task.Result.IsSuccess)
            {

                if (state == RpcTaskState.Running)
                {
                    task.Wait();
                }
                Response.StatusCode = 404;
            }
            Write(text);
        }

3、测试运行准备:

 为了测试,程序启动了:

1、注册中心:(监听5000端口)

2、微服务模块(ms)模块:启动了两个:(随机端口)

3、微服务模块(rpc)模块,启动了1个:(监听4000端口)

示例是在rpc模块中,调用ms模块的服务: 代码即上述RpcTask中的CallGet的代码。 

4、测试运行结果:

Rpc调用:请求示例结果:(浏览器显示是2毫秒) 

Rpc模块请求时间:(控制台显示的请求时间,1.N毫秒左右):

MS模块(被调用者)请求时间:(ms模块执行业务请求的时间,每次都在1毫秒以内

总结:

1、框架Rpc架基于WebClient和HttpClient进行优化,主要优化点是进行端口和链接的复用。 

2、性能整体在预期内,在并发下(>1000)仍然稳定流畅。

3、使用简单。

标签:task,服务,string,Taurus,Rpc,MVC,Result
来源: https://www.cnblogs.com/cyq1162/p/16694749.html