服务与服务之间的调用

服务与服务之间的调用，

解决方案目前比较流行的有

1：基于rpc,如微软推荐的：grpc，创建grpc服务后可以生成proco等文件

1：什么是GRPC？
gRPC是与语言无关的高性能远程过程调用（RPC）框架。谷歌开发的grpc技术框架，C#端由微软的员工来维护升级

2: 使用GRPC有啥好处？
合同优先的API开发，默认情况下使用协议缓冲区，允许使用与语言无关的实现。
可用于多种语言的工具，以生成强类型的服务器和客户端。
支持客户端，服务器和双向流呼叫。
通过Protobuf二进制序列化减少网络使用。

GRPC的主要优点是：
GRPC是与语言无关的高性能远程过程调用（RPC）框架。
现代，高性能，轻量级的RPC框架。
效率至关重要的轻量级微服务。
开发需要多种语言的多语言系统。
需要处理流式请求或响应的点对点实时服务。

3：啥时候使用和不建议使用GRPC？
直播,聊天等不适合

4：使用GRPC的步骤
***************下次整理写一个案例，目前网络上有很多可以参考，长时间不使用容易忘记**************
这次决定还是不使用GRPC,虽然效率上高一些，还得再多搞一个服务和通用的配置出来，而且如果服务多配置文件也会比较多，
配置上也感觉不是很喜欢，所以就使用比较传统的方案二

2：网络请求的工具，如系统自带的 IHttpClientFactory(从.NetCore 2.1官方已经优化),不是HttpClient（缺点可以网络上查询）

get请求

get测试效果截图：

post请求

post测试效果截图：

调用的步骤为：服务07调用06的服务，本地测试为ip一致，但是端口不一致，模拟不同的服务之间的调用

为啥要这样设计？
1：首先将各个服务的host如：http://localhost:8081等等都写在appsetting配置文件中，
   这样方便维护和修改，一处修改处处修改的效果，修改替换后也不需要构建镜像再发布，直接Docker重启即可。

2：获取配置信息：采用枚举+常量+静态类，清晰明了，使用时不用到处声明变量，避免多次申请内存空间，提升系统执行效率。

3：基于第二点，有枚举，选择调用哪一个服务时方便高效点出来，
   HttpFactoryClient网络请求为优化后的解决方案，不用担心之前的版本Tcp/ip资源不能及时释放，而导致无资源可调用，因为已经内置pool池化。

code主要代码如下：

using GDBS.Shared.Data;
using GDBS.Shared.Data.Const;

using Microsoft.AspNetCore.Http;

using Newtonsoft.Json;

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;

namespace GDBS.Shared.ToolKits.Tool
{
    /// <summary>
    /// 跨服务 WebApi部分帮助类 jason  待进一步完善
    /// </summary>
    public class HttpClientHelper
    {

        private static string GetHostStrByConst(PlatFormEnum optionEnum)
        {
            string gethost = string.Empty;
            switch (optionEnum)
            {
                case PlatFormEnum.BridgeService:
                    gethost = PlatFormApiHostOptions.BridgeService;
                    break;
                case PlatFormEnum.GdbsProjectService:
                    gethost = PlatFormApiHostOptions.GdbsProjectService;
                    break;
                case PlatFormEnum.ReceAndSendMsgService:
                    gethost = PlatFormApiHostOptions.ReceAndSendMsgService;
                    break;
                case PlatFormEnum.ProvincialLevelService:
                    gethost = PlatFormApiHostOptions.ProvincialLevelService;
                    break;
                case PlatFormEnum.ThirdPartyService:
                    gethost = PlatFormApiHostOptions.ThirdPartyService;
                    break;
                case PlatFormEnum.MonitoringService:
                    gethost = PlatFormApiHostOptions.MonitoringService;
                    break;
                case PlatFormEnum.LogService:
                    gethost = PlatFormApiHostOptions.LogService;
                    break;
                default:
                    gethost = PlatFormApiHostOptions.BridgeService;
                    break;
            }
            return gethost;
        }

        /// <summary>
        ///  服务之间的网络请求，PostAsync异步处理
        /// </summary>
        /// <typeparam name="T">T 通常返回的实体数据</typeparam>
        /// <param name="_httpContext">请求上下文</param>
        /// <param name="_httpClientFactory">网络请求对象</param>
        /// <param name="hostEnum">服务枚举的一个域名，如：http://localhost:8081</param>
        /// <param name="requestApiUrlPath">服务的具体请求地址,开头为：/api/....如：/api/ReceAndSendMsgService/abc/testapi</param>
        /// <param name="dataDto">有数据的话约定为一个实体对象 如：var datatDto = new { Id = 1001, Name = "LMZ",Age=18 }</param>
        /// <param name="timeOut">默认连接超时时间为50秒</param>
        /// <paramref name="returnModel">默认true：返回实体数据；false：返回字符串</paramref>
        /// <returns></returns>
        public static async Task<T> PostAsync<T>(IHttpClientFactory _httpClientFactory, HttpContext _httpContext, string requestApiUrlPath, PlatFormEnum hostEnum = PlatFormEnum.BridgeService, object dataDto = null, int timeOut = 50)
        {
            if (string.IsNullOrEmpty(requestApiUrlPath))
                throw new Exception("请求服务的具体接口地址不可以为空!");
            if (!requestApiUrlPath.Contains("/api"))
                throw new Exception("接口地址错误，应该为如：/api/AbcService/****");
            string content = dataDto != null ? JsonConvert.SerializeObject(dataDto) : "0";
            var jsonDataStr = new StringContent(content, Encoding.UTF8, WebApiHeaderStrConst.Head_MediaType);
            var authVal = _httpContext.Request.Headers[WebApiHeaderStrConst.Head_Authorization].ToString().Replace(WebApiHeaderStrConst.Head_Authorization, "");
            using var client = _httpClientFactory.CreateClient();
            client.DefaultRequestHeaders.Add(WebApiHeaderStrConst.Head_Authorization, authVal);
            var connectTimeOut = timeOut <= 0 || timeOut > 180 ? 50 : timeOut;
            client.Timeout = TimeSpan.FromSeconds(connectTimeOut);
            var host = GetHostStrByConst(hostEnum);
            //string requesturl = $"{host}{requestApiUrlPath}";
            using (var httpResponseMsg = await client.PostAsync($"{host}{requestApiUrlPath}", jsonDataStr))
            {
                if (httpResponseMsg.IsSuccessStatusCode)
                {
                    var getstr = await httpResponseMsg.Content.ReadAsStringAsync();
                    Console.WriteLine("getStr=" + getstr);
                    return JsonConvert.DeserializeObject<T>(getstr);
                }
                else
                {
                    throw new Exception("服务调用异常失败，请刷新再试!");
                }
            };
        }

        /// <summary>
        /// 服务之间的网络请求，GetAsync异步处理
        /// </summary>
        /// <param name="_httpContext">请求上下文</param>
        /// <param name="_httpClientFactory">网络请求对象</param>
        /// <param name="hostEnum">服务枚举的一个域名，如：http://localhost:8081</param>
        /// <param name="RequestApiUrlPath">服务的具体请求地址,开头为：/api/.... 如：/api/ReceAndSendMsgService/abc/testapi</param>
        /// <param name="RequestDataDic">传输的数据字典 Dictionary<string, object> </param>
        /// <param name="timeOut">默认连接超时时间为50秒</param>
        /// <paramref name="returnModel">默认true：返回实体数据；false：返回字符串</paramref>
        /// <returns></returns>
        public static async Task<T> GetAsync<T>(IHttpClientFactory _httpClientFactory, HttpContext _httpContext, string RequestApiUrlPath, PlatFormEnum hostEnum = PlatFormEnum.BridgeService, Dictionary<string, object> RequestDataDic = null, int timeOut = 50, bool returnModel = true)
        {
            if (string.IsNullOrEmpty(RequestApiUrlPath))
                throw new Exception("请求服务的具体接口地址不可以为空!");
            if (!RequestApiUrlPath.Contains("/api"))
                throw new Exception("接口地址错误，应该为如：/api/AbcService/****");
            using var client = _httpClientFactory.CreateClient();
            var authVal = _httpContext.Request.Headers[WebApiHeaderStrConst.Head_Authorization].ToString().Replace(WebApiHeaderStrConst.Head_Authorization, "");
            client.DefaultRequestHeaders.Add(WebApiHeaderStrConst.Head_Authorization, authVal);
            var connectTimeOut = timeOut <= 0 || timeOut > 180 ? 50 : timeOut;
            client.Timeout = TimeSpan.FromSeconds(connectTimeOut);
            var sb = new StringBuilder();
            if (RequestDataDic != null)
            {
                foreach (var dickey in RequestDataDic.Keys)
                    sb.Append($"&{dickey}={RequestDataDic[dickey]}");
            }
            var host = GetHostStrByConst(hostEnum);
            string requestData = $"{host}{RequestApiUrlPath}?lmz_temp=0{sb}";
            using (var httpResponseMsg = await client.GetAsync(requestData))
            {
                if (httpResponseMsg.IsSuccessStatusCode)
                {
                    var getstr = await httpResponseMsg.Content.ReadAsStringAsync();
                    Console.WriteLine("getStr=" + getstr + ", sbdata=" + sb);
                    return JsonConvert.DeserializeObject<T>(getstr);
                }
                else
                {
                    throw new Exception("服务调用异常失败，请刷新再试!");
                }
            };
        }
    }
}

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/63941.html

服务与服务之间的调用

相关推荐