-------------------------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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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

系统目录：

前言：