智慧团建信息系统网站,青岛网站seo多少钱,做网页用什么编程语言,应用开发是什么0x00 简介
DotBPE.RPC是一款基于dotnet core编写的RPC框架#xff0c;而它的爸爸DotBPE#xff0c;目标是实现一个开箱即用的微服务框架#xff0c;但是它还差点意思#xff0c;还仅仅在构思和尝试的阶段。但不管怎么说RPC是微服务的基础#xff0c;先来讲讲RPC的实现吧。…0x00 简介
DotBPE.RPC是一款基于dotnet core编写的RPC框架而它的爸爸DotBPE目标是实现一个开箱即用的微服务框架但是它还差点意思还仅仅在构思和尝试的阶段。但不管怎么说RPC是微服务的基础先来讲讲RPC的实现吧。DotBPE.RPC底层通信默认实现基于DotNetty这是由微软Azure团队开发的C#的Netty实现非常酷。当然你也可以替换成其他Socket通信组件。DotBPE.RPC使用的默认协议名称叫Amp,编解码使用谷歌的Protobuf3,不过这些默认实现都是可以替换的。
源码地址https://github.com/xuanye/dotbpe.git
0x01 关于Amp协议和Google Protobuf
Amp(A Message Protocol)
Amp(A Message Protocol) ,中文名叫 一个消息协议 ,是DotBPE.RPC默认实现的消息协议在实际开发中其实是不需要了解消息是如何编解码和传输的但是了解协议有助于进一步了解框架。协议基本结构如下图所示: 0 1 2 3 4 5 6 7 8 9 10 11 12 13 length-14
-----------------------------------------------------------------
| ver/argc | length | seq |type|serId| msgid | data |
-----------------------------------------------------------------
Amp协议默认消息头长为14个字节不包含扩展包头第0位ver/argc // 为版本号暂时来说默认为0第1-4位: length //为包总长度含包头长度第5-8位: sequence // 为消息序列号通过该序列号对应 请求---响应第9位: type // 消息类型现值有5种如下: Request 1, Response 2, Notify 3,NotFound 4, ERROR 5第10-11位: serviceId//消息ID ushort类型第12-13位: msgId//消息ID ushort类型在Amp协议中serviceId标识一类请求类似应用中的模块而msgId标识模块中的具体方法 其后紧跟实际的数据
Google Protobuf
Google Protocol Buffer( 简称 Protobuf) 是 Google 公司内部的混合语言数据标准目前已经正在使用的有超过 48,162 种报文格式定义和超过 12,183 个 .proto 文件。他们用于 RPC 系统和持续数据存储系统。
Protocol Buffers 是一种轻便高效的结构化数据存储格式可以用于结构化数据串行化或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。目前提供了 多种语言的API包括C、 C# 、GO、 JAVA、 PYTHON
我在之前的博客使用CSharp编写Google Protobuf插件中有过介绍如果通过编写插件的方式来通过定义proto文件并生成我们需要的代码。
在DotBPE.RPC 中我使用protobuf来作为服务的描述文件并通过自定义的插件方式来生成服务端和客户端代理类。
0x02 快速开始
0. 前提 因为DotBPE是基于dotnet core开发的你本地必须已经有了dotnet core开发环境使用github托管代码所以你必须已经安装了git客户端需要通过protoc生成模板代码所以你必须已经安装了google protobuf命令行工具 1. 下载示例程序
为了能够解释我们的快速开始程序你需要一份本地能够运行的示例代码。从github上下载我已经写好的示例代码可以让你快速的搭建程序免去一些繁琐但是又必须的步骤。
$ # Clone the repository to get the example code: $ git clone https://github.com/xuanye/dotbpe-sample.git
$ cd dotbpe-sample
使用VS2017或者VSCode打开下载好的代码目录结构如下所示 frameborder0 scrollingno styleborder-width: medium; width: 428px; height: 490px;
如果你使用VS2017 可以自动帮你还原如果使用VSCode的话 需要运行dotnet restore 下载依赖成功后使用dotnet build 编译一下看看结果看着很完美 frameborder0 scrollingno styleborder-width: medium; width: 960px; height: 304px;
2. 运行程序
运行Server
$ cd HelloDotBPE.Server $ dotnet run
运行Client
$ cd HelloDotBPE.Client $ dotnet run
恭喜已经使用DotBPE.RPC运行一个Server/Client的应用程序。
3. 来一起看一下代码吧
3.1 服务描述文件proto
首先是DotBPE.RPC框架中对proto的扩展文件所有的项目都需要这个文件关于如何扩展proto我的这篇博客有比较详细的介绍,这里就不重复说了
//dotbpe_option.proto 文件syntax proto3;package dotbpe;option csharp_namespace DotBPE.ProtoBuf;import google/protobuf/descriptor.proto;//扩展服务extend google.protobuf.ServiceOptions { int32 service_id 51001; bool disable_generic_service_client 51003; //禁止生成客户端代码bool disable_generic_service_server 51004; //禁止生成服务端代码}
extend google.protobuf.MethodOptions { int32 message_id 51002;
}extend google.protobuf.FileOptions { bool disable_generic_services_client 51003; //禁止生成客户端代码bool disable_generic_services_server 51004; //禁止生成服务端代码bool generic_markdown_doc 51005; //是否生成文档 本示例中无用bool generic_objectfactory 51006; //是否生成objectfactory 本示例中无用}
下面的服务描述文件 greeter.proto 才是真正的示例的服务描述文件比较简单定义一个Greeter Rpc服务并定义一个Hello的方法
//greeter.protosyntax proto3;
package dotbpe;option csharp_namespace HelloDotBPE.Common;// 引入扩展import public dotbpe_option.proto;// 定义一个服务service Greeter {option (service_id) 100 ;//消息ID全局必须唯一// Sends a greetingrpc Hello (HelloRequest) returns (HelloResponse) {option (message_id) 1 ;//设定消息ID同一服务内唯一}}// The request message containing the users name.message HelloRequest { string name 1;
}// The response message containing the greetingsmessage HelloResponse { string message 1;
}
通过protoc工具生成模板代码示例中的代码生成到了 HelloDotBPE.Common_g 目录下本地可以运行shell命令的同学可以直接到dotbpe-sample\script\generate 目录运行sh generate_hello.sh windows下一般安装cgywin不能运行的同学也可以在HelloDotBPE目录下直接运行命令行
protoc -I../protos --csharp_out./HelloDotBPE.Common/_g/ --dotbpe_out./HelloDotBPE.Common/_g/ ../protos/dotbpe_option.proto ../protos/greeter.proto --pluginprotoc-gen-dotbpe../../tool/protoc_plugin/Protobuf.Gen.exe
当然我还是建议大家安装以下cgywin运行环境可以运行unix上的一些常用命令。同时在部署到正式环境的时候可以公用开发环境的一些脚本。
3.2 服务端代码
服务实现
// 服务实现代码public class GreeterImpl : GreeterBase { public override TaskHelloResponse HelloAsync(HelloRequest request) { // 直接返回Hello Namereturn Task.FromResult(new HelloResponse() { Message Hello request.Name });}
}
服务端启动类 public class Startup : IStartup{ public void Configure(IAppBuilder app, IHostingEnvironment env) {} public IServiceProvider ConfigureServices(IServiceCollection services) {services.AddDotBPE(); // 添加DotBPE.RPC的核心依赖services.AddServiceActorsAmpMessage(actors {actors.AddGreeterImpl(); // 注册服务实现}); return services.BuildServiceProvider();}}
启动服务端 class Program{ static void Main(string[] args) {Console.OutputEncoding System.Text.Encoding.UTF8; //在控制台输出调试日志DotBPE.Rpc.Environment.SetLogger(new DotBPE.Rpc.Logging.ConsoleLogger()); var host new RpcHostBuilder().UseServer(0.0.0.0:6201) //绑定本地端口6201.UseStartupStartup().Build();host.StartAsync().Wait();Console.WriteLine(Press any key to quit!);Console.ReadKey();host.ShutdownAsync().Wait();}}
3.3 客户端代码 class Program{ static void Main(string[] args) {Console.OutputEncoding Encoding.UTF8; var client AmpClient.Create(127.0.0.1:6201); //建立链接通道var greeter new GreeterClient(client); //客户端代理类while (true){Console.WriteLine(input your name and press enter:); string name Console.ReadLine(); if (bye.Equals(name)){ break;} try{ var request new HelloRequest() { Name name }; var result greeter.HelloAsync(request).Result; Console.WriteLine($---------------receive form server:{result.Message}-----------);} catch (Exception ex){Console.WriteLine(发生错误 ex.Message);}}Console.WriteLine($---------------close connection-----------);client.CloseAsync();}}
0x03 下一步
下一篇 我将详细讲述DotBPE.RPC中的主要类和调用关系并介绍如何使用DotNetty实现RPC通信。事实上我正在编写一个更加复杂的示例https://github.com/xuanye/PiggyMetrics.git这原是spring cloud的一个示例程序我使用DotBPE进行改造用示例描述DotBPE在真实场景中的应用。包括服务注册和发现服务间调用公开HttpApi监控检查等功能并通过实践进一步完善DotBPE。初步的功能已经实现不过还没来的及写文档。该系列的后面将详细描述该系统的实现。 原文地址http://www.cnblogs.com/xuanye/p/a-dotnet-core-rpc-sln-dotbpe-quickstart.html .NET社区新闻深度好文微信中搜索dotNET跨平台或扫描二维码关注
