服务与服务之间的调用

2021年9月2日 6点热度 0条评论 来源: 天天向上518

服务与服务之间的调用,

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

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("服务调用异常失败,请刷新再试!");
                }
            };
        }
    }
}

 

    原文作者:天天向上518
    原文地址: https://www.cnblogs.com/Fengge518/p/15216012.html
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。