(11)学习笔记 ) ASP.NET CORE微服务 Micro-Service ---- Thrift高效通讯 (完结)

本文涉及的产品
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 一、 什么是 RPC Restful 采用 Http 进行通讯,优点是开放、标准、简单、兼容性升级容易; 缺点是性能略低。在 QPS 高或者对响应时间要求苛刻的服务上,可以用 RPC(Remote Procedure Call),RPC 由于采用二进制传输、TCP 通讯,所以通常性能更好。

一、 什么是 RPC

Restful 采用 Http 进行通讯,优点是开放、标准、简单、兼容性升级容易;

缺点是性能略低。在 QPS 高或者对响应时间要求苛刻的服务上,可以用 RPC(Remote Procedure Call),RPC 由于采用二进制传输、TCP 通讯,所以通常性能更好。

.Net Core 下的 RPC(远程方法调用)框架有 gRPC、Thrift 等,都支持主流的编程语言。

RPC 虽然效率略高,但是耦合性强,如果兼容性处理不好的话,一旦服务器端接口升级,客户端就要更新,即使是增加一个参数,而 rest 则比较灵活。

最佳实践:对内一些性能要求高的场合用 RPC,对内其他场合以及对外用 Rest。比如 web 服务器和视频转码服务器之间通讯可以用 restful 就够了,转账接口用 RPC 性能会更高一些。 

二、 Thrift 基本使用

参考资料:https://www.cnblogs.com/focus-lei/p/8889389.html

1、  下载thrift http://thrift.apache.org/

把thrift-***.exe解压到磁盘,改名为thrift.exe(用起来方便一些)

2、  编写一个UserService.thrift文件(IDL) 

namespace csharp RuPeng.ThriftTest1.Contract
service UserService{ SaveResult Save(
1:User user)
User Get(1:i32 id)
list<User> GetAll() } enum SaveResult {
SUCCESS = 0, FAILED = 1, }

struct User { 1: required i64 Id; 2: required string Name;
3: required i32 Age; 4: optional bool IsVIP; 5: optional string Remark; }

service定义的是服务类,enum 是枚举,struct是传入或者传出的复杂数据类型(支持对象级联)。

语法规范 http://thrift.apache.org/docs/idl

 

根据thrift语法生成C#代码

cmd -> thrift.exe -gen csharp UserService.thrift

创建一个类库项目 ThriftTest1.Contract,作为客户端和服务器之间的共用协议,把上一步生成的代码放进项目。

项目nuget安装apache-thrift-netcore:

Install-Package apache-thrift-netcore

3、 创建服务器端项目 ThriftTest1.Server,建一个控制台项目(放到 web 项目中或者在 Linux中用守护进程运行起来(SuperVisor等,类似Windows下的“Windows服务”)也可以)。

ThriftTest1.Server项目引用ThriftTest1.Contract

创建项目:ApplicationExtenssion.cs

编写实现类 UserServiceImpl.cs

public class UserServiceImpl : UserService.Iface
{
    public User Get(int id)
    {
        User u = new User();
        u.Id = id;
        u.Name = "用户" + id;
        u.Age = 6; return u;
    }

    public List<User> GetAll()
    {
        List<User> list = new List<User>();
        list.Add(new User { Id = 1, Name = "yzk", Age = 18, Remark = "hello" });
        list.Add(new User { Id = 2, Name = "rupeng", Age = 6 });
        return list;
    }

    public SaveResult Save(User user)
    {
        Console.WriteLine($"保存用户,{user.Id}"); return SaveResult.SUCCESS;
    }
}

修改Program下的Main函数 启动服务器端

TServerTransport transport = new TServerSocket(8800);//监听8800端口
var processor = new RuPeng.ThriftTest1.Contract.UserService.Processor(new UserServiceImpl());//设置实现类
TServer server = new TThreadPoolServer(processor, transport);
server.Serve();

监听8800端口

4、创建客户端项目也引用ThriftTest1.Contract项目

调用方法

using (TTransport transport = new TSocket("localhost", 8800))
    using (TProtocol protocol = new TBinaryProtocol(transport))
    using (var clientUser = new UserService.Client(protocol))
{
    transport.Open();
    User u = clientUser.Get(1);
    Console.WriteLine($"{u.Id},{u.Name}");
}

 三、一个服务器中放多个服务

0.9.1之前只支持一个服务器一个服务,这也是建议的做法。之后支持多路服务在thrift中增加一个服务

修改UserService.thrift文件 添加以下内容 然后重新生成替换

service CalcService{ 
     i32 Add(1:i32 i1,2:i32 i2)
}

服务器:

1.创建CalcServiceImpl文件实现CalcService服务

2.修改Main方法如下:

TServerTransport transport = new TServerSocket(8800);
var processorUserService = new RuPeng.ThriftTest1.Contract.UserService.Processor(new UserServiceImpl())
var processorCalcService = new RuPeng.ThriftTest1.Contract.CalcService.Processor(new CalcServiceImpl());
var processorMulti = new TMultiplexedProcessor();
processorMulti.RegisterProcessor("userService", processorUserService);
processorMulti.RegisterProcessor("calcService", processorCalcService);
TServer server = new TThreadPoolServer(processorMulti, transport);
server.Serve();

客户端:

using (TTransport transport = new TSocket("localhost", 8800))
    using (TProtocol protocol = new TBinaryProtocol(transport))
    using (var protocolUserService = new TMultiplexedProtocol(protocol, "userService"))
    using (var clientUser = new UserService.Client(protocolUserService))
    using (var protocolCalcService = new TMultiplexedProtocol(protocol,"calcService"))
    using (var clientCalc = new CalcService.Client(protocolCalcService))
{
    transport.Open();
    User u = clientUser.Get(1);
    Console.WriteLine($"{u.Id},{u.Name}");
    Console.WriteLine(clientCalc.Add(1, 2));
}

 

 https://www.cnblogs.com/focus-lei/p/8889389.html

(*)新版:thrift.exe -gen netcore UserService.thrift(支持.net Core)

貌似支持还不完善(http://www.cnblogs.com/zhaiyf/p/8351361.html )还不能用,编译也有问题,值得期待的是:支持异步。

四、Java 等其他语言的融入

和使用Restful做服务一样,Java也可以调用、也可以做Thrift服务,演示一下java调用c#写的Thrift服务的例子

Java编译器版本需要>=1.6

Maven添加组件包的支持(thrift maven版本一定要和生成代码的thrift的版本一致):

<dependency>

  <groupId>org.apache.thrift</groupId>

  <artifactId>libthrift</artifactId>

  <version>0.11.0</version>

</dependency>

<dependency>

  <groupId>org.slf4j</groupId>

  <artifactId>slf4j-log4j12</artifactId>

  <version>1.7.5</version>

</dependency>

在thrift的IDL文件中加入一行(各个语言的namespace等参数可以共存)

修改UserService.thrift文件 添加以下代码就可以控制生成的java类的报名,最好按照java的命名规范来。

namespace java com.rupeng.thriftTest1.contract 

 产生java代码

thrift.exe -gen java UserService.thrift 

Java代码:

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
public class Main {
  public static void main(String[] args) throws Exception {
      System.out.println("客户端启动....");
      TTransport transport = new TSocket("localhost", 8800, 30000);        
      TProtocol protocol = new TBinaryProtocol(transport);        
      UserService.Client client = new UserService.Client(protocol);        
      transport.open();
      User result = client.Get(1);
      System.out.println(result.getAge()+result.getName()+result.getRemark());
   }
}

也可以用Java写服务器,C#调用。当然别的语言也可以。

接口设计原则“API design is like sex: Make one mistake and support it for the rest of your life”

五、 Thrift+Consul 服务发现

注册和发现和Rest方式没有什么区别。

consul支持tcp健康监测:https://www.consul.io/docs/agent/checks.html

因为 Thrift 一般不对外,所以一般不涉及和 API 网关结合的问题 

gRPC 的优势:支持异步;支持 Http2。没有Thrift性能高

总结

回顾一下我们学到的微服务:服务治理和服务发现、熔断降级、API 网关。

不是所有项目都适合微服务架构,互联网项目及结构复杂的企业信息系统才可以考虑微服务架构。

设计微服务架构,模块拆分的原则:可以独立运行,尽量服务间不要依赖,即使依赖层级也不要太深,不要想着还要 join。按业务划分、按模块划分。

 

扩展知识:

1、    分布式跟踪、日志服务、监控等对微服务来说非常重要 

2、    gRPC 另外一个 RPC 框架,gRPC 的.Net Core 支持异步。百度“.net core grpc” https://www.jianshu.com/p/f5e1c002047a

3、    https://github.com/neuecc/MagicOnion 可以参考下这位日本 mvp 写的 grpc 封装,不需要定义接口文件。

4、    nanofabric https://github.com/geffzhang/NanoFabric简单分析

5、    Surging https://github.com/dotnetcore/surging

6、    service  fabric

https://azure.microsoft.com/zh-cn/documentation/learning-paths/service-fabric/

7、    Spring Cloud 入门视频:http://www.rupeng.com/Courses/Chapter/755

8、    steeltoe http://steeltoe.io/ 参    考    文    章

https://mp.weixin.qq.com/s/g9w-qgT2YHyDX8OE5q-OHQ

9、    限流算法 https://mp.weixin.qq.com/s/bck0Q2lDj_J9pLhFEhqm9w 

10、https://github.com/PolicyServer/PolicyServer.Local 认证 + 授权 是两个服务, identityserver 解决了认证 ,PolicyServer 解决授权 

11、Using Polly with HttpClient  factory from  ASPNET Core 2.1

https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory

12、CSharpKit 微服务工具包 http://www.csharpkit.com/

现在的努力只是为了更好的将来,将来你一定不会后悔你现在的努力。一起加油吧!!!
C#/.NetCore技术交流群:608188505  欢迎加群交流
如果您认为这篇文章还不错或者有所收获,您可以点击右下角的【推荐】按钮精神支持,因为这种支持是我继续写作,分享的最大动力!
相关文章
|
14天前
|
开发框架 .NET 开发者
简化 ASP.NET Core 依赖注入(DI)注册-Scrutor
Scrutor 是一个简化 ASP.NET Core 应用程序中依赖注入(DI)注册过程的开源库,支持自动扫描和注册服务。通过简单的配置,开发者可以轻松地从指定程序集中筛选、注册服务,并设置其生命周期,同时支持服务装饰等高级功能。适用于大型项目,提高代码的可维护性和简洁性。仓库地址:&lt;https://github.com/khellang/Scrutor&gt;
36 5
|
2月前
|
存储 开发框架 JSON
ASP.NET Core OData 9 正式发布
【10月更文挑战第8天】Microsoft 在 2024 年 8 月 30 日宣布推出 ASP.NET Core OData 9,此版本与 .NET 8 的 OData 库保持一致,改进了数据编码以符合 OData 规范,并放弃了对旧版 .NET Framework 的支持,仅支持 .NET 8 及更高版本。新版本引入了更快的 JSON 编写器 `System.Text.UTF8JsonWriter`,优化了内存使用和序列化速度。
|
1月前
|
开发框架 .NET C#
在 ASP.NET Core 中创建 gRPC 客户端和服务器
本文介绍了如何使用 gRPC 框架搭建一个简单的“Hello World”示例。首先创建了一个名为 GrpcDemo 的解决方案,其中包含一个 gRPC 服务端项目 GrpcServer 和一个客户端项目 GrpcClient。服务端通过定义 `greeter.proto` 文件中的服务和消息类型,实现了一个简单的问候服务 `GreeterService`。客户端则通过 gRPC 客户端库连接到服务端并调用其 `SayHello` 方法,展示了 gRPC 在 C# 中的基本使用方法。
41 5
在 ASP.NET Core 中创建 gRPC 客户端和服务器
|
22天前
|
开发框架 缓存 .NET
GraphQL 与 ASP.NET Core 集成:从入门到精通
本文详细介绍了如何在ASP.NET Core中集成GraphQL,包括安装必要的NuGet包、创建GraphQL Schema、配置GraphQL服务等步骤。同时,文章还探讨了常见问题及其解决方法,如处理复杂查询、错误处理、性能优化和实现认证授权等,旨在帮助开发者构建灵活且高效的API。
24 3
|
2月前
|
消息中间件 网络协议 API
微服务之间是如何独立通讯的?
微服务之间独立通讯主要依靠定义清晰的API协议、使用轻量级交互机制、以及通过服务发现机制维持服务间连接。微服务体系结构中,每个服务都设计为独立部署的单元,它们通过网络调用彼此的API以实现互操作。
53 0
|
2月前
|
开发框架 JavaScript 前端开发
一个适用于 ASP.NET Core 的轻量级插件框架
一个适用于 ASP.NET Core 的轻量级插件框架
|
1月前
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
130 6
|
1月前
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
51 1
|
20天前
|
Java 开发者 微服务
从单体到微服务:如何借助 Spring Cloud 实现架构转型
**Spring Cloud** 是一套基于 Spring 框架的**微服务架构解决方案**,它提供了一系列的工具和组件,帮助开发者快速构建分布式系统,尤其是微服务架构。
141 68
从单体到微服务:如何借助 Spring Cloud 实现架构转型
|
19天前
|
运维 监控 持续交付
微服务架构解析:跨越传统架构的技术革命
微服务架构(Microservices Architecture)是一种软件架构风格,它将一个大型的单体应用拆分为多个小而独立的服务,每个服务都可以独立开发、部署和扩展。
149 36
微服务架构解析:跨越传统架构的技术革命